欢迎来到 德阳市某某建筑工程维修网点
全国咨询热线:020-123456789
联系我们

地址:联系地址联系地址联系地址

电话:020-123456789

传真:020-123456789

邮箱:admin@aa.com

新闻中心
聊聊雪花算法生成分布式ID的原理
  来源:德阳市某某建筑工程维修网点  更新时间:2024-04-27 21:40:38

聊聊雪花算法生成分布式ID的原理

一 、聊聊ID生成常见的雪花几种策略

ID作为我们数据的唯一标识,具有不重复 ,算法生成式趋势递增的分布特点。

如果ID不递增,原理数据插入会有性能问题 ,聊聊这个后面再聊 。雪花

  1. MYSQL表自增ID:适合数据量不大的算法生成式业务场景,数据量大的分布时候我们需要分库分表 ,这时候可能会出现ID重复问题。原理
  2. UUID:字符串类型 ,聊聊唯一但不是雪花趋势递增,表意不强 。算法生成式
  3. 雪花算法:适合大数据量,分布唯一并且趋势递增 。原理
  4. Leaf: 美团开源的分布式id生解决方案,属于中间件服务,需要独立部署  ,服务器贵这个就别考虑了。
  5. Redis生成:使用redis的Incr命令,类似于mysql主键自增的方式,但它也要依赖外部服务。
  6. 时间戳:System.currentTimeMillis()的方式,但是多节点情况下会出现相同的时间戳。

从成本及可靠性考虑 ,雪花算法是最佳之选。

二丶雪花算法原理

雪花算法其实是对时间戳生成ID的方式的一种改进,通过64bit位生成long类型的唯一id ,原理如下图:

聊聊雪花算法生成分布式ID的原理

雪花算法组成

  1. 最高位标识id的正负 ,0-正,1-负。
  2. 41位时间戳,存储毫秒级别的时间戳 ,2^41换成年来计算,最大能支持69年后的时间戳 。
  3. 10位机器标识 ,最多可以部署2^10=1024台机器
  4. 12位自增序列同一毫秒时间戳下 ,可以生成2^12=4096个不重复 id。

三丶源码分析

package com.xiaojiang;nnimport java.util.Set;nimport java.util.TreeSet;nn/**n * @author xiaojiangn * @version 1.0n * @description 雪花算法ID生成器n * @date 2022/6/22n */npublic class SnowflakeIdGenerator { nn // 初始时间戳一般为服务的上线时间n private static final long INIT_EPOCH = 1656169263130L;nn // 最后一次时间戳 ,用来判断是否同一毫秒和服务器时钟回拨判断n private long lastTimeMillis = -1L;nn // 数据中心占用的比特位n private static final long DATA_CENTER_ID_BITS = 5L;n // 数据中心最大值31n // 0000000000000000000000000000000000000000000000000000000000011111n private static final long MAX_DATA_CENTER_ID = ~(-1L << DATA_CENTER_ID_BITS);n // datacenterIdn private long datacenterId;nn // workId占用的位数n private static final long WORKER_ID_BITS = 5L;n // workId占用5个比特位 ,最大值31n // 0000000000000000000000000000000000000000000000000000000000011111n private static final long MAX_WORKER_ID = ~(-1L << WORKER_ID_BITS);n // workIdn private long workerId;nn // 最后12位 ,代表每毫秒内可产生最大序列号,即 2^12 - 1 = 4095n private static final long SEQUENCE_BITS = 12L;n // 掩码(最低12位为1,高位都为0),主要用于与自增后的序列号进行位与  ,如果值为0,则代表自增后的序列号超过了4095n // 0000000000000000000000000000000000000000000000000000111111111111n private static final long SEQUENCE_MASK = ~(-1L << SEQUENCE_BITS);n // 同一毫秒内的最新序号 ,最大值可为 2^12 - 1 = 4095n private long sequence;nn // workId位需要左移的位数 12n private static final long WORK_ID_SHIFT = SEQUENCE_BITS;n // dataCenterId位需要左移的位数 12+5n private static final long DATA_CENTER_ID_SHIFT = SEQUENCE_BITS + WORKER_ID_BITS;n // 时间戳需要左移的位数 12+5+5n private static final long TIMESTAMP_SHIFT = SEQUENCE_BITS + WORKER_ID_BITS + DATA_CENTER_ID_BITS;nn public SnowflakeIdGenerator(long datacenterId, long workerId) { nn // 检查datacenterId的合法值n if (datacenterId < 0 || datacenterId > MAX_DATA_CENTER_ID) { n throw new IllegalArgumentException(n String.format("datacenterId值必须大于0并且小于%d", MAX_DATA_CENTER_ID));n }nn // 检查workId的合法值n if (workerId < 0 || workerId > MAX_WORKER_ID) { n throw new IllegalArgumentException(String.format("workId值必须大于0并且小于%d", MAX_WORKER_ID));n }nn this.workerId = workerId;n this.datacenterId = datacenterId;n }nn /**n * 通过雪花算法生成下一个id ,注意这里使用synchronized同步n *n * @return 唯一idn */n public synchronized long nextId() { nn long currentTimeMillis = System.currentTimeMillis();nn // 当前时间小于上一次生成id使用的时间 ,可能出现服务器时钟回拨问题n if (currentTimeMillis < lastTimeMillis) { n throw new RuntimeException(n String.format("可能出现服务器时钟回拨问题 ,请检查服务器时间。当前服务器时间戳 :%d ,上一次使用时间戳 :%d", currentTimeMillis,n lastTimeMillis));n }ntt//还是在同一毫秒内,则将序列号递增1,序列号最大值为4095n if (currentTimeMillis == lastTimeMillis) { nn // 序列号的最大值是4095,使用掩码(最低12位为1 ,高位都为0)n //进行位与运行后如果值为0 ,则自增后的序列号超过了4095n // 那么就使用新的时间戳n sequence = (sequence + 1) & SEQUENCE_MASK;n if (sequence == 0) { n currentTimeMillis = tilNextMillis(lastTimeMillis);n }nn } else { // 不在同一毫秒内,则序列号重新从0开始,序列号最大值为4095n sequence = 0;n }nn // 记录最后一次使用的毫秒时间戳n lastTimeMillis = currentTimeMillis;nn // 核心算法 ,将不同部分的数值移动到指定的位置 ,然后进行或运行n return ((currentTimeMillis - INIT_EPOCH) << TIMESTAMP_SHIFT) n ttt| (datacenterId << DATA_CENTER_ID_SHIFT) n ttt| (workerId << WORK_ID_SHIFT) n ttt| sequence;n }nn /**n * 获取指定时间戳的接下来的时间戳 ,也可以说是下一毫秒n *n * @param lastTimeMillis 指定毫秒时间戳n * @return 时间戳n */n private long tilNextMillis(long lastTimeMillis) { n long currentTimeMillis = System.currentTimeMillis();n while (currentTimeMillis <= lastTimeMillis) { n currentTimeMillis = System.currentTimeMillis();n }n return currentTimeMillis;n }n}

重点讲一下这段代码

// 核心算法 ,将不同部分的数值移动到指定的位置 ,然后进行或运行n return ((currentTimeMillis - INIT_EPOCH) << TIMESTAMP_SHIFT) n ttt| (datacenterId << DATA_CENTER_ID_SHIFT) n ttt| (workerId << WORK_ID_SHIFT) n ttt| sequence;

举个栗子来说 ,我需要将9和5合成一个数。

9的二进制表示为1001,5的二进制表示为101 ,我们发现5的二进制占3位,那么需要将9左边3位腾出位置来,9左移3位即为1001000,我们知道

0 | 1 = 1

1 | 1 = 1

0 | 0 = 0

9左移其实是用0往右边补齐3位,那么1001000 | 0000101 = 1001101 实现了两数合并,雪花算法同理使用了这种实现了时间戳+数据中心ID+机器ID+自增序列的位数合并。


友情链接魔兽男性狼人皮甲幻化分享:毛多不怕 清凉一夏魔兽世界沙塔尔天空卫队声望速刷方法魔兽世界9月26日8.2.5补丁更新内容汇总 15周年庆补丁更新日志三国杀貂蝉技能详解(貂蝉的离间应该先点谁)开罐之王、不灭之王波罗丁,当年DNF的称号你肝了几个?魔兽怀旧服:P2法师该什么天赋进本?各大加点一览lol无限火力乌迪尔怎么出装最好用手游破解网站大全 手游破解网站排行榜前十魔兽怀旧服:盗贼与狂暴战,谁才是近战一哥?P6能否改变命运?DNF手游气功师装备搭配 DNF手游气功师装备怎么获得魔兽世界怀旧服台服字体怎么改-台服字体修改方法逃跑吧少年卖号平台下载 专业逃跑吧少年账号出售平台推荐超兽派别解析魔兽7.0圣骑士前瞻:防骑PvP天赋技能的详解推荐《王者荣耀》新英雄暃曝光,自带斩杀无视名刀,离谱!魔兽世界怀旧服攻略:一阶神圣骑士天赋选择与现阶段 毛装 指南创建状态回调函数魔兽世界怀旧服plus圣骑士天赋怎么加点 圣骑士天赋加点攻略酷我音乐VIP破解版,苹果/安卓/电脑全家桶破解版《英雄联盟》乐芙兰神装推荐 诡术妖姬怎么出装问道手游鬼宠哪里飞升,问道手游宠物飞升攻略魔兽世界怀旧服装备在哪里修理2022手机版仙剑奇侠传2游戏下载单机版 仙剑奇侠传2安卓版下载阴阳师2021夏日花火祭猜灯谜答案是什么?原创12.11版本前瞻:莎弥拉、月男、刀妹加强 剑圣、格温削弱原神芭芭拉怎么样-原神芭芭拉角色介绍魔力结晶怎么弄,地下城中魔力结晶如何得到dnf怎么摆摊 dnf摆摊卖东西方法魔兽世界巫妖王之怒前夕法师天赋怎么点-魔兽世界巫妖王之怒前夕法师天赋加点推荐《魔兽世界》wlk重铸盟约任务怎么完成 重铸盟约任务完成方法介绍好玩的攻略PSP游戏(psp好玩的策略游戏)梦幻西游各类宝宝如何选择赐福技能,老司机有话要说!《魔兽世界》对怀旧服中自动挂机玩家进行惩处魔兽世界证明价值任务怎么做哪些单机手机游戏让你玩两分钟就惊呼「太好玩了」?为什么?魔兽世界黑市在哪,魔兽世界7.0黑市在哪《原神》七圣召唤芭芭拉天赋牌详情DNF手游:即将推出异界副本,难度堪比e2时期,或将兴起竞速狂潮原创12.11版本前瞻:莎弥拉、月男、刀妹加强 剑圣、格温削弱dnf剑豪怎么加点 剑豪加点攻略大全
联系我们

地址:联系地址联系地址联系地址

电话:020-123456789

传真:020-123456789

邮箱:admin@aa.com

0.2236

Copyright © 2024 Powered by 德阳市某某建筑工程维修网点   sitemap