UidGenerato 基于snowflake算法實(shí)現(xiàn)

UidGenerato 由百度開發(fā)，基于SnowFlake算法的唯一ID生成器。UidGenerato 已組件的形式工作在應(yīng)用項(xiàng)目中，支持自定義workeid位數(shù)和初始化策略，從而適用docker等虛擬化環(huán)境下實(shí)例自動(dòng)重啟等場(chǎng)景。

準(zhǔn)備一個(gè)maven項(xiàng)目，構(gòu)建兩個(gè)模塊。分別作為使用方和提供方。（建兩個(gè)模塊主要是為了“造輪子”，其他模塊或項(xiàng)目可以直接引用，無(wú)需關(guān)心uid配置，如果沒有分模塊，可以指忽略構(gòu)建兩個(gè)模塊）

下載uid源碼，放在項(xiàng)目中，開源地址 https://github.com/baidu/uid-generator

DROP TABLE IF EXISTS WORKER_NODE;CREATE TABLE WORKER_NODE(ID BIGINT NOT NULL AUTO_INCREMENT COMMENT ’auto increment id’,HOST_NAME VARCHAR(64) NOT NULL COMMENT ’host name’,PORT VARCHAR(64) NOT NULL COMMENT ’port’,TYPE INT NOT NULL COMMENT ’node type: ACTUAL or CONTAINER’,LAUNCH_DATE DATE NOT NULL COMMENT ’launch date’,MODIFIED TIMESTAMP NOT NULL COMMENT ’modified time’,CREATED TIMESTAMP NOT NULL COMMENT ’created time’,PRIMARY KEY(ID))COMMENT=’DB WorkerID Assigner for UID Generator’,ENGINE = INNODB;Spring 配置

CachedUidGennerator：

UidGenerator 有兩個(gè)具體的實(shí)現(xiàn)類，分別是 DefaultUidGenerator 和 CachedUidGenerator， 官方推薦使用性能較強(qiáng)的 CachedUidGenerator。

我們直接引用 UdiGenerator源碼中的 cached-uid-spring.xml文件，使用默認(rèn)配置

<?xml version='1.0' encoding='UTF-8'?><beans xmlns='http://www.springframework.org/schema/beans' xmlns:xsi='http://www.w3.org/2001/XMLSchema-instance' xsi:schemaLocation=' http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd'> <!-- UID generator --> <bean /> <bean class='com.baidu.fsg.uid.impl.CachedUidGenerator'> <property name='workerIdAssigner' ref='disposableWorkerIdAssigner' /> <!-- 以下為可選配置, 如未指定將采用默認(rèn)值 --> <!-- RingBuffer size擴(kuò)容參數(shù), 可提高UID生成的吞吐量. --> <!-- 默認(rèn):3， 原bufferSize=8192, 擴(kuò)容后bufferSize= 8192 << 3 = 65536 --> <!--<property name='boostPower' value='3'></property>--><!-- 指定何時(shí)向RingBuffer中填充UID, 取值為百分比(0, 100), 默認(rèn)為50 --> <!-- 舉例: bufferSize=1024, paddingFactor=50 -> threshold=1024 * 50 / 100 = 512. --> <!-- 當(dāng)環(huán)上可用UID數(shù)量 < 512時(shí), 將自動(dòng)對(duì)RingBuffer進(jìn)行填充補(bǔ)全 --> <!--<property name='paddingFactor' value='50'></property>--><!-- 另外一種RingBuffer填充時(shí)機(jī), 在Schedule線程中, 周期性檢查填充 --> <!-- 默認(rèn):不配置此項(xiàng), 即不實(shí)用Schedule線程. 如需使用, 請(qǐng)指定Schedule線程時(shí)間間隔, 單位:秒 --> <!--<property name='scheduleInterval' value='60'></property>--><!-- 拒絕策略: 當(dāng)環(huán)已滿, 無(wú)法繼續(xù)填充時(shí) --> <!-- 默認(rèn)無(wú)需指定, 將丟棄Put操作, 僅日志記錄. 如有特殊需求, 請(qǐng)實(shí)現(xiàn)RejectedPutBufferHandler接口(支持Lambda表達(dá)式) --> <!--<property name='rejectedPutBufferHandler' ref='XxxxYourPutRejectPolicy'></property>--><!-- 拒絕策略: 當(dāng)環(huán)已空, 無(wú)法繼續(xù)獲取時(shí) --> <!-- 默認(rèn)無(wú)需指定, 將記錄日志, 并拋出UidGenerateException異常. 如有特殊需求, 請(qǐng)實(shí)現(xiàn)RejectedTakeBufferHandler接口(支持Lambda表達(dá)式) --> <!--<property name='rejectedPutBufferHandler' ref='XxxxYourPutRejectPolicy'></property>--> </bean></beans>

引入cached-uid-spring.xml配置文件，在我們自己新建的 UidConfig中

package com.xxx.uid.config;import org.springframework.context.annotation.Configuration;import org.springframework.context.annotation.ImportResource;/*** @author lishuzhen* @date 2020/8/11 16:10*/@Configuration@ImportResource(locations = {'classpath:/uid/cached-uid-spring.xml'})public class UidConfig {}

在另一個(gè)模塊中maven引入，創(chuàng)建一個(gè)UidGenUtils工具類，方便使用

package com.xxxx.utils;import com.xxx.uid.UidGenerator;import org.springframework.stereotype.Component;import javax.annotation.Resource;/*** @author lishuzhen* @date 2020/8/11 16:13*/@Componentpublic class UidGenUtils { @Resource private UidGenerator uidGenerator; public long getUid() { return uidGenerator.getUID(); } public String getUidStr() { return String.valueOf(uidGenerator.getUID()); }}

到此這篇關(guān)于Spring Boot項(xiàng)目集成UidGenerato的方法步驟的文章就介紹到這了,更多相關(guān)Spring Boot集成UidGenerato內(nèi)容請(qǐng)搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！