ID生成器

模块说明

使用方法

非springboot项目

Maven依赖

<dependency>
 <groupId>com.doublechain</groupId>
 <artifactId>snowflake</artifactId>
 <version>1.0.0</version>
</dependency>

静态配置方式

NodeIdentityProvider nodeIdentityProvider = new DefaultNodeIdentityProvider(worker, dataCenter, group);
SnowFlakeIdGenerator idGenerator = new SnowFlakeIdGenerator(nodeIdentityProvider, startEpochMs);
idGenerator.start();
for (int i = 0; i < 5 ; i++) {
 long id = idGenerator.nextId();
}
idGenerator.stop();

使用ignite管理

TcpDiscoverySpi discoverySpi = new TcpDiscoverySpi();
TcpDiscoveryMulticastIpFinder ipFinder = new TcpDiscoveryMulticastIpFinder();
ipFinder.setMulticastGroup("228.1.2.4");
discoverySpi.setIpFinder(ipFinder);
NodeIdentityProvider nodeIdentityProvider = IgniteNodeIdentityProvider(group, dataCenter, discoverySpi);
SnowFlakeIdGenerator idGenerator = new SnowFlakeIdGenerator(nodeIdentityProvider, startEpochMs);
idGenerator.start();
for (int i = 0; i < 5 ; i++) {
 long id = idGenerator.nextId();
}
idGenerator.stop();

使用zookeeper管理

NodeIdentityProvider nodeIdentityProvider = ZookeeperNodeIdentityProvider.builder(dataCenter, group, zkServers)
 .namespace(namespace)
 .sessionTimeoutMs(sessionTimeoutMs)
 .build();
SnowFlakeIdGenerator idGenerator = new SnowFlakeIdGenerator(nodeIdentityProvider, startEpochMs);
idGenerator.start();
for (int i = 0; i < 5 ; i++) {
 long id = idGenerator.nextId();
}
idGenerator.stop();

Springboot项目

使用ignite管理

Maven依赖

<dependency>
 <groupId>com.doublechain</groupId>
 <artifactId>snowflake-ignite-starter</artifactId>
 <version>1.0.0</version>
</dependency>

Springboot配置文件

doublechain:
 idgen:
 snowflake:
 data-center: 1 #指定snowflake的data center的Id
 group: test #group用于隔离snowflake的全局性的范围,比如你可以指定在test这个项目内全局唯一
 start-timestamp: 2019年06月01日T12:00:00 #由于snowflake的时间戳采用41位存储。所以最多能使用69年,请合理设置起始时间。设定后不应该再改动,默认值是2018年01月01日T00:00:00
 ignite:
 multicast:
 group-ip: 228.1.2.4 #ignite用于组播通讯的ip
 multicast-port: 47401 #ignite用于发送组播消息的端口
 discovery-type: multicast #节点发现发现目前只支持组播

使用zookeeper管理

Maven依赖

<dependency>
 <groupId>com.doublechain</groupId>
 <artifactId>snowflake-zookeeper-starter</artifactId>
 <version>1.0.0</version>
</dependency>

Springboot配置文件

doublechain:
 idgen:
 snowflake:
 data-center: 1 #指定snowflake的data center的Id
 group: test #group用于隔离snowflake的全局性的范围,比如你可以指定在test这个项目内全局唯一
 start-timestamp: 2019年06月01日T12:00:00 #由于snowflake的时间戳采用41位存储。所以最多能使用69年,请合理设置起始时间。设定后不应该再改动,默认值是2018年01月01日T00:00:00
 zookeeper:
 namespace: my-snowflake #注册到zookeeper上的根路径,和其他中间件公用同一个zookeeper集群的时候可能会用到。
 servers: 10.0.0.32:2181 #zookeeper集群地址,逗号分隔
 session-timeout-ms: 30000 #zookeeper会话超时时间

@Autowired
private SnowFlakeIdGenerator idGenerator;

说明