Ref: https://pdai.tech/md/algorithm/alg-domain-id-snowflake.html

    Snowflake,雪花算法是由 Twitter 开源的分布式 ID 生成算法,以划分命名空间的方式将 64-bit 位分割成多个部分,每个部分代表不同的含义。而 Java 中 64bit 的整数是 Long 类型,所以在 Java 中 SnowFlake 算法生成的 ID 就是 long 来存储的。

    • 第 1 位占用 1bit,其值始终是 0,可看做是符号位不使用。
    • 第 2 位开始的 41 位是时间戳,41-bit 位可表示 2^41 个数,每个数代表毫秒,那么雪花算法可用的时间年限是 (1L<<41)/(1000L360024*365)=69 年的时间。
    • 中间的 10-bit 位可表示机器数,即 2^10 = 1024 台机器,但是一般情况下我们不会部署这么台机器。如果我们对 IDC(互联网数据中心)有需求,还可以将 10-bit 分 5-bit 给 IDC,分 5-bit 给工作机器。这样就可以表示 32 个 IDC,每个 IDC 下可以有 32 台机器,具体的划分可以根据自身需求定义。
    • 最后 12-bit 位是自增序列,可表示 2^12 = 4096 个数。

    这样的划分之后相当于在一毫秒一个数据中心的一台机器上可产生 4096 个有序的不重复的 ID。但是我们 IDC 和机器数肯定不止一个,所以毫秒内能生成的有序 ID 数是翻倍的。
    image.png
    Snowflake 的 Twitter 官方原版是用 Scala 写的,对 Scala 语言有研究的同学可以去阅读下,以下是 Java 版本的写法。

    1. package com.jajian.demo.distribute;
    2. /**
    3. * Twitter_Snowflake<br>
    4. * SnowFlake的结构如下(每部分用-分开):<br>
    5. * 0 - 0000000000 0000000000 0000000000 0000000000 0 - 00000 - 00000 - 000000000000 <br>
    6. * 1位标识,由于long基本类型在Java中是带符号的,最高位是符号位,正数是0,负数是1,所以id一般是正数,最高位是0<br>
    7. * 41位时间截(毫秒级),注意,41位时间截不是存储当前时间的时间截,而是存储时间截的差值(当前时间截 - 开始时间截)
    8. * 得到的值),这里的的开始时间截,一般是我们的id生成器开始使用的时间,由我们程序来指定的(如下下面程序IdWorker类的startTime属性)。41位的时间截,可以使用69年,年T = (1L << 41) / (1000L * 60 * 60 * 24 * 365) = 69<br>
    9. * 10位的数据机器位,可以部署在1024个节点,包括5位datacenterId和5位workerId<br>
    10. * 12位序列,毫秒内的计数,12位的计数顺序号支持每个节点每毫秒(同一机器,同一时间截)产生4096个ID序号<br>
    11. * 加起来刚好64位,为一个Long型。<br>
    12. * SnowFlake的优点是,整体上按照时间自增排序,并且整个分布式系统内不会产生ID碰撞(由数据中心ID和机器ID作区分),并且效率较高,经测试,SnowFlake每秒能够产生26万ID左右。
    13. */
    14. public class SnowflakeDistributeId {
    15. // ==============================Fields===========================================
    16. /**
    17. * 开始时间截 (2015-01-01)
    18. */
    19. private final long twepoch = 1420041600000L;
    20. /**
    21. * 机器id所占的位数
    22. */
    23. private final long workerIdBits = 5L;
    24. /**
    25. * 数据标识id所占的位数
    26. */
    27. private final long datacenterIdBits = 5L;
    28. /**
    29. * 支持的最大机器id,结果是31 (这个移位算法可以很快的计算出几位二进制数所能表示的最大十进制数)
    30. */
    31. private final long maxWorkerId = -1L ^ (-1L << workerIdBits);
    32. /**
    33. * 支持的最大数据标识id,结果是31
    34. */
    35. private final long maxDatacenterId = -1L ^ (-1L << datacenterIdBits);
    36. /**
    37. * 序列在id中占的位数
    38. */
    39. private final long sequenceBits = 12L;
    40. /**
    41. * 机器ID向左移12位
    42. */
    43. private final long workerIdShift = sequenceBits;
    44. /**
    45. * 数据标识id向左移17位(12+5)
    46. */
    47. private final long datacenterIdShift = sequenceBits + workerIdBits;
    48. /**
    49. * 时间截向左移22位(5+5+12)
    50. */
    51. private final long timestampLeftShift = sequenceBits + workerIdBits + datacenterIdBits;
    52. /**
    53. * 生成序列的掩码,这里为4095 (0b111111111111=0xfff=4095)
    54. */
    55. private final long sequenceMask = -1L ^ (-1L << sequenceBits);
    56. /**
    57. * 工作机器ID(0~31)
    58. */
    59. private long workerId;
    60. /**
    61. * 数据中心ID(0~31)
    62. */
    63. private long datacenterId;
    64. /**
    65. * 毫秒内序列(0~4095)
    66. */
    67. private long sequence = 0L;
    68. /**
    69. * 上次生成ID的时间截
    70. */
    71. private long lastTimestamp = -1L;
    72. //==============================Constructors=====================================
    73. /**
    74. * 构造函数
    75. *
    76. * @param workerId 工作ID (0~31)
    77. * @param datacenterId 数据中心ID (0~31)
    78. */
    79. public SnowflakeDistributeId(long workerId, long datacenterId) {
    80. if (workerId > maxWorkerId || workerId < 0) {
    81. throw new IllegalArgumentException(String.format("worker Id can't be greater than %d or less than 0", maxWorkerId));
    82. }
    83. if (datacenterId > maxDatacenterId || datacenterId < 0) {
    84. throw new IllegalArgumentException(String.format("datacenter Id can't be greater than %d or less than 0", maxDatacenterId));
    85. }
    86. this.workerId = workerId;
    87. this.datacenterId = datacenterId;
    88. }
    89. // ==============================Methods==========================================
    90. /**
    91. * 获得下一个ID (该方法是线程安全的)
    92. *
    93. * @return SnowflakeId
    94. */
    95. public synchronized long nextId() {
    96. long timestamp = timeGen();
    97. //如果当前时间小于上一次ID生成的时间戳,说明系统时钟回退过这个时候应当抛出异常
    98. if (timestamp < lastTimestamp) {
    99. throw new RuntimeException(
    100. String.format("Clock moved backwards. Refusing to generate id for %d milliseconds", lastTimestamp - timestamp));
    101. }
    102. //如果是同一时间生成的,则进行毫秒内序列
    103. if (lastTimestamp == timestamp) {
    104. sequence = (sequence + 1) & sequenceMask;
    105. //毫秒内序列溢出
    106. if (sequence == 0) {
    107. //阻塞到下一个毫秒,获得新的时间戳
    108. timestamp = tilNextMillis(lastTimestamp);
    109. }
    110. }
    111. //时间戳改变,毫秒内序列重置
    112. else {
    113. sequence = 0L;
    114. }
    115. //上次生成ID的时间截
    116. lastTimestamp = timestamp;
    117. //移位并通过或运算拼到一起组成64位的ID
    118. return ((timestamp - twepoch) << timestampLeftShift) //
    119. | (datacenterId << datacenterIdShift) //
    120. | (workerId << workerIdShift) //
    121. | sequence;
    122. }
    123. /**
    124. * 阻塞到下一个毫秒,直到获得新的时间戳
    125. *
    126. * @param lastTimestamp 上次生成ID的时间截
    127. * @return 当前时间戳
    128. */
    129. protected long tilNextMillis(long lastTimestamp) {
    130. long timestamp = timeGen();
    131. while (timestamp <= lastTimestamp) {
    132. timestamp = timeGen();
    133. }
    134. return timestamp;
    135. }
    136. /**
    137. * 返回以毫秒为单位的当前时间
    138. *
    139. * @return 当前时间(毫秒)
    140. */
    141. protected long timeGen() {
    142. return System.currentTimeMillis();
    143. }
    144. }

    雪花算法提供了一个很好的设计思想,雪花算法生成的 ID 是趋势递增,不依赖数据库等第三方系统,以服务的方式部署,稳定性更高,生成 ID 的性能也是非常高的,而且可以根据自身业务特性分配 bit 位,非常灵活

    但是雪花算法强依赖机器时钟,如果机器上时钟回拨,会导致发号重复或者服务会处于不可用状态。如果恰巧回退前生成过一些 ID,而时间回退后,生成的 ID 就有可能重复。官方对于此并没有给出解决方案,而是简单的抛错处理,这样会造成在时间被追回之前的这段时间服务不可用。

    很多其他类雪花算法也是在此思想上的设计然后改进规避它的缺陷,后面介绍的百度 UidGenerator 和 美团分布式ID生成系统 Leaf 中 snowflake 模式都是在 snowflake 的基础上演进出来的。