位置: IT常识 - 正文

雪花算法(SnowFlake)(雪花算法时钟回拨)

编辑:rootadmin
雪花算法(SnowFlake)

推荐整理分享雪花算法(SnowFlake)(雪花算法时钟回拨),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:雪花算法生成id,雪花算法 分库分表,雪花算法生成id,雪花算法时钟回拨,雪花算法 分库分表,雪花算法时钟回拨,雪花算法snowflake,雪花算法snowflake,内容如对您有帮助,希望把文章链接给更多的朋友!

简介

现在的服务基本是分布式、微服务形式的,而且大数据量也导致分库分表的产生,对于水平分表就需要保证表中 id 的全局唯一性。

对于 MySQL 而言,一个表中的主键 id 一般使用自增的方式,但是如果进行水平分表之后,多个表中会生成重复的 id 值。那么如何保证水平分表后的多张表中的 id 是全局唯一性的呢?

如果还是借助数据库主键自增的形式,那么可以让不同表初始化一个不同的初始值,然后按指定的步长进行自增。例如有3张拆分表,初始主键值为1,2,3,自增步长为3。

当然也有人使用 UUID 来作为主键,但是 UUID 生成的是一个无序的字符串,对于 MySQL 推荐使用增长的数值类型值作为主键来说不适合。

也可以使用 Redis 的自增原子性来生成唯一 id,但是这种方式业内比较少用。

当然还有其他解决方案,不同互联网公司也有自己内部的实现方案。雪花算法是其中一个用于解决分布式 id 的高效方案,也是许多互联网公司在推荐使用的。

SnowFlake 雪花算法

SnowFlake 中文意思为雪花,故称为雪花算法。最早是 Twitter 公司在其内部用于分布式环境下生成唯一 ID。在2014年开源 scala 语言版本。

雪花算法的原理就是生成一个的 64 位比特位的 long 类型的唯一 id。

最高 1 位固定值 0,因为生成的 id 是正整数,如果是 1 就是负数了。

接下来 41 位存储毫秒级时间戳,2^41/(1000*60*60*24*365)=69,大概可以使用 69 年。

雪花算法(SnowFlake)(雪花算法时钟回拨)

再接下 10 位存储机器码,包括 5 位 datacenterId 和 5 位 workerId。最多可以部署 2^10=1024 台机器。

最后 12 位存储序列号。同一毫秒时间戳时,通过这个递增的序列号来区分。即对于同一台机器而言,同一毫秒时间戳下,可以生成 2^12=4096 个不重复 id。

可以将雪花算法作为一个单独的服务进行部署,然后需要全局唯一 id 的系统,请求雪花算法服务获取 id 即可。

对于每一个雪花算法服务,需要先指定 10 位的机器码,这个根据自身业务进行设定即可。例如机房号+机器号,机器号+服务号,或者是其他可区别标识的 10 位比特位的整数值都行。

算法实现

package com.ruoyi.common.utils;import java.util.Date;/*** @ClassName: SnowFlakeUtil* 雪花算法*/public class SnowFlakeUtil {private static SnowFlakeUtil snowFlakeUtil;static {snowFlakeUtil = new SnowFlakeUtil();}// 初始时间戳(纪年),可用雪花算法服务上线时间戳的值// 1650789964886:2022-04-24 16:45:59private static final long INIT_EPOCH = 1650789964886L;// 时间位取&private static final long TIME_BIT = 0b1111111111111111111111111111111111111111110000000000000000000000L;// 记录最后使用的毫秒时间戳,主要用于判断是否同一毫秒,以及用于服务器时钟回拨判断private long lastTimeMillis = -1L;// dataCenterId占用的位数private static final long DATA_CENTER_ID_BITS = 5L;// dataCenterId占用5个比特位,最大值31// 0000000000000000000000000000000000000000000000000000000000011111private static final long MAX_DATA_CENTER_ID = ~(-1L << DATA_CENTER_ID_BITS);// dataCenterIdprivate long dataCenterId;// workId占用的位数private static final long WORKER_ID_BITS = 5L;// workId占用5个比特位,最大值31// 0000000000000000000000000000000000000000000000000000000000011111private static final long MAX_WORKER_ID = ~(-1L << WORKER_ID_BITS);// workIdprivate long workerId;// 最后12位,代表每毫秒内可产生最大序列号,即 2^12 - 1 = 4095private static final long SEQUENCE_BITS = 12L;// 掩码(最低12位为1,高位都为0),主要用于与自增后的序列号进行位与,如果值为0,则代表自增后的序列号超过了4095// 0000000000000000000000000000000000000000000000000000111111111111private static final long SEQUENCE_MASK = ~(-1L << SEQUENCE_BITS);// 同一毫秒内的最新序号,最大值可为 2^12 - 1 = 4095private long sequence;// workId位需要左移的位数 12private static final long WORK_ID_SHIFT = SEQUENCE_BITS;// dataCenterId位需要左移的位数 12+5private static final long DATA_CENTER_ID_SHIFT = SEQUENCE_BITS + WORKER_ID_BITS;// 时间戳需要左移的位数 12+5+5private static final long TIMESTAMP_SHIFT = SEQUENCE_BITS + WORKER_ID_BITS + DATA_CENTER_ID_BITS;/*** 无参构造*/public SnowFlakeUtil() {//实际分布式系统中,一种参考方案是dataCenterId为mac地址,workerId为pid相关this(1, 1);}/*** 有参构造* @param dataCenterId* @param workerId*/public SnowFlakeUtil(long dataCenterId, long workerId) {// 检查dataCenterId的合法值if (dataCenterId < 0 || dataCenterId > MAX_DATA_CENTER_ID) {throw new IllegalArgumentException(String.format("dataCenterId 值必须大于 0 并且小于 %d", MAX_DATA_CENTER_ID));}// 检查workId的合法值if (workerId < 0 || workerId > MAX_WORKER_ID) {throw new IllegalArgumentException(String.format("workId 值必须大于 0 并且小于 %d", MAX_WORKER_ID));}this.workerId = workerId;this.dataCenterId = dataCenterId;}/*** 获取唯一ID* @return*/public static Long getSnowFlakeId() {return snowFlakeUtil.nextId();}/*** 通过雪花算法生成下一个id,注意这里使用synchronized同步* @return 唯一id*/public synchronized long nextId() {long currentTimeMillis = System.currentTimeMillis();System.out.println(currentTimeMillis);// 当前时间小于上一次生成id使用的时间,可能出现服务器时钟回拨问题if (currentTimeMillis < lastTimeMillis) {throw new RuntimeException(String.format("可能出现服务器时钟回拨问题,请检查服务器时间。当前服务器时间戳:%d,上一次使用时间戳:%d", currentTimeMillis,lastTimeMillis));}if (currentTimeMillis == lastTimeMillis) {// 还是在同一毫秒内,则将序列号递增1,序列号最大值为4095// 序列号的最大值是4095,使用掩码(最低12位为1,高位都为0)进行位与运行后如果值为0,则自增后的序列号超过了4095// 那么就使用新的时间戳sequence = (sequence + 1) & SEQUENCE_MASK;if (sequence == 0) {currentTimeMillis = getNextMillis(lastTimeMillis);}} else { // 不在同一毫秒内,则序列号重新从0开始,序列号最大值为4095sequence = 0;}// 记录最后一次使用的毫秒时间戳lastTimeMillis = currentTimeMillis;// 核心算法,将不同部分的数值移动到指定的位置,然后进行或运行// <<:左移运算符, 1 << 2 即将二进制的 1 扩大 2^2 倍// |:位或运算符, 是把某两个数中, 只要其中一个的某一位为1, 则结果的该位就为1// 优先级:<< > |return// 时间戳部分((currentTimeMillis - INIT_EPOCH) << TIMESTAMP_SHIFT)// 数据中心部分| (dataCenterId << DATA_CENTER_ID_SHIFT)// 机器表示部分| (workerId << WORK_ID_SHIFT)// 序列号部分| sequence;}/*** 获取指定时间戳的接下来的时间戳,也可以说是下一毫秒* @param lastTimeMillis 指定毫秒时间戳* @return 时间戳*/private long getNextMillis(long lastTimeMillis) {long currentTimeMillis = System.currentTimeMillis();while (currentTimeMillis <= lastTimeMillis) {currentTimeMillis = System.currentTimeMillis();}return currentTimeMillis;}/*** 获取随机字符串,length=13* @return*/public static String getRandomStr() {return Long.toString(getSnowFlakeId(), Character.MAX_RADIX);}/*** 从ID中获取时间* @param id 由此类生成的ID* @return*/public static Date getTimeBySnowFlakeId(long id) {return new Date(((TIME_BIT & id) >> 22) + INIT_EPOCH);}public static void main(String[] args) {SnowFlakeUtil snowFlakeUtil = new SnowFlakeUtil();long id = snowFlakeUtil.nextId();System.out.println("id:" + id);Date date = SnowFlakeUtil.getTimeBySnowFlakeId(id);System.out.println(date);long time = date.getTime();System.out.println("time:" + time);System.out.println(getRandomStr());}}

算法优缺点

雪花算法有以下几个优点:

高并发分布式环境下生成不重复 id,每秒可生成百万个不重复 id。

基于时间戳,以及同一时间戳下序列号自增,基本保证 id 有序递增。

不依赖第三方库或者中间件。

算法简单,在内存中进行,效率高。

雪花算法有如下缺点:

依赖服务器时间,服务器时钟回拨时可能会生成重复 id。算法中可通过记录最后一个生成 id 时的时间戳来解决,每次生成 id 之前比较当前服务器时钟是否被回拨,避免生成重复 id。

注意事项

其实雪花算法每一部分占用的比特位数量并不是固定死的。例如你的业务可能达不到 69 年之久,那么可用减少时间戳占用的位数,雪花算法服务需要部署的节点超过1024 台,那么可将减少的位数补充给机器码用。

注意,雪花算法中 41 位比特位不是直接用来存储当前服务器毫秒时间戳的,而是需要当前服务器时间戳减去某一个初始时间戳值,一般可以使用服务上线时间作为初始时间戳值。

对于机器码,可根据自身情况做调整,例如机房号,服务器号,业务号,机器 IP 等都是可使用的。对于部署的不同雪花算法服务中,最后计算出来的机器码能区分开来即可。

本文链接地址:https://www.jiuchutong.com/zhishi/300091.html 转载请保留说明!

上一篇:Tomcat安装使用与部署Web项目的三种方法(tomcat的安装配置)

下一篇:【AI大比拼】文心一言 VS ChatGPT-4

  • 华为5g手机nova6怎么插耳机(华为5g手机什么时候回归)

    华为5g手机nova6怎么插耳机(华为5g手机什么时候回归)

  • 快剪辑剪辑后不清晰(快剪辑下一步点不了)

    快剪辑剪辑后不清晰(快剪辑下一步点不了)

  • 黄钻图标怎么更换(黄钻图标怎么更换图片)

    黄钻图标怎么更换(黄钻图标怎么更换图片)

  • kindle国行和美版日版有什么区别(kindle国行和美版包装)

    kindle国行和美版日版有什么区别(kindle国行和美版包装)

  • 无法作为压缩包打开文件(无法作为压缩包打开文件怎么办啊)

    无法作为压缩包打开文件(无法作为压缩包打开文件怎么办啊)

  • 锂电池短路后能恢复吗(锂电池短路后能充电吗)

    锂电池短路后能恢复吗(锂电池短路后能充电吗)

  • 锐龙54500u相当于i几(锐龙5 4500相当于i几)

    锐龙54500u相当于i几(锐龙5 4500相当于i几)

  • 手机的nfc功能是啥意思(手机的nfc功能是自带的吗)

    手机的nfc功能是啥意思(手机的nfc功能是自带的吗)

  • 华为bac一tl00是什么型号(华为bactl00型号手机)

    华为bac一tl00是什么型号(华为bactl00型号手机)

  • 手机电池鼓包了还能用吗(手机电池鼓包了还能充电吗)

    手机电池鼓包了还能用吗(手机电池鼓包了还能充电吗)

  • 微信新消息不显示红点(微信新消息不显示)

    微信新消息不显示红点(微信新消息不显示)

  • 蓝客蓝牙音响怎么使用(蓝客蓝牙音响怎么使用视频)

    蓝客蓝牙音响怎么使用(蓝客蓝牙音响怎么使用视频)

  • 曲面屏显示器的优缺点(曲面屏显示器的曲率越小视距应该越远)

    曲面屏显示器的优缺点(曲面屏显示器的曲率越小视距应该越远)

  • 电表显示脉冲代表什么(电表上的脉冲指示灯)

    电表显示脉冲代表什么(电表上的脉冲指示灯)

  • vivo怎么同时用两个软件

    vivo怎么同时用两个软件

  • 微信绑定手机号有什么用(微信绑定手机号被别人绑定了会怎么样)

    微信绑定手机号有什么用(微信绑定手机号被别人绑定了会怎么样)

  • 苹果x怎么单独给软件上锁(苹果x怎么单独隐藏一个应用)

    苹果x怎么单独给软件上锁(苹果x怎么单独隐藏一个应用)

  • 支付宝怎么连音箱(支付宝连音响不播报)

    支付宝怎么连音箱(支付宝连音响不播报)

  • opporealme在哪买(在oppo店里能买到realme吗)

    opporealme在哪买(在oppo店里能买到realme吗)

  • 电脑系统还原步骤,ghost系统还原教程(电脑系统还原步骤)

    电脑系统还原步骤,ghost系统还原教程(电脑系统还原步骤)

  • win1019025更新了什么(window10今天更新)

    win1019025更新了什么(window10今天更新)

  • 卢塞恩老城,瑞士 (© Xantana/Getty Images)(卢塞恩小镇瑞士)

    卢塞恩老城,瑞士 (© Xantana/Getty Images)(卢塞恩小镇瑞士)

  • python中count函数是什么意思?(python中的count函数)

    python中count函数是什么意思?(python中的count函数)

  • elementui中表单el-form的label如何设置宽度(element表格表单)

    elementui中表单el-form的label如何设置宽度(element表格表单)

  • 企业计提增值税 附加税
  • 哪些单位须执行国家政策
  • 去年收到一张普票超范围了怎么办
  • 购入交通运输设备计入什么科目
  • 刚成立的公司好不好
  • 非居民企业适用的企业所得税税率
  • 小规模纳税人处置固定资产的税率
  • 空白增值税专用发票丢失罚款
  • 固定资产提折旧 账务处理
  • 销售承兑现金会退回来吗
  • 缓缴税款到期缴纳填主表第几行
  • 商品削价准备怎么算
  • 小微企业银行贷款印花税
  • 现房销售土增税怎么缴纳
  • 建筑设计行业收入调查
  • 安全费用支出范围包括
  • 企业用于在建工程购入的材料
  • 海关缴款书认证不符
  • 土地使用权出让和划拨有什么区别
  • 税种认定登记流程
  • 改扩建要计提折旧吗
  • 可转债转换为股权投资的企业所得税处理
  • win11如何更改开始菜单位置
  • 银行汇票与银行本票的区别
  • 非居民个人所得税税率表最新
  • php能开发微信小程序吗
  • 给员工支付的房租费计入哪里?
  • 长期病假解除劳动合同怎么赔偿
  • 电脑桌面调出键盘
  • 蚊子叮咬怎么办手抄报
  • 坏账准备 结转
  • 日本北海道 (© Hiroshi Yokoyama/eStock Photo)
  • 暂估成本的账务处理分录
  • 消费税会计分录怎么做的
  • js获取本机ip地址
  • vue该怎么学
  • dmsetup remove_all 会不会清掉数据
  • 农民专业合作社是什么性质
  • 本月确认收入 发票下月开
  • 瀑布流样式
  • 织梦怎么添加相关
  • sql server触发器实例
  • 普通发票的后续怎么开
  • 企业所得税计算题及答案解析
  • 土地使用税减免税优惠
  • 合并报表存货抵消
  • 现金付发票再摊销怎么算
  • 行政拨款给工会的账务处理
  • 票据质押如何做账
  • 设备投资要开票吗
  • 固定资产更换配件 资本化标准
  • 人工费怎么核算
  • 买电脑能砍多少
  • 在mysql中,删除表的外键约束的关键字为()
  • mysql常用关键字及其用法
  • winxp设置在哪
  • win2000系统禁止ping
  • windows不能打开此文件result:31
  • win8.1 win7
  • cleanmymac3激活码领取
  • linux如何快速统计文件个数
  • KbdTray.exe - KbdTray是什么进程 有什么作用
  • window10突然激活失效
  • linux ifconfig命令详解
  • linux各种命令
  • win7系统桌面图标不见了怎么办
  • shell 替换文件中匹配的内容
  • linux常用脚本代码
  • nodejs常用内置模块
  • js中dom的用法
  • JavaScript indexOf方法入门实例(计算指定字符在字符串中首次出现的位置)
  • js获取图片的宽高
  • python twilio
  • 国家税务局广东省电子税务总局手机版
  • 税务稽查建议书反馈意见
  • 四川国税总局官网
  • 广州市番禺区国丹信息管理有限公司
  • 一般纳税人企业所得税5%还是25%
  • 12366地税投诉
  • 2018年3月增值税申报期限
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设