微服务+分库分表的自增主键ID该如何设计?

一. 前言

分布式ID 是分布式系统里面非常重要的一个组成部分,那么我们在设计分布式ID的时候,需要考虑什么问题呢?

  • ❓简单结构下是怎么实现 ID 的控制的?

  • 单实例系统 :通过时间戳,系统内自增,上锁等方式保证ID的唯一性

  • 单数据库实例 : 通过自增字段(不谈性能)实现ID的唯一

  • ❓微服务 + 分库分表了 ,又该如何进行控制?

  • 问题 : 单个系统没办法直接感知到其他系统的ID情况,哪怕通信也要付出极大的代价

二. 来理解分布式ID的原则

2.1 分布式 ID 的本质是什么 ?

  • 全局唯一 : 要保证的是在任何场景下,任何系统,任何库,同一业务场景中生成的ID一定是唯一的

  • 递增 : 有的文章里面会谈到单调递增和趋势递增,这讲到的是2个维度:

  • 一个要求ID是有序增长的(趋势递增 ,用于排序

  • 一个是要求ID是正向增长的(单调递增 ,下一个一定比上一个大

  • 无规则 : 无规则是指不能按照MySQL主键自增这种方式进行 + 1 自增,简单的自增方式会带来安全层面的风险

最近无意间获得一份阿里大佬写的刷题笔记,一下子打通了我的任督二脉,进大厂原来没那么难。这是大佬写的,7701页的BAT大佬写的刷题笔记,让我offer拿到手软

2.2 有哪些相同性质的问题?

对于分布式 ID 的实现 ,在某些思路上和很多业务是通用的 ,例如 :

  • 订单编号的生成逻辑 :有序 + 反映时间
  • 券码的生成逻辑 : 有序 + 不可推测
  • 动态码 : 付款码,会员动态码等等

这些码的生产一般都会包含上述的2项原则,一定会要求全局唯一 ,同时根据情况来进行有序或者无序的控制。

其实无序一般也是看起来无序,在底层逻辑的生成上不可能完全无序,否则总会出现冲突的场景。

2.3 分布式 ID 的根本实现方式是什么 ?

ID的生成本质上只需要关注两个核心 :

  • 区域的划分 :我们需要保证每台机器是一个固定的区域 ,一般称之为机器ID
  • 锁的控制 : 不止是不同服务之间的分布式锁,还包括同一个服务的线程锁

来简单解读下 ,服务之间的通信很消耗资源 ,所以能不通信实现分布式ID的生成效率是最高的 , 那么一般会在服务启动的时候就计算出对应的工作区间。

同时要理解的是 ,锁往往和性能是对立关系,锁越多 ,则性能会相对越差,所以如何控制锁的粒度,则是分布式ID生成的一大核心。

三. 来探讨一下实现的思路

3.1 常规的分布式ID 算法

可用但是有限制的方案

// 简易版 - 基于时间戳的ID算法 :
- 方案 : 使用时间戳作为ID的前缀,然后通过机器的IP地址或MAC地址进行哈希计算得到剩余部分
- 问题 : 过于简单 , 只能实现单机毫秒级的并发
// 低效版 - 数据库自增
- 方案 : 没有方案 ,交给数据库来
- 问题 : 性能低 , 不支持分库分表
// 升级版 - 基于UUID
- 方案 :
    - 基于时间的UUID:主要依赖当前的时间戳及机器mac地址,因此可以保证全球唯一性
    - 分布式安全的UUID:将版本1的时间戳前四位换为POSIXUIDGID
    - 基于随机数的UUID:基于随机数或伪随机数生成
    - 基于名字空间的UUIDMD5版):基于指定的名字空间/名字生成MD5散列值得到
- 问题 : 长度过长 ,无序 ,不可读

常规的方案 :

  • 基于雪花算法的ID算法

雪花算法是由Twitter开发的一种分布式ID算法,它由几部分组成:时间戳、数据中心ID和机器ID以及序列ID。该算法可以保证ID的唯一性和稳定性,但需要较为复杂的计算和管理。

  • 基于LeaseSet的ID算法

LeaseSet是一种分布式ID系统,它通过将ID划分为多个片段,然后将这些片段分配给不同的机器来生成ID。该算法可以实现高可用和可扩展性,但需要较为复杂的实现和管理。

  • 总结一下

雪花ID一般是常见的分布式ID的方案 ,很多厂商都有这种算法的变种,操作灵活性能也比较理想。我生成主键ID时就是这种方案。

而通过分段的方案性能会很高,会在分布式锁的基础上 一次拿多个ID序列 ,然后在本地消耗这些ID序列。

比如生成订单码的时候 ,会一次性取出100个码,然后本地(单机上)逐步使用这些码。

雪花ID比较通用 。分段方式性能会更好,有序性会更强,毕竟都是连着的。

最近无意间获得一份阿里大佬写的刷题笔记,一下子打通了我的任督二脉,进大厂原来没那么难。这是大佬写的,7701页的BAT大佬写的刷题笔记,让我offer拿到手软

四. 分布式 ID 的简化方案

不同的业务场景对于分布式ID的要求不同 ,所以这里不说业务相关的,只谈实现流程,也没有什么代码

4.1 为你的 ID 定义格式

  • 起始位 : 起始位一般都是 1 ,在日常使用中一般不会变动,除非系统发生了整体的重做又需要保留之前数据时 ,才可以考虑通过这个来进行扩展

  • 总长度 : 位数一般基于具体的业务场景 , 和关联的内容以及数据总量息息相关。

  • 案例一 : 内含时间戳 ,一般 ID 里面会包含一个毫秒精度的时间戳,具体看业务

  • 案例二 : 插入随机数 ,在并发比较高的情况下 ,则需要通过随机数减少ID冲突的概率

  • 总结 : 一般情况下都是 64 位的纯数字 ,短了信息少,并发低。 长了浪费空间,浪费性能,库不支持。

  • 机器ID : 用来描述对应的服务器 , 一般支持1024位(也就是 1024台服务器,大多数情况下够用了)

👉 来看一下最常见的雪花算法的格式 :

0                                       41     51         64
+---------------------------------------+------+-----------+
| 时间戳(以毫秒为单位)                  |机器ID|    递增数  |
+---------------------------------------+------+-----------+

最近无意间获得一份阿里大佬写的刷题笔记,一下子打通了我的任督二脉,进大厂原来没那么难。这是大佬写的,7701页的BAT大佬写的刷题笔记,让我offer拿到手软

👉 来解析下里面的一些具体的细节 :

问题一 : 关于时间戳从什么时候开始

一般我们看到的雪花算法都会以当前时间减去过去一个纪元时间 (参考时间点), 有的可能是 1970 年 1 月 1 日 00:00:00 , 有的可能是上线时间或者一个特殊的时间点

通过这种方式既可以减少整体的长度,让数据变得紧凑 。又可以混淆 ID 的含义,让ID 没有那么容易被解析。

比如上面那个案例 , 可以看到最开始还空了4位数 ,所以时间戳的总空间是一定够的

问题二 : 关于机器ID

机器ID 的目的主要是为了区别不同的机器,从而避免在不同机器上面生成的数据冲突,一般都是通过分布式锁的方式来启动时获取 :

  • Redis 原子获取 : 适用于服务器Pod数不高的场景,启动不频繁,流程比较规范的情况下,用 Redis 完全是足够的
  • 数据库自增 : 一般这些ID的获取都是在系统启动时完成,所以数据库里面通过自增键去做也能实现我们的需求
  • Zookeeper : Zookeeper持久顺序节点的特性也可以实现类似的功能

这3种方式也是传统的分布式锁的获取方式 ,通过自增这种实现保证机器ID每个都不一样。

但是需要避免下面几个问题 :

  • 集群过大或者不同业务使用了同一个表生成 (机器ID一般就1024 ,超过了需要从 0 开始,一般是取模的方式)
  • 避免某个节点长期不重启带来的机器ID冲突
  • 避免某个机器频繁的重启导致机器ID被击穿

问题三 : 关于 sequence 序列ID

重点一 : sequence ID 是先要比对时间戳的 ,时间戳一样这个值才会增加
重点二 : 注意并发的影响 ,要么在生成 ID 的方法上添加 synchronized 控制并发 ,要么使用原子变量

问题四 : 时钟回拨 切记切记

由于上述的分布式 ID 是基于时间来实现的,这种方案最大的问题在于时钟回拨,如果服务器的时间回滚了,而机器又没重启 ,就可能会出现ID的冲突。

也有相关的解决方案 ,最常见的就是启动时校验时钟,比较其他的机器上的时间,方案就不详述了。

再一个就是换种思路 ,时间不是依赖的系统时间 ,而是一个自增的时间位。 这个是百度那边的一种算法,下一章单独讲。

最后总结: ❗❗❗❗

位数不是绝对 ,在保持64位总长度的情况下 ,机器ID 和 最后的自增数都可以随便调节。

包括整体的 64 位也不是完全绝对的 ,业务不同比 64 小几位也完全是可以的。

4.2 简单的实现方案

// S1 : 不管用什么方案 ,Redis 原子自增什么的,拿到一个 机器ID
public long getMechineId() {
    // 伪代码,方案自寻
    return redisService.incr("MECHINE_ID:" + prefixName);
}
// S2 : 构建分布式ID
private static Long lastTimestamp;

// 注意并发问题 ,加锁或者原子变量
public static synchronized long buildId(){
    long timestamp = System.currentTimeMillis();
    
    // 如果时间一致 ,则需要增加 sequenceID
    if (lastTimestamp == timestamp) {
        sequence = sequence + 1L & 1023L;
    } else {
        // 瞎写的 ,目的就是拿到一个 ID ,从 0 开始也可以
        sequence = (long)random.nextInt(128);
    }
    
    // 设置时间戳为最新时间戳
    lastTimestamp = timestamp;
    
    // tenantCode 是初始位 ,可以是0 ,也可以是 1
    // 如果为 0 则可能导致 ID 长度不统一 ,所以这里要根据具体的情况去设置
    // - 这里偏移多少位取决于后续的 sequence 想要留多少空间 ,只要时间戳偏移不要超过总数就行
    // - MechineId 留了 10 位 ,也就是 1024 个机器
    // - sequence 留了 12位 ,也就是每毫秒 4095 个
    return tenantCode << 60 | timestamp - 1288834974657L << 22 | getMechineId() << 12 | sequence;
}

// S3 : 入库时使用
略 ,这就不用说了吧 ,写数据库的时候设置到ID里面就行了

最近无意间获得一份阿里大佬写的刷题笔记,一下子打通了我的任督二脉,进大厂原来没那么难。这是大佬写的,7701页的BAT大佬写的刷题笔记,让我offer拿到手软

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/685634.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

【高校科研前沿】新疆生地所陈亚宁研究员团队在GeoSus发文:在1.5°C和2°C全球升温情景下,中亚地区暴露于极端降水的人口增加

目录 文章简介 1.研究内容 2.相关图件 3.文章引用 文章简介 论文名称&#xff1a;Increased population exposures to extreme precipitation in Central Asia under 1.5 ◦C and 2 ◦C global warming scenarios&#xff08;在1.5C和2C全球变暖情景下&#xff0c;中亚地区…

flutter LINK : ...fatal error LNK1168: �޷���...

执行 flutter run -d windows 后报错 LINK : fatal error LNK1168: &#xfffd;޷&#xfffd;&#xfffd;&#xfffd; E:\xiaoli\flutter_project\huapu_update_hardware\build\windows\x64\runner\Debug\huapu_update_hardware.exe &#xfffd;&#xfffd;&#xfffd;…

gstreamer+mpp调用硬解码播放视频

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 前言一、cpu解码二、gstreamermpp1.默认已安装2.没安装必要软件 总结 前言 以前一直在MPP上开发硬解码推理&#xff0c;最近想弄一个盒子支持调用mpp硬解码播放视频…

OZON快蜗牛数据工具,OZON数据分析工具

在当今的电商时代&#xff0c;数据已经成为了商家们最宝贵的资产之一。无论是产品选品、市场定位&#xff0c;还是营销策略的制定&#xff0c;都离不开对数据的深入分析和精准把握。而在众多电商平台中&#xff0c;OZON以其独特的商业模式和庞大的用户群体&#xff0c;吸引了众…

Docker高级篇之Dockerfile解析

文章目录 1. DockerFile简介2. DockerFile的构建过程3. DockerFile的常用保留字4. 使用案例5. 虚悬镜像 1. DockerFile简介 DockerFile是用来构建Docker镜像的文本文件&#xff0c;是由一条条构建镜像的指令和参数构成的脚本。 2. DockerFile的构建过程 DockerFile内容的基…

DpEasy社区版1.4.0 | 体验全新的数据库特权账号管理平台!

上周&#xff0c;我们在社区发布了 DpEasy 调整为数据库特权账号管理平台的说明&#xff08;详见文章《“一键”掌控数据库特权&#xff0c;DpEasy 新版本即将起航》&#xff09;。今天&#xff0c;DpEasy 作为数据库特权账号管理平台正式发布了第一个版本&#xff0c;即 DpEas…

惠海 H5112C DC-DC降压恒流 PWM调光芯片12V 24V 36V 48V 60V 共阳无频闪 调光细腻顺滑

H5112C多功能平均电流型LED恒流驱动器是一款性能良好的产品&#xff0c;专为大功率恒流LED驱动领域设计。它具备以下显著特点&#xff1a; 宽电压范围&#xff1a;这款驱动器支持5-90V的宽电压输入范围&#xff0c;使其能够适应许多应用环境&#xff0c;有其稳定驱动性能。 准…

【PL理论】(6) F#:标准库之列表(List)

​​​​​ &#x1f4ad; 写在前面&#xff1a;本章我们将介绍 F# 标准库的列表&#xff0c;我们将简单的先过一遍列表的一些常用操作&#xff0c;具体的讲解我们将放在后续章节。 目录 0x00 标准库&#xff1a;列表&#xff08;List&#xff09; 0x01 模式匹配与列表 0x…

【机器学习系列】“购物篮分析入门:使用Apyori库进行关联规则挖掘”

目录 一、关联分析介绍 关键概念&#xff1a; 1. 支持度&#xff08;Support&#xff09; 2. 置信度&#xff08;Confidence&#xff09; 3. 提升度&#xff08;Lift&#xff09; 4. 频繁项集 5. 关联规则 应用场景&#xff1a; 实现方法 二、导入数据集 额外介绍一…

C语言小例程6/100

题目&#xff1a;输入三个整数x,y,z&#xff0c;请把这三个数由小到大输出。 程序分析&#xff1a;我们想办法把最小的数放到x上&#xff0c;先将x与y进行比较&#xff0c;如果x>y则将x与y的值进行交换&#xff0c;然后再用x与z进行比较&#xff0c;如果x>z则将x与z的值…

信号:干扰类别及特征提取

目录 第一部分&#xff1a;干扰类别 1.压制干扰 1.1噪声调幅瞄准式干扰(单音干扰) 1.2噪声调频阻塞式干扰&#xff08;宽带噪声干扰&#xff09; 1.3噪声调频扫频式干扰&#xff08;线性调频&#xff09; 2.欺骗干扰 2.1距离欺骗干扰&#xff08;幅度调制干扰&#xff0…

现代密码学-X.509认证业务

X.509的基础式公钥密码体制和数字签名。 证书 证书的格式 证书由可信的认证机构CA建立并由CA或者用户自己将其放入目录&#xff0c;以供其他用户方便访问。目录服务器本身并不负责为用户建立公钥证书&#xff0c;仅仅为用户访问公钥提供方便。 x.509证书格式 证书的获取 其…

详解 Flink 的运行架构

一、组件 1. JobManager 作业管理器是一个 Flink 集群中任务管理和调度的核心&#xff0c;是控制应用执行的主进程 1.1 JobMaster JobMaster 是 JobManager 中最核心的组件&#xff0c;负责处理单独的作业&#xff08;Job&#xff09;。JobMaster 和具体的 Job 是一一对应的&…

QT快速下载

去QT官网之后&#xff0c;如下图所示 比如要下载qt-opensource-windows-x86-5.14.2.exe&#xff0c;进入5.14对应的文件夹&#xff0c;找到对应的版本 点击Details&#xff0c; 下载对应的种子&#xff0c;然后通过迅雷下载 个人实测&#xff0c;家庭网络平均18M的速率

【云岚到家】-day01-项目熟悉-查询区域服务开发

文章目录 1 云岚家政项目概述1.1 简介1.2 项目业务流程1.3 项目业务模块1.4 项目架构及技术栈1.5 学习后掌握能力 2 熟悉项目2.1 熟悉需求2.2 熟悉设计2.2.1 表结构2.2.2 熟悉工程结构2.2.3 jzo2o-foundations2.2.3.1 工程结构2.2.3.2 接口测试 3 开发区域服务模块3.1 流程分析…

uinty游戏界面模糊的解决方法

1.把低分辨率关掉 2.调缩放&#xff0c;不要调长宽高 3.调整画布的分辨率 4.调整图片的像素点

令人沉醉的移动端 UI 风格

小程序 UI 风格&#xff0c;独具匠心

Vivado 设置关联使用第三方编辑器 Notepad++

目录 1.前言2.Vivado关联外部编辑器步骤3.Notepad的一些便捷操作 微信公众号获取更多FPGA相关源码&#xff1a; 1.前言 Vivado软件自带的编辑器超级难用&#xff0c;代码高亮对比不明显&#xff0c;而且白色背景看久了眼睛痛。为了写代码时有更加舒适的体验&#xff0c;可以…

达梦8 并行查询

达梦数据库可以通过在查询语句加/* parallel */ HINT并行执行。下面以一个排序语句为例 我们通过一条监控语句查询排序区的使用情况。 最初没有查询结果&#xff08;no rows&#xff09; 伴随着语句insert /* parallel(4) */ into d select * from a order by 2执行&#xff…

Android Bugreport分析工具:ChkBugReport教程

安装&#xff1a; 如果下载地址过期请看原仓库地址的wiki&#xff0c;或许会有更新&#xff1a;https://github.com/sonyxperiadev/ChkBugReport/wiki 提前下载好如下文件&#xff1a; ​​​​​​http://sonyxperiadev.github.io/ChkBugReport/download/chkbugreport (Lau…