欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

如何自定義Mybatis-Plus分布式ID生成器(解決ID長(zhǎng)度超過(guò)JavaScript整數(shù)安全范圍問(wèn)題)

 更新時(shí)間:2024年08月06日 09:27:06   作者:”P(pán)ANDA  
MyBatis-Plus默認(rèn)生成的是 64bit 長(zhǎng)整型,而 JS 的 Number 類(lèi)型精度最高只有 53bit,這篇文章主要介紹了如何自定義Mybatis-Plus分布式ID生成器(解決ID長(zhǎng)度超過(guò)JavaScript整數(shù)安全范圍問(wèn)題),需要的朋友可以參考下

自定義MyBatis-Plus分布式ID生成器(解決ID長(zhǎng)度超過(guò)JavaScript整數(shù)安全范圍問(wèn)題)

版本

MyBatis-Plus 3.4.1

問(wèn)題

MyBatis-Plus 默認(rèn)生成的是 64bit 長(zhǎng)整型,而 JS 的 Number 類(lèi)型精度最高只有 53bit,如果以 Long 類(lèi)型 ID 和前端 JS 進(jìn)行交互,會(huì)出現(xiàn)精度丟失(最后兩位數(shù)字變成 00) 而導(dǎo)致最終系統(tǒng)報(bào)錯(cuò)。

解決方案

一種方案是在響應(yīng)前端時(shí),將 ID 轉(zhuǎn)換成 String 類(lèi)型返回,但這個(gè)方法治標(biāo)不治本,因此最終通過(guò)采用截短 ID 長(zhǎng)度,以避免 ID 超過(guò) JS 整數(shù)安全范圍。

縮短雪花算法后空間劃分(可根據(jù)實(shí)際需求調(diào)整):
1. 高位 32bit 作為秒級(jí)時(shí)間戳, 時(shí)間戳減去固定值(2024 年時(shí)間戳)
2. 5bit 作為機(jī)器標(biāo)識(shí), 最高可部署 32 臺(tái)機(jī)器
3. 最后 16bit 作為自增序列, 單節(jié)點(diǎn)最高每秒 2^16 = 65536 個(gè) ID

代碼實(shí)現(xiàn)

通過(guò)實(shí)現(xiàn) MyBatis-Plus IdentifierGenerator 接口以自定義 ID 生成器

import com.baomidou.mybatisplus.core.incrementer.IdentifierGenerator;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
/**
 * 符合 JavaScript 整數(shù)安全范圍的自定義ID生成器
 *
 * @author PANDA
 */
@Slf4j
@Component
public class JsSafeIdGenerator implements IdentifierGenerator {
    /** 初始偏移時(shí)間戳 2024-01-01 */
    private static final long OFFSET = 1704067200L;
    /** 機(jī)器id (0~15 保留 16~31作為備份機(jī)器) */
    private static final long WORKER_ID;
    /** 機(jī)器id所占位數(shù) (5bit, 支持最大機(jī)器數(shù) 2^5 = 32)*/
    private static final long WORKER_ID_BITS = 5L;
    /** 自增序列所占位數(shù) (16bit, 支持最大每秒生成 2^16 = ?65536?) */
    private static final long SEQUENCE_ID_BITS = 16L;
    /** 機(jī)器id偏移位數(shù) */
    private static final long WORKER_SHIFT_BITS = SEQUENCE_ID_BITS;
    /** 自增序列偏移位數(shù) */
    private static final long OFFSET_SHIFT_BITS = SEQUENCE_ID_BITS + WORKER_ID_BITS;
    /** 機(jī)器標(biāo)識(shí)最大值 (2^5 / 2 - 1 = 15) */
    private static final long WORKER_ID_MAX = ((1 << WORKER_ID_BITS) - 1) >> 1;
    /** 備份機(jī)器ID開(kāi)始位置 (2^5 / 2 = 16) */
    private static final long BACK_WORKER_ID_BEGIN = (1 << WORKER_ID_BITS) >> 1;
    /** 自增序列最大值 (2^16 - 1 = ?65535) */
    private static final long SEQUENCE_MAX = (1 << SEQUENCE_ID_BITS) - 1;
    /** 發(fā)生時(shí)間回?fù)軙r(shí)容忍的最大回?fù)軙r(shí)間 (秒) */
    private static final long BACK_TIME_MAX = 1L;
    /** 上次生成ID的時(shí)間戳 (秒) */
    private static long lastTimestamp = 0L;
    /** 當(dāng)前秒內(nèi)序列 (2^16)*/
    private static long sequence = 0L;
    /** 備份機(jī)器上次生成ID的時(shí)間戳 (秒) */
    private static long lastTimestampBak = 0L;
    /** 備份機(jī)器當(dāng)前秒內(nèi)序列 (2^16)*/
    private static long sequenceBak = 0L;
    static {
        // 初始化機(jī)器ID 可配置文件獲取
        long workerId = 1;
        if (workerId < 0 || workerId > WORKER_ID_MAX) {
            throw new IllegalArgumentException(String.format("worker-id [%d] 越界, 有效范圍: 0 ~ %d ", workerId, WORKER_ID_MAX));
        }
        WORKER_ID = workerId;
    }
    @Override
    public synchronized Number nextId(Object entity) {
        return nextId(SystemClock.now() / 1000);
    }
    /**
     * 主機(jī)器自增序列
     * @param timestamp 當(dāng)前Unix時(shí)間戳
     * @return long
     */
    private static synchronized long nextId(long timestamp) {
        if (timestamp < lastTimestamp) {
            log.warn("時(shí)鐘回?fù)? 啟用備份機(jī)器ID: now: [{}] last: [{}]", timestamp, lastTimestamp);
            return nextIdBackup(timestamp);
        }
        if (timestamp != lastTimestamp) {
            lastTimestamp = timestamp;
            sequence = 0L;
        }
        if (0L == (++sequence & SEQUENCE_MAX)) {
            sequence--;
            return nextIdBackup(Math.max(timestamp, lastTimestampBak));
        }
        return ((timestamp - OFFSET) << OFFSET_SHIFT_BITS) | (WORKER_ID << WORKER_SHIFT_BITS) | sequence;
    }
    /**
     * 備份機(jī)器自增序列
     * @param timestamp 當(dāng)前Unix時(shí)間戳
     * @return long
     */
    private static long nextIdBackup(long timestamp) {
        if (timestamp < lastTimestampBak) {
            if (lastTimestampBak - (SystemClock.now() / 1000) <= BACK_TIME_MAX) {
                timestamp = lastTimestampBak;
            } else {
                throw new RuntimeException(String.format("時(shí)鐘回?fù)? now: [%d] last: [%d]", timestamp, lastTimestampBak));
            }
        }
        if (timestamp != lastTimestampBak) {
            lastTimestampBak = timestamp;
            sequenceBak = 0L;
        }
        if (0L == (++sequenceBak & SEQUENCE_MAX)) {
            return nextIdBackup(timestamp + 1);
        }
        return ((timestamp - OFFSET) << OFFSET_SHIFT_BITS) | ((WORKER_ID ^ BACK_WORKER_ID_BEGIN) << WORKER_SHIFT_BITS) | sequenceBak;
    }
}
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong;
/**
 * 緩存時(shí)間戳解決System.currentTimeMillis()高并發(fā)下性能問(wèn)題
 *
 * @author PANDA
 **/
public class SystemClock {
    private final long period;
    private final AtomicLong now;
    private SystemClock(long period) {
        this.period = period;
        this.now = new AtomicLong(System.currentTimeMillis());
        scheduleClockUpdating();
    }
    /**
     * 嘗試下枚舉單例法
     */
    private enum SystemClockEnum {
        SYSTEM_CLOCK;
        private SystemClock systemClock;
        SystemClockEnum() {
            systemClock = new SystemClock(1);
        }
        public SystemClock getInstance() {
            return systemClock;
        }
    }
    /**
     * 獲取單例對(duì)象
     * @return com.cmallshop.module.core.commons.util.sequence.SystemClock
     */
    private static SystemClock getInstance() {
        return SystemClockEnum.SYSTEM_CLOCK.getInstance();
    }
    /**
     * 獲取當(dāng)前毫秒時(shí)間戳
     * @return long
     */
    public static long now() {
        return getInstance().now.get();
    }
    /**
     * 起一個(gè)線程定時(shí)刷新時(shí)間戳
     */
    private void scheduleClockUpdating() {
        ScheduledThreadPoolExecutor scheduler = new ScheduledThreadPoolExecutor(1, runnable -> {
            Thread thread = new Thread(runnable, "System Clock");
            thread.setDaemon(true);
            return thread;
        });
        scheduler.scheduleAtFixedRate(() -> now.set(System.currentTimeMillis()), period, period, TimeUnit.MILLISECONDS);
    }
}

SpringBoot 項(xiàng)目中如何引用?

import com.baomidou.mybatisplus.core.config.GlobalConfig;
import lombok.RequiredArgsConstructor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
@RequiredArgsConstructor
public class MybatisPlusConfiguration {
    @Bean
    public GlobalConfig globalConfig() {
        GlobalConfig globalConfig = new GlobalConfig();
        globalConfig.setIdentifierGenerator(new JsSafeIdGenerator());
        return globalConfig;
    }
}

ID 映射字段添加 @TableId(type = IdType.ASSIGN_ID) 注解

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class Base implements Serializable {
    @TableId(type = IdType.ASSIGN_ID)
    private Long id;
}

到此這篇關(guān)于自定義Mybatis-Plus分布式ID生成器(解決ID長(zhǎng)度超過(guò)JavaScript整數(shù)安全范圍問(wèn)題)的文章就介紹到這了,更多相關(guān)Mybatis-Plus分布式ID生成器內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • IDEA中編寫(xiě)并運(yùn)行shell腳本的實(shí)現(xiàn)

    IDEA中編寫(xiě)并運(yùn)行shell腳本的實(shí)現(xiàn)

    這篇文章主要介紹了IDEA中編寫(xiě)并運(yùn)行shell腳本的實(shí)現(xiàn),文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2020-08-08
  • 詳解MyBatis 常用寫(xiě)法

    詳解MyBatis 常用寫(xiě)法

    MyBatis 是一款優(yōu)秀的持久層框架,它支持定制化 SQL、存儲(chǔ)過(guò)程以及高級(jí)映射。這篇文章給大家介紹了MyBatis 常用寫(xiě)法,感興趣的朋友跟隨小編一起看看吧
    2018-11-11
  • java.io.IOException:?UT010029:?Stream?is?closed異常分析及解決

    java.io.IOException:?UT010029:?Stream?is?closed異常分析及解決

    這篇文章主要給大家介紹了關(guān)于java.io.IOException:?UT010029:?Stream?is?closed異常分析及解決辦法,文中通過(guò)代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2024-02-02
  • 一篇文章帶你深入了解Java基礎(chǔ)(5)

    一篇文章帶你深入了解Java基礎(chǔ)(5)

    這篇文章主要給大家介紹了關(guān)于Java中方法使用的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2021-08-08
  • 基于java springboot + mybatis實(shí)現(xiàn)電影售票管理系統(tǒng)

    基于java springboot + mybatis實(shí)現(xiàn)電影售票管理系統(tǒng)

    這篇文章主要介紹了基于java springboot + mybatis實(shí)現(xiàn)的完整電影售票管理系統(tǒng)基于java springboot + mybatis,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2021-08-08
  • Java對(duì)象比較之equals與hashCode詳解

    Java對(duì)象比較之equals與hashCode詳解

    這篇文章主要介紹了Java對(duì)象比較之equals與hashCode詳解,equals?方法和?hashCode?方法是?Object?類(lèi)中的兩個(gè)基礎(chǔ)方法,它們共同協(xié)作來(lái)判斷兩個(gè)對(duì)象是否相等,需要的朋友可以參考下
    2023-12-12
  • RestTemplate對(duì)HttpClient的適配源碼解讀

    RestTemplate對(duì)HttpClient的適配源碼解讀

    這篇文章主要為大家介紹了RestTemplate對(duì)HttpClient的適配源碼解讀,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-10-10
  • Java版C語(yǔ)言版簡(jiǎn)單使用靜態(tài)語(yǔ)言實(shí)現(xiàn)動(dòng)態(tài)數(shù)組的方法

    Java版C語(yǔ)言版簡(jiǎn)單使用靜態(tài)語(yǔ)言實(shí)現(xiàn)動(dòng)態(tài)數(shù)組的方法

    本文給大家分享java版和C語(yǔ)言版簡(jiǎn)單使用靜態(tài)語(yǔ)言實(shí)現(xiàn)動(dòng)態(tài)數(shù)組的方法,非常不錯(cuò),具有參考借鑒價(jià)值,需要的朋友參考下吧
    2017-10-10
  • Spring擴(kuò)展點(diǎn)之BeanFactoryPostProcessor詳解

    Spring擴(kuò)展點(diǎn)之BeanFactoryPostProcessor詳解

    這篇文章主要介紹了Spring擴(kuò)展點(diǎn)之BeanFactoryPostProcessor詳解,Spring的設(shè)計(jì)非常優(yōu)雅,有很多的擴(kuò)展點(diǎn)供我們對(duì)項(xiàng)目進(jìn)行擴(kuò)展,今天學(xué)習(xí)一下Spring其中擴(kuò)展點(diǎn)之一的BeanFactoryPostProcessor,需要的朋友可以參考下
    2023-11-11
  • 詳解如何在SpringBoot里使用SwaggerUI

    詳解如何在SpringBoot里使用SwaggerUI

    本篇文章主要介紹了詳解如何在SpringBoot里使用SwaggerUI,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧
    2018-02-02

最新評(píng)論