公共方法源码 · 组件库

# 源码 /** * @author ：Yijs * @date ：Created in 2019/4/23 14:35 * @description：${description * @version : $version */ public static class SnowflakeIdUtil { /** * 获取随机UUID * * @return 随机UUID */ public static String randomUUID() { return UUID.randomUUID().toString(); } /** * 简化的UUID，去掉了横线 * * @return 简化的UUID，去掉了横线 */ public static String simpleUUID() { return UUID.randomUUID().toString(true); } /** * 获取随机UUID，使用性能更好的ThreadLocalRandom生成UUID * * @return 随机UUID * @since 4.1.19 */ public static String fastUUID() { return UUID.fastUUID().toString(); } /** * 简化的UUID，去掉了横线，使用性能更好的ThreadLocalRandom生成UUID * * @return 简化的UUID，去掉了横线 * @since 4.1.19 */ public static String fastSimpleUUID() { return UUID.fastUUID().toString(true); } /** * 创建MongoDB ID生成策略实现 * ObjectId由以下几部分组成： * * <pre> * 1. Time 时间戳。 2. Machine 所在主机的唯一标识符，一般是机器主机名的散列值。 3. PID 进程ID。确保同一机器中不冲突 4. INC 自增计数器。确保同一秒内产生objectId的唯一性。 * </pre> * * 参考：http://blog.csdn.net/qxc1281/article/details/54021882 * * @return ObjectId */ public static String objectId() { return ObjectId.next(); } /** * 创建Twitter的Snowflake 算法 * 分布式系统中，有一些需要使用全局唯一ID的场景，有些时候我们希望能使用一种简单一些的ID，并且希望ID能够按照时间有序生成。 * * snowflake的结构如下(每部分用-分开): * * <pre> * 0 - 0000000000 0000000000 0000000000 0000000000 0 - 00000 - 00000 - 000000000000 * </pre> * * 第一位为未使用，接下来的41位为毫秒级时间(41位的长度可以使用69年) * 然后是5位datacenterId和5位workerId(10位的长度最多支持部署1024个节点） * 最后12位是毫秒内的计数（12位的计数顺序号支持每个节点每毫秒产生4096个ID序号） * * 参考：http://www.cnblogs.com/relucent/p/4955340.html * * @param workerId 终端ID * @param datacenterId 数据中心ID * @return {@link Snowflake} */ public static FgbpSnowflakeUtil createSnowflake(long workerId, long datacenterId) { return new FgbpSnowflakeUtil(workerId, datacenterId); } } /** * Twitter的Snowflake 算法 * 分布式系统中，有一些需要使用全局唯一ID的场景，有些时候我们希望能使用一种简单一些的ID，并且希望ID能够按照时间有序生成。 * * snowflake的结构如下(每部分用-分开): * * <pre> * 0 - 0000000000 0000000000 0000000000 0000000000 0 - 00000 - 00000 - 000000000000 * </pre> * * 第一位为未使用，接下来的41位为毫秒级时间(41位的长度可以使用69年) * 然后是5位datacenterId和5位workerId(10位的长度最多支持部署1024个节点） * 最后12位是毫秒内的计数（12位的计数顺序号支持每个节点每毫秒产生4096个ID序号） * 并且可以通过生成的id反推出生成时间,datacenterId和workerId * * 参考：http://www.cnblogs.com/relucent/p/4955340.html * * @author Looly * @since 3.0.1 */ public static class FgbpSnowflakeUtil { /** * 根据Snowflake的ID，获取机器id * * @param id snowflake算法生成的id * @return 所属机器的id */ public long getWorkerId(long id) { return id >> workerIdShift & ~(-1L << workerIdBits); } /** * 根据Snowflake的ID，获取数据中心id * * @param id snowflake算法生成的id * @return 所属数据中心 */ public long getDataCenterId(long id) { return id >> datacenterIdShift & ~(-1L << datacenterIdBits); } /** * 根据Snowflake的ID，获取生成时间 * * @param id snowflake算法生成的id * @return 生成的时间 */ public long getGenerateDateTime(long id) { return (id >> timestampLeftShift & ~(-1L << 41L)) + twepoch; } private final long twepoch = 1288834974657L; private final long workerIdBits = 2L; private final long datacenterIdBits = 2L; private final long maxWorkerId = -1L ^ (-1L << workerIdBits); private final long maxDatacenterId = -1L ^ (-1L << datacenterIdBits); private final long sequenceBits = 10L; private final long workerIdShift = sequenceBits; private final long datacenterIdShift = sequenceBits + workerIdBits; private final long timestampLeftShift = sequenceBits + workerIdBits + datacenterIdBits; private final long sequenceMask = -1L ^ (-1L << sequenceBits); private long workerId; private long datacenterId; private long sequence = 0L; private long lastTimestamp = -1L; private boolean useSystemClock; /** * 构造 * * @param workerId 终端ID * @param datacenterId 数据中心ID */ public FgbpSnowflakeUtil(long workerId, long datacenterId) { this(workerId, datacenterId, false); } /** * 构造 * * @param workerId 终端ID * @param datacenterId 数据中心ID * @param isUseSystemClock 是否使用 {@link SystemClock} 获取当前时间戳 */ public FgbpSnowflakeUtil(long workerId, long datacenterId, boolean isUseSystemClock) { if (workerId > maxWorkerId || workerId < 0) { throw new IllegalArgumentException( StrUtil.format("worker Id can't be greater than {} or less than 0", maxWorkerId)); } if (datacenterId > maxDatacenterId || datacenterId < 0) { throw new IllegalArgumentException( StrUtil.format("datacenter Id can't be greater than {} or less than 0", maxDatacenterId)); } this.workerId = workerId; this.datacenterId = datacenterId; this.useSystemClock = isUseSystemClock; } /** * 下一个ID * * @return ID */ public synchronized long nextId() { long timestamp = genTime(); if (timestamp < lastTimestamp) { throw new IllegalStateException(StrUtil .format("Clock moved backwards. Refusing to generate id for {}ms", lastTimestamp - timestamp)); } if (lastTimestamp == timestamp) { sequence = (sequence + 1) & sequenceMask; if (sequence == 0) { timestamp = tilNextMillis(lastTimestamp); } } else { sequence = 0L; } lastTimestamp = timestamp; return ((timestamp - twepoch) << timestampLeftShift) | (datacenterId << datacenterIdShift) | (workerId << workerIdShift) | sequence; } /** * 循环等待下一个时间 * * @param lastTimestamp 上次记录的时间 * @return 下一个时间 */ private long tilNextMillis(long lastTimestamp) { long timestamp = genTime(); while (timestamp <= lastTimestamp) { timestamp = genTime(); } return timestamp; } /** * 生成时间戳 * * @return 时间戳 */ private long genTime() { return this.useSystemClock ? SystemClock.now() : System.currentTimeMillis(); } }