java算法之靜態(tài)內(nèi)部類實(shí)現(xiàn)雪花算法
在生成表主鍵ID時(shí),我們可以考慮主鍵自增 或者 UUID,但它們都有很明顯的缺點(diǎn)
主鍵自增:1、自增ID容易被爬蟲(chóng)遍歷數(shù)據(jù)。2、分表分庫(kù)會(huì)有ID沖突。
UUID: 1、太長(zhǎng),并且有索引碎片,索引多占用空間的問(wèn)題 2、無(wú)序。
雪花算法就很適合在分布式場(chǎng)景下生成唯一ID,它既可以保證唯一又可以排序。為了提高生產(chǎn)雪花ID的效率,
在這里面數(shù)據(jù)的運(yùn)算都采用的是位運(yùn)算
一、概念1、原理SnowFlake算法生成ID的結(jié)果是一個(gè)64bit大小的整數(shù),它的結(jié)構(gòu)如下圖:
算法描述:
1bit 因?yàn)槎M(jìn)制中最高位是符號(hào)位,1表示負(fù)數(shù),0表示正數(shù)。生成的ID都是正整數(shù),所以最高位固定為0。
41bit-時(shí)間戳 精確到毫秒級(jí),41位的長(zhǎng)度可以使用69年。時(shí)間位還有一個(gè)很重要的作用是可以根據(jù)時(shí)間進(jìn)行排序。
10bit-工作機(jī)器id 10位的機(jī)器標(biāo)識(shí),10位的長(zhǎng)度最多支持部署1024個(gè)節(jié)點(diǎn)。
12bit-序列號(hào) 序列號(hào)即一系列的自增id,可以支持同一節(jié)點(diǎn)同一毫秒生成多個(gè)ID序號(hào)。12位(bit)可以表示的最大正整數(shù)是,即可以用0、1、2、3、....4094這4095個(gè)數(shù)字,來(lái)表示同一機(jī)器同一時(shí)間截(毫秒)內(nèi)產(chǎn)生的4095個(gè)ID序號(hào)。
說(shuō)明 由于在Java中64bit的整數(shù)是long類型,所以在Java中SnowFlake算法生成的id就是long來(lái)存儲(chǔ)的。
二、靜態(tài)類部類單例模式生產(chǎn)雪花ID代碼下面生成雪花ID的代碼可以用于線上分布式項(xiàng)目中來(lái)生成分布式主鍵ID,因?yàn)樵O(shè)計(jì)采用的靜態(tài)內(nèi)部類的單例模式,通過(guò)加synchronized鎖來(lái)保證在
同一個(gè)服務(wù)器線程安全。至于不同服務(wù)器其實(shí)是不相關(guān)的,因?yàn)樗鼈兊臋C(jī)器碼是不一致的,所以就算同一時(shí)刻兩臺(tái)服務(wù)器都產(chǎn)生了雪花ID,那也不會(huì)一樣的。
1、代碼public class SnowIdUtils { /** * 私有的 靜態(tài)內(nèi)部類 */ private static class SnowFlake {/** * 內(nèi)部類對(duì)象(單例模式) */private static final SnowIdUtils.SnowFlake SNOW_FLAKE = new SnowIdUtils.SnowFlake();/** * 起始的時(shí)間戳 */private final long START_TIMESTAMP = 1557489395327L;/** * 序列號(hào)占用位數(shù) */private final long SEQUENCE_BIT = 12;/** * 機(jī)器標(biāo)識(shí)占用位數(shù) */private final long MACHINE_BIT = 10;/** * 時(shí)間戳位移位數(shù) */private final long TIMESTAMP_LEFT = SEQUENCE_BIT + MACHINE_BIT;/** * 最大序列號(hào) (4095) */private final long MAX_SEQUENCE = ~(-1L << SEQUENCE_BIT);/** * 最大機(jī)器編號(hào) (1023) */private final long MAX_MACHINE_ID = ~(-1L << MACHINE_BIT);/** * 生成id機(jī)器標(biāo)識(shí)部分 */private long machineIdPart;/** * 序列號(hào) */private long sequence = 0L;/** * 上一次時(shí)間戳 */private long lastStamp = -1L;/** * 構(gòu)造函數(shù)初始化機(jī)器編碼 */private SnowFlake() { //模擬這里獲得本機(jī)機(jī)器編碼 long localIp = 4321; //localIp & MAX_MACHINE_ID最大不會(huì)超過(guò)1023,在左位移12位 machineIdPart = (localIp & MAX_MACHINE_ID) << SEQUENCE_BIT;}/** * 獲取雪花ID */public synchronized long nextId() { long currentStamp = timeGen(); //避免機(jī)器時(shí)鐘回?fù)? while (currentStamp < lastStamp) {// //服務(wù)器時(shí)鐘被調(diào)整了,ID生成器停止服務(wù).throw new RuntimeException(String.format('時(shí)鐘已經(jīng)回?fù)? Refusing to generate id for %d milliseconds', lastStamp - currentStamp)); } if (currentStamp == lastStamp) {// 每次+1sequence = (sequence + 1) & MAX_SEQUENCE;// 毫秒內(nèi)序列溢出if (sequence == 0) { // 阻塞到下一個(gè)毫秒,獲得新的時(shí)間戳 currentStamp = getNextMill();} } else {//不同毫秒內(nèi),序列號(hào)置0sequence = 0L; } lastStamp = currentStamp; //時(shí)間戳部分+機(jī)器標(biāo)識(shí)部分+序列號(hào)部分 return (currentStamp - START_TIMESTAMP) << TIMESTAMP_LEFT | machineIdPart | sequence;}/** * 阻塞到下一個(gè)毫秒,直到獲得新的時(shí)間戳 */private long getNextMill() { long mill = timeGen(); // while (mill <= lastStamp) {mill = timeGen(); } return mill;}/** * 返回以毫秒為單位的當(dāng)前時(shí)間 */protected long timeGen() { return System.currentTimeMillis();} } /** * 獲取long類型雪花ID */ public static long uniqueLong() {return SnowIdUtils.SnowFlake.SNOW_FLAKE.nextId(); } /** * 獲取String類型雪花ID */ public static String uniqueLongHex() {return String.format('%016x', uniqueLong()); } /** * 測(cè)試 */ public static void main(String[] args) throws InterruptedException {//計(jì)時(shí)開(kāi)始時(shí)間long start = System.currentTimeMillis();//讓100個(gè)線程同時(shí)進(jìn)行final CountDownLatch latch = new CountDownLatch(100);//判斷生成的20萬(wàn)條記錄是否有重復(fù)記錄final Map<Long, Integer> map = new ConcurrentHashMap();for (int i = 0; i < 100; i++) { //創(chuàng)建100個(gè)線程 new Thread(() -> {for (int s = 0; s < 2000; s++) { long snowID = SnowIdUtils.uniqueLong(); log.info('生成雪花ID={}',snowID); Integer put = map.put(snowID, 1); if (put != null) {throw new RuntimeException('主鍵重復(fù)'); }}latch.countDown(); }).start();}//讓上面100個(gè)線程執(zhí)行結(jié)束后,在走下面輸出信息latch.await();log.info('生成20萬(wàn)條雪花ID總用時(shí)={}', System.currentTimeMillis() - start); }}2、測(cè)試結(jié)果
從圖中我們可以得出
1、在100個(gè)線程并發(fā)下,生成20萬(wàn)條雪花ID的時(shí)間大概在1.6秒左右,所有所性能還是蠻ok的。
2、生成20萬(wàn)條雪花ID并沒(méi)有一條相同的ID,因?yàn)橛幸粭l就會(huì)拋出異常了。
3、為什么說(shuō)41位時(shí)間戳最長(zhǎng)只能有69年我們思考41的二進(jìn)制,最大值也就41位都是1,也就是也就是說(shuō)41位可以表示
所以說(shuō)雪花算法生成的ID,只能保證69年內(nèi)不會(huì)重復(fù),如果超過(guò)69年的話,那就考慮換個(gè)服務(wù)器部署吧,并且要保證該服務(wù)器的ID和之前都沒(méi)有重復(fù)過(guò)。
以上就是java算法之靜態(tài)內(nèi)部類實(shí)現(xiàn)雪花算法的詳細(xì)內(nèi)容,更多關(guān)于java算法的資料請(qǐng)關(guān)注好吧啦網(wǎng)其它相關(guān)文章!
相關(guān)文章:
1. 詳解php如何合并身份證正反面圖片為一張圖片2. 得到XML文檔大小的方法3. ASP錯(cuò)誤捕獲的幾種常規(guī)處理方式4. asp.net core項(xiàng)目授權(quán)流程詳解5. 詳解JS前端使用迭代器和生成器原理及示例6. ASP編碼必備的8條原則7. Python 如何將字符串每?jī)蓚€(gè)用空格隔開(kāi)8. .NET 中配置從xml轉(zhuǎn)向json方法示例詳解9. 解決python 輸出到csv 出現(xiàn)多空行的情況10. asp錯(cuò)誤 '80040e21' 多步 OLE DB 操作產(chǎn)生錯(cuò)誤
