package com.wgcloud.util; import cn.hutool.core.lang.Snowflake; import cn.hutool.core.util.IdUtil; import com.wgcloud.config.CommonConfig; import com.wgcloud.util.staticvar.StaticKeys; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import javax.annotation.PostConstruct; /** * @version v3.3 * @ClassName: IdGeneratorSnowflake * @author: http://www.wgstart.com * @date: 2021年05月18日 * @Description: springboot整合雪花算法 * @Copyright: 2019-2021 wgcloud. All rights reserved. */ @Component public class IdGeneratorSnowflake { /** * Twitter_Snowflake
* SnowFlake的结构如下(每部分用-分开):
* 0 - 0000000000 0000000000 0000000000 0000000000 0 - 00000 - 00000 - 000000000000
* 1位标识,由于long基本类型在Java中是带符号的,最高位是符号位,正数是0,负数是1,所以id一般是正数,最高位是0
* 41位时间截(毫秒级),注意,41位时间截不是存储当前时间的时间截,而是存储时间截的差值(当前时间截 - 开始时间截) * 得到的值),这里的的开始时间截,一般是我们的id生成器开始使用的时间,由我们程序来指定的(如下下面程序IdWorker类的startTime属性)。41位的时间截,可以使用69年,年T = (1L << 41) / (1000L * 60 * 60 * 24 * 365) = 69
* 10位的数据机器位,可以部署在1024个节点,包括5位datacenterId和5位workerId
* 12位序列,毫秒内的计数,12位的计数顺序号支持每个节点每毫秒(同一机器,同一时间截)产生4096个ID序号
* 加起来刚好64位,为一个Long型。
* SnowFlake的优点是,整体上按照时间自增排序,并且整个分布式系统内不会产生ID碰撞(由数据中心ID和机器ID作区分),并且效率较高,经测试,SnowFlake每秒能够产生26万ID左右。 */ private static final Logger logger = LoggerFactory.getLogger(IdGeneratorSnowflake.class); @Autowired CommonConfig commonConfig; /** * 工作机器ID(0~31) */ private long workerId = 0; /** * 数据中心ID(0~31) */ private long datacenterId = 1; private Snowflake snowflake = null; //依赖注入完成后执行该方法,进行一些初始化工作 @PostConstruct public void init() { try { if (!StaticKeys.NODE_MASTER.equals(commonConfig.getNodeType())) { String slaveId = commonConfig.getNodeType().replace(StaticKeys.NODE_SLAVE, ""); workerId = Long.valueOf(slaveId); } snowflake = IdUtil.createSnowflake(workerId, datacenterId); logger.info("当前机器的workerId: {}", workerId); } catch (Exception e) { snowflake = IdUtil.createSnowflake(workerId, datacenterId); logger.error("当前机器的workerId获取失败", e); } } //使用默认机房号获取ID public synchronized long snowflakeId() { return snowflake.nextId(); } }