最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

如何自定義Mybatis-Plus分布式ID生成器(解決ID長度超過JavaScript整數安全范圍問題)

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

自定義MyBatis-Plus分布式ID生成器(解決ID長度超過JavaScript整數安全范圍問題)

版本

MyBatis-Plus 3.4.1

問題

MyBatis-Plus 默認生成的是 64bit 長整型,而 JS 的 Number 類型精度最高只有 53bit,如果以 Long 類型 ID 和前端 JS 進行交互,會出現精度丟失(最后兩位數字變成 00) 而導致最終系統(tǒng)報錯。

解決方案

一種方案是在響應前端時,將 ID 轉換成 String 類型返回,但這個方法治標不治本,因此最終通過采用截短 ID 長度,以避免 ID 超過 JS 整數安全范圍。

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

代碼實現

通過實現 MyBatis-Plus IdentifierGenerator 接口以自定義 ID 生成器

import com.baomidou.mybatisplus.core.incrementer.IdentifierGenerator;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
/**
 * 符合 JavaScript 整數安全范圍的自定義ID生成器
 *
 * @author PANDA
 */
@Slf4j
@Component
public class JsSafeIdGenerator implements IdentifierGenerator {
    /** 初始偏移時間戳 2024-01-01 */
    private static final long OFFSET = 1704067200L;
    /** 機器id (0~15 保留 16~31作為備份機器) */
    private static final long WORKER_ID;
    /** 機器id所占位數 (5bit, 支持最大機器數 2^5 = 32)*/
    private static final long WORKER_ID_BITS = 5L;
    /** 自增序列所占位數 (16bit, 支持最大每秒生成 2^16 = ?65536?) */
    private static final long SEQUENCE_ID_BITS = 16L;
    /** 機器id偏移位數 */
    private static final long WORKER_SHIFT_BITS = SEQUENCE_ID_BITS;
    /** 自增序列偏移位數 */
    private static final long OFFSET_SHIFT_BITS = SEQUENCE_ID_BITS + WORKER_ID_BITS;
    /** 機器標識最大值 (2^5 / 2 - 1 = 15) */
    private static final long WORKER_ID_MAX = ((1 << WORKER_ID_BITS) - 1) >> 1;
    /** 備份機器ID開始位置 (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ā)生時間回撥時容忍的最大回撥時間 (秒) */
    private static final long BACK_TIME_MAX = 1L;
    /** 上次生成ID的時間戳 (秒) */
    private static long lastTimestamp = 0L;
    /** 當前秒內序列 (2^16)*/
    private static long sequence = 0L;
    /** 備份機器上次生成ID的時間戳 (秒) */
    private static long lastTimestampBak = 0L;
    /** 備份機器當前秒內序列 (2^16)*/
    private static long sequenceBak = 0L;
    static {
        // 初始化機器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);
    }
    /**
     * 主機器自增序列
     * @param timestamp 當前Unix時間戳
     * @return long
     */
    private static synchronized long nextId(long timestamp) {
        if (timestamp < lastTimestamp) {
            log.warn("時鐘回撥, 啟用備份機器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;
    }
    /**
     * 備份機器自增序列
     * @param timestamp 當前Unix時間戳
     * @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("時鐘回撥: 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;
/**
 * 緩存時間戳解決System.currentTimeMillis()高并發(fā)下性能問題
 *
 * @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;
        }
    }
    /**
     * 獲取單例對象
     * @return com.cmallshop.module.core.commons.util.sequence.SystemClock
     */
    private static SystemClock getInstance() {
        return SystemClockEnum.SYSTEM_CLOCK.getInstance();
    }
    /**
     * 獲取當前毫秒時間戳
     * @return long
     */
    public static long now() {
        return getInstance().now.get();
    }
    /**
     * 起一個線程定時刷新時間戳
     */
    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 項目中如何引用?

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;
}

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

相關文章

  • 處理java異步事件的阻塞和非阻塞方法分析

    處理java異步事件的阻塞和非阻塞方法分析

    這篇文章主要介紹了處理java異步事件的阻塞和非阻塞方法分析,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,阻塞與非阻塞關注的是交互雙方是否可以彈性工作。,需要的朋友可以參考下
    2019-06-06
  • Spring Cloud Nacos配置管理方案

    Spring Cloud Nacos配置管理方案

    Nacos是SpringCloud中用于服務注冊與發(fā)現和配置管理的組件,提供多種健康檢查機制和歷史版本管理,Nacos支持單機、集群和多集群模式,通過OpenAPI和多種語言客戶端進行接入,感興趣的朋友一起看看吧
    2025-01-01
  • SpringBoot 使用WebSocket功能(實現步驟)

    SpringBoot 使用WebSocket功能(實現步驟)

    本文通過詳細步驟介紹了SpringBoot 使用WebSocket功能,首先需要導入WebSocket坐標,編寫WebSocket配置類,用于注冊WebSocket的Bean,結合示例代碼給大家介紹的非常詳細,感興趣的朋友跟隨小編一起看看吧
    2024-02-02
  • 詳解Java如何實現FP-Growth算法

    詳解Java如何實現FP-Growth算法

    學校里的實驗,要求實現FP-Growth算法.FP-Growth算法比Apriori算法快很多(但是卻比不上時間)在網上搜索后發(fā)現Java實現的FP-Growth算法很少,且大多數不太能理解):太菜.所以就自己實現了一下.這篇文章重點介紹一下我的Java實現 ,需要的朋友可以參考下
    2021-06-06
  • Java搜索與圖論之DFS和BFS算法詳解

    Java搜索與圖論之DFS和BFS算法詳解

    DFS指在進行算法運算時,優(yōu)先將該路徑的當前路徑執(zhí)行完畢,執(zhí)行完畢或失敗后向上回溯嘗試其他途徑。BFS指在進行算法運算時,優(yōu)先將當前路徑點的所有情況羅列出來,然后根據羅列出來的情況羅列下一層。本文介紹了二者的實現與應用,需要的可以參考一下
    2022-11-11
  • Java網絡編程:Socket套接字、TCP和UDP協(xié)議以及Java高性能實戰(zhàn)

    Java網絡編程:Socket套接字、TCP和UDP協(xié)議以及Java高性能實戰(zhàn)

    本文介紹了網絡編程的基礎知識,包括Socket套接字、TCP和UDP協(xié)議的區(qū)別以及如何使用Java實現網絡服務器,通過實戰(zhàn)代碼,展示了如何從單線程到高性能線程池模型構建網絡服務器,并探討了常見的網絡編程問題和解決方法
    2026-02-02
  • 【spring-boot】快速構建spring-boot微框架的方法

    【spring-boot】快速構建spring-boot微框架的方法

    本篇文章主要介紹了【spring-boot】快速構建spring-boot微框架的方法,小編覺得挺不錯的,現在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-12-12
  • Java獲取當前時間并轉化為yyyy-MM-dd?HH:mm:ss格式的多種方式

    Java獲取當前時間并轉化為yyyy-MM-dd?HH:mm:ss格式的多種方式

    這篇文章主要介紹了Java獲取當前時間并轉化為yyyy-MM-dd?HH:mm:ss格式的多種方式,每種方式結合實例代碼給大家介紹的非常詳細,感興趣的朋友跟隨小編一起看看吧
    2024-03-03
  • SpringBoot集成Flyway進行數據庫版本遷移管理的步驟

    SpringBoot集成Flyway進行數據庫版本遷移管理的步驟

    這篇文章主要介紹了SpringBoot集成Flyway進行數據庫版本遷移管理的步驟,幫助大家更好的理解和學習使用SpringBoot框架,感興趣的朋友可以了解下
    2021-03-03
  • 詳解spring boot配置 ssl

    詳解spring boot配置 ssl

    本篇文章主要介紹了詳解spring boot配置 ssl,小編覺得挺不錯的,現在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-05-05

最新評論

渭南市| 漳州市| 和林格尔县| 汉寿县| 同心县| 汶川县| 永登县| 韶山市| 西乌| 宣城市| 萨嘎县| 保康县| 霍城县| 普兰店市| 崇明县| 奉新县| 库尔勒市| 阳城县| 五河县| 六安市| 盐亭县| 中卫市| 临澧县| 南通市| 嘉峪关市| 新闻| 临沧市| 礼泉县| 宝丰县| 宁化县| 高雄市| 五华县| 荃湾区| 会同县| 抚宁县| 新宁县| 中超| 清流县| 肃北| 茶陵县| 浙江省|