SnowFlake算法是Twitter设计的一个可以在分布式系统中生成唯一的ID的算法,它可以满足Twitter每秒上万条消息ID分配的请求,这些消息ID是唯一的且有大致的递增顺序
SnowFlake算法产生的ID是一个64位的整型,结构如下(每一部分用“-”符号分隔):
0 - 0000000000 0000000000 0000000000 0000000000 0 - 00000 - 00000 - 000000000000
1位标识部分,在java中由于long的最高位是符号位,正数是0,负数是1,一般生成的ID为正数,所以为0;
41位时间戳部分,这个是毫秒级的时间,一般实现上不会存储当前的时间戳,而是时间戳的差值(当前时间-固定的开始时间),这样可以使产生的ID从更小值开始;41位的时间戳可以使用69年,(1L << 41) / (1000L * 60 * 60 * 24 * 365) = 69年;
10位节点部分,Twitter实现中使用前5位作为数据中心标识,后5位作为机器标识,可以部署1024个节点;
12位序列号部分,支持同一毫秒内同一个节点可以生成4096个ID;
SnowFlake算法生成的ID大致上是按照时间递增的,用在分布式系统中时,需要注意数据中心标识和机器标识必须唯一,这样就能保证每个节点生成的ID都是唯一的。或许我们不一定都需要像上面那样使用5位作为数据中心标识,5位作为机器标识,可以根据我们业务的需要,灵活分配节点部分,如:若不需要数据中心,完全可以使用全部10位作为机器标识;若数据中心不多,也可以只使用3位作为数据中心,7位作为机器标识
源码如下:
package com.wws.mytest;
/**
* @program: mytest
* @description: SnowFlake雪花算法
* @author: weishi.wang
* @create: 2019-10-30 09:59
*/
public class SnowFlake {
private final static long START_STMP = 1480166465631L;
/**
* 每一部分占用的位数
*/
private final static long SEQUENCE_BIT = 12; //序列号占用的位数
private final static long MACHINE_BIT = 5; //机器标识占用的位数
private final static long DATACENTER_BIT = 5;//数据中心占用的位数
/**
* 每一部分的最大值
*/
private final static long MAX_DATACENTER_NUM = -1L ^ (-1L << DATACENTER_BIT);
private final static long MAX_MACHINE_NUM = -1L ^ (-1L << MACHINE_BIT);
private final static long MAX_SEQUENCE = -1L ^ (-1L << SEQUENCE_BIT);
/**
* 每一部分向左的位移
*/
private final static long MACHINE_LEFT = SEQUENCE_BIT;
private final static long DATACENTER_LEFT = SEQUENCE_BIT + MACHINE_BIT;
private final static long TIMESTMP_LEFT = DATACENTER_LEFT + DATACENTER_BIT;
private long datacenterId; //数据中心
private long machineId; //机器标识
private long sequence = 0L; //序列号
private long lastStmp = -1L;//上一次时间戳
public SnowFlake(long datacenterId, long machineId) {
if (datacenterId > MAX_DATACENTER_NUM || datacenterId < 0) {
throw new IllegalArgumentException("datacenterId can't be greater than MAX_DATACENTER_NUM or less than 0");
}
if (machineId > MAX_MACHINE_NUM || machineId < 0) {
throw new IllegalArgumentException("machineId can't be greater than MAX_MACHINE_NUM or less than 0");
}
this.datacenterId = datacenterId;
this.machineId = machineId;
}
/**
* 产生下一个ID
*
* @return
*/
public synchronized long nextId() {
long currStmp = getNewstmp();
if (currStmp < lastStmp) {
throw new RuntimeException("Clock moved backwards. Refusing to generate id");
}
if (currStmp == lastStmp) {
//相同毫秒内,序列号自增
sequence = (sequence + 1) & MAX_SEQUENCE;
//同一毫秒的序列数已经达到最大
if (sequence == 0L) {
currStmp = getNextMill();
}
} else {
//不同毫秒内,序列号置为0
sequence = 0L;
}
lastStmp = currStmp;
return (currStmp - START_STMP) << TIMESTMP_LEFT //时间戳部分
| datacenterId << DATACENTER_LEFT //数据中心部分
| machineId << MACHINE_LEFT //机器标识部分
| sequence; //序列号部分
}
private long getNextMill() {
long mill = getNewstmp();
while (mill <= lastStmp) {
mill = getNewstmp();
}
return mill;
}
private long getNewstmp() {
return System.currentTimeMillis();
}
}
测试方法:
public static void main(String[] args) {
SnowFlake snowFlake = new SnowFlake(2, 3);
for (int i = 0; i < (1 << 12); i++) {
System.out.println(snowFlake.nextId());
}
}
文章浏览阅读9.9k次。当使用Mybatis-plus的ASSIGN_ID主键生成策略时,出现两条数据id相同,导致添加不进数据库的问题,根据ASSIGN_ID生成策略原理,一毫秒的时间可以生成4096个不同主键(),实际使用上基本不可能出现重复id,但是却出现了,下面这个回答可能会解决你的问题。_数据库里是空的,但是mybatis plus提示主键重复
文章浏览阅读1.2w次。支付宝扫码支付首先申请 appid、app_private_key,publicKey,直接上代码:方式一:可以禁用支付通道(disable_pay_channels)public static void main(String[] args) throws AlipayApiException {AlipayClient alipayClient = new DefaultAlipay..._java支付宝网站支付参数中传了qr_pay_mode=4,前端怎么从body生成二维码
文章浏览阅读253次。mysql安装包教程1.下载mysql安装包MySQL官网下载连接:http://www.mysql.com/downloads/mysql/2.将zip包解压到本地目录这里我解压到了目录 C:\Program Files\MySQL当然也可以是 D:\MySQL 等其他目录3.添加系统环境变量MYSQL_HOME ==>C:\Program Files\MySQLPATH==>;%..._mysql-front 连接mysql server
文章浏览阅读3.6k次。JsonObject to FstringTSharedRef<TJsonWriter<>> Writer = TJsonWriterFactory<>::Create(&JsonStr);FJsonSerializer::Serialize(JsonObject.ToSharedRef(), Writer); FString to Js..._fjsonserializer::serialize
文章浏览阅读768次,点赞10次,收藏17次。介绍计算机领域相关证书
文章浏览阅读9.8k次,点赞6次,收藏14次。SPSS导入excel文件时,保留4位小数点欢迎使用Markdown编辑器欢迎使用Markdown编辑器SPSS导入excel文件时,会只保留整数部分,而小数点部分的数据不显示,如下图:我尝试在SPSS的变量视图里将小数点位数改成4位,如图,但是导入数据后,仍是只保留整数部分,不知道问题何在了。如若先导入数据,再改变变量视图里面的小数点位数,则小数点只以".0000"显示。如图:最..._spss导入excel数据小数后位数不符
文章浏览阅读224次。 前些日子,由于上头要来大领导到绿之韵集团视察,公司总经理发动了一场“全员大扫除” 活动。和绿之韵历次的扫除一样,很多员工虽说很努力,实际上却还是有一些工作没到位。最经典的例子, 就是在绿之韵内部称之为“围桌擦地”的现象。 简单点儿说, 就是一些绿之韵员工在擦地的时候,总是绕着桌子、 沙发等办公用具擦, 有时候忘记了把这些物件儿搬开点儿, 挪个地儿擦擦它们底下的部分。结果可想而知,..._开拓精神
文章浏览阅读252次。Git使用教程之本地仓库的基本操作Git是什么?一个分布式版本控制系统,和SVN类似,但远比SVN强大的一个版本控制系统 ①Git可以方便的在本地进行版本管理,如同你本地有一个版本管理服务器一样 我们可以选择在合适的时间将本地版本推送到统一的版本管理服务器 ②Git每次会提取整个代码仓库的完整镜像,相当于对整个代码仓库都进行了一次备份,这样计时版本服务器_git 查看本地仓库的代码
文章浏览阅读1.7k次。3209: 花神的数论题Time Limit: 10 Sec Memory Limit: 128 MBSubmit: 33 Solved: 18[Submit][Status][Discuss]Description背景众所周知,花神多年来凭借无边的神力狂虐各大 OJ、OI、CF、TC …… 当然也包括 CH 啦。描述话说花神这天又来讲课了。课后照例有超级难_背景 众所周知,花神多年来凭借无边的神力狂虐各大 oj、oi、cf、tc …… 当然也包
文章浏览阅读1.5k次。在写这篇博客之前,我想淡淡的发表下自己的观点:在写技术博客的时候用点心,积点德,自己搞清楚了在往上写,比如下面这一位,可把我坑惨了https://www.cnblogs.com/wuchanming/p/4043480.html我都跟着一步步的往下做了,后面 他突然来了一句,他也没搭出来环境,我....呵呵just a joke~开始正题,最近在测bcache,dm-cache以及flashc..._centos7安装flashcache
文章浏览阅读227次。点击“开发者技术前线”,选择“星标????”让一部分开发者看到未来在多形态业务场景下,如何保障多端体验的一致性,是前端技术领域一个比较受关注的方向。美团外卖前端技术团队基于 Flutter..._美团商家版 用什么开发工具
文章浏览阅读243次。启动SpringCloudEureka 报错:com.netflix.discovery.shared.transport.TransportException: Cannot execute request on any known server原因是SpringCloudEureka这个应用本身就是eureka服务器,不需要不断的尝试连接注册自己。可以添加以下配置:如果配置文件a..._receive server push request, request = notifysubscriberrequest, requestid =