From 4678fbe8165888672985e2ac5310ed4934cf6a5e Mon Sep 17 00:00:00 2001 From: ZhouXY108 Date: Fri, 16 Jun 2023 02:39:37 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=20SnowflakeIdGenerateor?= =?UTF-8?q?=EF=BC=8C=E4=BD=BF=E7=94=A8=E9=9B=AA=E5=8D=8E=E7=AE=97=E6=B3=95?= =?UTF-8?q?=E7=94=9F=E6=88=90=20ID=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../commons/util/SnowflakeIdGenerator.java | 159 ++++++++++++++++++ 1 file changed, 159 insertions(+) create mode 100644 src/main/java/xyz/zhouxy/plusone/commons/util/SnowflakeIdGenerator.java diff --git a/src/main/java/xyz/zhouxy/plusone/commons/util/SnowflakeIdGenerator.java b/src/main/java/xyz/zhouxy/plusone/commons/util/SnowflakeIdGenerator.java new file mode 100644 index 0000000..4e410b2 --- /dev/null +++ b/src/main/java/xyz/zhouxy/plusone/commons/util/SnowflakeIdGenerator.java @@ -0,0 +1,159 @@ +package xyz.zhouxy.plusone.commons.util; + +import java.util.concurrent.TimeUnit; + +import com.google.common.annotations.Beta; + +/** + * Twitter_Snowflake + */ +@Beta +public class SnowflakeIdGenerator { + + // ==============================Fields=========================================== + /** 开始时间截（北京时间 2008/08/08 20:00） */ + private static final long TWEPOCH = 1218196800000L; + + /** 机器id所占的位数 */ + private static final long WORKER_ID_BITS = 5L; + + /** 数据标识id所占的位数 */ + private static final long DATACENTER_ID_BITS = 5L; + + /** 支持的最大机器 id，结果是 31 (这个移位算法可以很快的计算出几位二进制数所能表示的最大十进制数) */ + private static final long MAX_WORKER_ID = -1L ^ (-1L << WORKER_ID_BITS); + + /** 支持的最大数据标识 id，结果是 31 */ + private static final long MAX_DATACENTER_ID = -1L ^ (-1L << DATACENTER_ID_BITS); + + /** 序列在 id 中占的位数 */ + private static final long SEQUENCE_BITS = 12L; + + /** 机器 ID 向左移 12 位 */ + private static final long WORKER_ID_SHIFT = SEQUENCE_BITS; + + /** 数据标识id向左移 17 位 (12+5) */ + private static final long DATACENTER_ID_SHIFT = SEQUENCE_BITS + WORKER_ID_BITS; + + /** 时间截向左移 22 位 (5+5+12) */ + private static final long TIMESTAMP_LEFT_SHIFT = SEQUENCE_BITS + WORKER_ID_BITS + DATACENTER_ID_BITS; + + /** 生成序列的掩码，这里为 4095 (0b111111111111=0xfff=4095) */ + private static final long SEQUENCE_MASK = -1L ^ (-1L << SEQUENCE_BITS); + + /** 工作机器 ID (0~31) */ + private long workerId; + + /** 数据中心 ID (0~31) */ + private long datacenterId; + + /** 毫秒内序列 (0~4095) */ + private long sequence = 0L; + + /** 上次生成 ID 的时间截 */ + private long lastTimestamp = -1L; + + // ==============================Constructors===================================== + /** + * 构造函数 + * + * @param workerId 工作ID (0~31) + * @param datacenterId 数据中心ID (0~31) + */ + public SnowflakeIdGenerator(long workerId, long datacenterId) { + if (workerId > MAX_WORKER_ID || workerId < 0) { + throw new IllegalArgumentException( + String.format("WorkerId can't be greater than %d or less than 0.", MAX_WORKER_ID)); + } + if (datacenterId > MAX_DATACENTER_ID || datacenterId < 0) { + throw new IllegalArgumentException( + String.format("DatacenterId can't be greater than %d or less than 0.", MAX_DATACENTER_ID)); + } + this.workerId = workerId; + this.datacenterId = datacenterId; + } + + // ==============================Methods========================================== + /** + * 获得下一个ID (该方法是线程安全的) + * + * @return SnowflakeId + * @throws InterruptedException + */ + public synchronized long nextId() { + long timestamp = timeGen(); + + // 发生了回拨，此刻时间小于上次发号时间 + if (timestamp < lastTimestamp) { + long offset = lastTimestamp - timestamp; + if (offset <= 5) { + // 时间偏差大小小于5ms，则等待两倍时间 + try { + TimeUnit.MILLISECONDS.sleep(offset << 1); + } catch (InterruptedException e) { + Thread.currentThread().interrupt(); + throw new IllegalStateException(e); + } + timestamp = timeGen(); + if (timestamp < lastTimestamp) { + // 还是小于，抛异常上报 + throwClockBackwardsEx(lastTimestamp, timestamp); + } + } else { + throwClockBackwardsEx(lastTimestamp, timestamp); + } + } + + // 如果是同一时间生成的，则进行毫秒内序列 + if (lastTimestamp == timestamp) { + sequence = (sequence + 1) & SEQUENCE_MASK; + // 毫秒内序列溢出 + if (sequence == 0) { + // 阻塞到下一个毫秒,获得新的时间戳 + timestamp = tilNextMillis(lastTimestamp); + } + } + // 时间戳改变，毫秒内序列重置 + else { + sequence = 0L; + } + + // 上次生成 ID 的时间截 + lastTimestamp = timestamp; + + // 移位并通过或运算拼到一起组成64位的ID + return ((timestamp - TWEPOCH) << TIMESTAMP_LEFT_SHIFT) // + | (datacenterId << DATACENTER_ID_SHIFT) // + | (workerId << WORKER_ID_SHIFT) // + | sequence; + } + + /** + * 阻塞到下一个毫秒，直到获得新的时间戳 + * + * @param lastTimestamp 上次生成ID的时间截 + * @return 当前时间戳 + */ + protected long tilNextMillis(long lastTimestamp) { + long timestamp = timeGen(); + while (timestamp <= lastTimestamp) { + timestamp = timeGen(); + } + return timestamp; + } + + /** + * 返回以毫秒为单位的当前时间 + * + * @return 当前时间（毫秒） + */ + protected long timeGen() { + return System.currentTimeMillis(); + } + + protected void throwClockBackwardsEx(long lastTimestamp, long timestamp) { + throw new IllegalStateException( + String.format("Clock moved backwards. Refusing to generate id for %d milliseconds", + lastTimestamp - timestamp)); + } +}