基于雪花算法實(shí)現(xiàn)增強(qiáng)版ID生成器詳解

第基于雪花算法實(shí)現(xiàn)增強(qiáng)版ID生成器詳解目錄基于雪花算法的增強(qiáng)版ID生成器快速開始配置解析目前提供兩個(gè)配置類詳情生產(chǎn)推薦使用方式JMH性能測(cè)試測(cè)試機(jī)硬件情況Sequence配置參數(shù)JMH參數(shù)測(cè)試結(jié)果Tip

基于雪花算法的增強(qiáng)版ID生成器

解決了時(shí)間回?fù)艿膯栴}無(wú)需手動(dòng)指定workId,微服務(wù)環(huán)境自適應(yīng)可配置化

快速開始

1.依賴引入

dependency

groupIdio.github.mocreates/groupId

artifactIduid-generator/artifactId

version2.0-RELEASE/version

/dependency

2.配置序列器Sequence

@Bean

publicSequencesequence(){

SequenceConfigsequenceConfig=newSimpleSequenceConfig();

returnnewSequence(sequenceConfig);

3.使用序列器生成ID

@Autowired

privateSequencesequence;

publiclonggenerateId(){

returnsequence.nextId();

配置解析

目前提供兩個(gè)配置類

io.github.mocreates.config.DefaultSequenceConfigio.github.mocreates.config.SimpleSequenceConfig

前者需要顯式地指定workerId、datacenterId，可以結(jié)合數(shù)據(jù)庫(kù)來(lái)使用，后者是利用網(wǎng)卡信息進(jìn)行自適應(yīng)

詳情

字段名釋義默認(rèn)值twepoch可以被設(shè)置為最接近項(xiàng)目啟用前的某個(gè)時(shí)間點(diǎn)（unix時(shí)間戳)1665817757000LworkerIdBits機(jī)器位所占的bit位數(shù)19LdatacenterIdBits數(shù)據(jù)標(biāo)識(shí)位所占的bit位數(shù)0LsequenceBits毫秒內(nèi)自增位數(shù)3LworkerId機(jī)器位datacenterId數(shù)據(jù)位0LinetAddress網(wǎng)絡(luò)相關(guān)信息

生產(chǎn)推薦使用方式

1.依賴引入

dependency

groupIdio.github.mocreates/groupId

artifactIduid-generator/artifactId

version2.0-RELEASE/version

/dependency

2.創(chuàng)建表

CREATETABLE`worker_node`(

`id`bigint(20)NOTNULLAUTO_INCREMENT,

`node_info`varchar(512)NOTNULL,

`gmt_create`datetimeNOTNULLDEFAULTCURRENT_TIMESTAMP,

`gmt_modify`datetimeNOTNULLDEFAULTCURRENT_TIMESTAMPONUPDATECURRENT_TIMESTAMP,

PRIMARYKEY(`id`)

)ENGINE=InnoDBDEFAULTCHARSET=utf8mb4COMMENT='DBWorkerIDAssignerforUIDGenerator';

3.配置(利用主鍵自增來(lái)分配workerId,解決分布式環(huán)境下手動(dòng)指定workerId的痛點(diǎn))

@Bean

publicSequencesequence(WorkerNodeMapperworkerNodeMapper)throwsUnknownHostException{

WorkerNodeworkerNode=newWorkerNode();

InetAddresslocalHost=InetAddress.getLocalHost();

workerNode.setNodeInfo(localHost.toString());

workerNodeMapper.insertSelective(workerNode);

DefaultSequenceConfigdefaultSequenceConfig=newDefaultSequenceConfig();

defaultSequenceConfig.setWorkerId(workerNode.getId());

returnnewSequence(defaultSequenceConfig);

4.使用序列器生成ID

@Autowired

privateSequencesequence;

publiclonggenerateId(){

returnsequence.nextId();

JMH性能測(cè)試

測(cè)試機(jī)硬件情況

MacBookPro(13-inch,M1,2025)8C16G

Sequence配置參數(shù)

privatestaticfinalDefaultSequenceConfigSEQUENCE_CONFIG=newDefaultSequenceConfig();

static{

SEQUENCE_CONFIG.setSequenceBits(22);

SEQUENCE_CONFIG.setWorkerIdBits(0);

SEQUENCE_CONFIG.setDatacenterIdBits(0);

SEQUENCE_CONFIG.setTwepoch(System.currentTimeMillis());

SEQUENCE_CONFIG.setWorkerId(0L);

SEQUENCE_CONFIG.setDatacenterId(0L);

privatestaticfinalSequenceSEQUENCE=newSequence(SEQUENCE_CONFIG);

JMH參數(shù)

@BenchmarkMode(Mode.Throughput)

@Threads(10)

@Warmup(iterations=3,time=10,timeUnit=TimeUnit.SECONDS)

@Measurement(iterations=10,time=10,timeUnit=TimeUnit.SECONDS)

@State(value=Scope.Benchmark)

@Fork(1)

@OutputTimeUnit(TimeUnit.SECONDS)

測(cè)試結(jié)果

BenchmarkModeCnt