如何自定義Mybatis-Plus分布式ID生成器(解決ID長度超過JavaScript整數(shù)安全范圍問題)
自定義MyBatis-Plus分布式ID生成器(解決ID長度超過JavaScript整數(shù)安全范圍問題)
版本
MyBatis-Plus 3.4.1
問題
MyBatis-Plus 默認(rèn)生成的是 64bit 長整型,而 JS 的 Number 類型精度最高只有 53bit,如果以 Long 類型 ID 和前端 JS 進(jìn)行交互,會出現(xiàn)精度丟失(最后兩位數(shù)字變成 00) 而導(dǎo)致最終系統(tǒng)報(bào)錯(cuò)。
解決方案
一種方案是在響應(yīng)前端時(shí),將 ID 轉(zhuǎn)換成 String 類型返回,但這個(gè)方法治標(biāo)不治本,因此最終通過采用截短 ID 長度,以避免 ID 超過 JS 整數(shù)安全范圍。
縮短雪花算法后空間劃分(可根據(jù)實(shí)際需求調(diào)整): 1. 高位 32bit 作為秒級時(shí)間戳, 時(shí)間戳減去固定值(2024 年時(shí)間戳) 2. 5bit 作為機(jī)器標(biāo)識, 最高可部署 32 臺機(jī)器 3. 最后 16bit 作為自增序列, 單節(jié)點(diǎn)最高每秒 2^16 = 65536 個(gè) ID
代碼實(shí)現(xiàn)
通過實(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)識最大值 (2^5 / 2 - 1 = 15) */
private static final long WORKER_ID_MAX = ((1 << WORKER_ID_BITS) - 1) >> 1;
/** 備份機(jī)器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ā)生時(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ā)下性能問題
*
* @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();
}
/**
* 獲取當(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長度超過JavaScript整數(shù)安全范圍問題)的文章就介紹到這了,更多相關(guān)Mybatis-Plus分布式ID生成器內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
SpringBoot 使用WebSocket功能(實(shí)現(xiàn)步驟)
本文通過詳細(xì)步驟介紹了SpringBoot 使用WebSocket功能,首先需要導(dǎo)入WebSocket坐標(biāo),編寫WebSocket配置類,用于注冊WebSocket的Bean,結(jié)合示例代碼給大家介紹的非常詳細(xì),感興趣的朋友跟隨小編一起看看吧2024-02-02
詳解Java如何實(shí)現(xiàn)FP-Growth算法
學(xué)校里的實(shí)驗(yàn),要求實(shí)現(xiàn)FP-Growth算法.FP-Growth算法比Apriori算法快很多(但是卻比不上時(shí)間)在網(wǎng)上搜索后發(fā)現(xiàn)Java實(shí)現(xiàn)的FP-Growth算法很少,且大多數(shù)不太能理解):太菜.所以就自己實(shí)現(xiàn)了一下.這篇文章重點(diǎn)介紹一下我的Java實(shí)現(xiàn) ,需要的朋友可以參考下2021-06-06
Java網(wǎng)絡(luò)編程:Socket套接字、TCP和UDP協(xié)議以及Java高性能實(shí)戰(zhàn)
本文介紹了網(wǎng)絡(luò)編程的基礎(chǔ)知識,包括Socket套接字、TCP和UDP協(xié)議的區(qū)別以及如何使用Java實(shí)現(xiàn)網(wǎng)絡(luò)服務(wù)器,通過實(shí)戰(zhàn)代碼,展示了如何從單線程到高性能線程池模型構(gòu)建網(wǎng)絡(luò)服務(wù)器,并探討了常見的網(wǎng)絡(luò)編程問題和解決方法2026-02-02
【spring-boot】快速構(gòu)建spring-boot微框架的方法
本篇文章主要介紹了【spring-boot】快速構(gòu)建spring-boot微框架的方法,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-12-12
Java獲取當(dāng)前時(shí)間并轉(zhuǎn)化為yyyy-MM-dd?HH:mm:ss格式的多種方式
這篇文章主要介紹了Java獲取當(dāng)前時(shí)間并轉(zhuǎn)化為yyyy-MM-dd?HH:mm:ss格式的多種方式,每種方式結(jié)合實(shí)例代碼給大家介紹的非常詳細(xì),感興趣的朋友跟隨小編一起看看吧2024-03-03
SpringBoot集成Flyway進(jìn)行數(shù)據(jù)庫版本遷移管理的步驟
這篇文章主要介紹了SpringBoot集成Flyway進(jìn)行數(shù)據(jù)庫版本遷移管理的步驟,幫助大家更好的理解和學(xué)習(xí)使用SpringBoot框架,感興趣的朋友可以了解下2021-03-03

