如何自定義Mybatis-Plus分布式ID生成器(解決ID長度超過JavaScript整數(shù)安全范圍問題)
自定義MyBatis-Plus分布式ID生成器(解決ID長度超過JavaScript整數(shù)安全范圍問題)
版本
MyBatis-Plus 3.4.1
問題
MyBatis-Plus 默認生成的是 64bit 長整型,而 JS 的 Number 類型精度最高只有 53bit,如果以 Long 類型 ID 和前端 JS 進行交互,會出現(xiàn)精度丟失(最后兩位數(shù)字變成 00) 而導致最終系統(tǒng)報錯。
解決方案
一種方案是在響應前端時,將 ID 轉(zhuǎn)換成 String 類型返回,但這個方法治標不治本,因此最終通過采用截短 ID 長度,以避免 ID 超過 JS 整數(shù)安全范圍。
縮短雪花算法后空間劃分(可根據(jù)實際需求調(diào)整): 1. 高位 32bit 作為秒級時間戳, 時間戳減去固定值(2024 年時間戳) 2. 5bit 作為機器標識, 最高可部署 32 臺機器 3. 最后 16bit 作為自增序列, 單節(jié)點最高每秒 2^16 = 65536 個 ID
代碼實現(xiàn)
通過實現(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 { /** 初始偏移時間戳 2024-01-01 */ private static final long OFFSET = 1704067200L; /** 機器id (0~15 保留 16~31作為備份機器) */ private static final long WORKER_ID; /** 機器id所占位數(shù) (5bit, 支持最大機器數(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; /** 機器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; /** 機器標識最大值 (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; /** 當前秒內(nèi)序列 (2^16)*/ private static long sequence = 0L; /** 備份機器上次生成ID的時間戳 (秒) */ private static long lastTimestampBak = 0L; /** 備份機器當前秒內(nèi)序列 (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; }
到此這篇關(guān)于自定義Mybatis-Plus分布式ID生成器(解決ID長度超過JavaScript整數(shù)安全范圍問題)的文章就介紹到這了,更多相關(guān)Mybatis-Plus分布式ID生成器內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
java.io.IOException:?UT010029:?Stream?is?closed異常分析及解決
這篇文章主要給大家介紹了關(guān)于java.io.IOException:?UT010029:?Stream?is?closed異常分析及解決辦法,文中通過代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考借鑒價值,需要的朋友可以參考下2024-02-02基于java springboot + mybatis實現(xiàn)電影售票管理系統(tǒng)
這篇文章主要介紹了基于java springboot + mybatis實現(xiàn)的完整電影售票管理系統(tǒng)基于java springboot + mybatis,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2021-08-08RestTemplate對HttpClient的適配源碼解讀
這篇文章主要為大家介紹了RestTemplate對HttpClient的適配源碼解讀,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-10-10Java版C語言版簡單使用靜態(tài)語言實現(xiàn)動態(tài)數(shù)組的方法
本文給大家分享java版和C語言版簡單使用靜態(tài)語言實現(xiàn)動態(tài)數(shù)組的方法,非常不錯,具有參考借鑒價值,需要的朋友參考下吧2017-10-10Spring擴展點之BeanFactoryPostProcessor詳解
這篇文章主要介紹了Spring擴展點之BeanFactoryPostProcessor詳解,Spring的設(shè)計非常優(yōu)雅,有很多的擴展點供我們對項目進行擴展,今天學習一下Spring其中擴展點之一的BeanFactoryPostProcessor,需要的朋友可以參考下2023-11-11