一、关于雪花

雪花(snowflake)在自然界中,是极具独特美丽,又变幻莫测的东西:雪花属于六方晶系,它具有四个结晶轴,其中三个辅轴在一个基面上,互相以60度的角度相交,第四轴(主晶轴)与三个辅轴所形成的基面垂直;

雪花的基本形状是六角形,但是大自然中却几乎找不出两朵完全相同的雪花,每一个雪花都拥有自己的独有图案,就象地球上找不出两个完全相同的人一样。许多学者用显微镜观测过成千上万朵雪花,这些研究最后表明,形状、大小完全一样和各部分完全对称的雪花,在自然界中是无法形成的。

二、雪花算法

雪花算法的原始版本是scala版,用于生成分布式ID(纯数字,时间顺序),订单编号等。自增ID:对于数据敏感场景不宜使用,且不适合于分布式场景。GUID:采用无意义字符串,数据量增大时造成访问过慢,且不宜排序。

算法描述:最高位是符号位,始终为0,不可用。

41位的时间序列,精确到毫秒级,41位的长度可以使用69年。时间位还有一个很重要的作用是可以根据时间进行排序。

10位的机器标识,10位的长度最多支持部署1024个节点。

12位的计数序列号,序列号即一系列的自增id,可以支持同一节点同一毫秒生成多个ID序号,12位的计数序列号支持每个节点每毫秒产生4096个ID序号。

三、实现过程

①、创建雪花算法实例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 <

private final static long MAX_MACHINE_NUM = -1L ^ (-1L <

private final static long MAX_SEQUENCE = -1L ^ (-1L <

/**

* 每一部分向左的位移

*/

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

throw new IllegalArgumentException("datacenterId can't be greater than MAX_DATACENTER_NUM or less than 0");

}

if (machineId > MAX_MACHINE_NUM || machineId

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

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) <

| datacenterId <

| machineId <

| sequence;                            //序列号部分

}

private long getNextMill() {

long mill = getNewstmp();

while (mill <= lastStmp) {

mill = getNewstmp();

}

return mill;

}

private long getNewstmp() {

return System.currentTimeMillis();

}

}

②、创建雪花算法工厂类public static class Factory {

/**

* 每一部分占用位数的默认值

*/

private final static int DEFAULT_MACHINE_BIT_NUM = 5;   //机器标识占用的位数

private final static int DEFAULT_IDC_BIT_NUM = 5;//数据中心占用的位数

private int machineBitNum;

private int idcBitNum;

public Factory() {

this.idcBitNum = DEFAULT_IDC_BIT_NUM;

this.machineBitNum = DEFAULT_MACHINE_BIT_NUM;

}

public Factory(int machineBitNum, int idcBitNum) {

this.idcBitNum = idcBitNum;

this.machineBitNum = machineBitNum;

}

public SnowFlakeGenerator create(long idcId, long machineId) {

return new SnowFlakeGenerator(this.idcBitNum, this.machineBitNum, idcId, machineId);

}

}

③、雪花算法核心代码private SnowFlakeGenerator(int idcBitNum, int machineBitNum, long idcId, long machineId) {

int sequenceBitNum = REMAIN_BIT_NUM - idcBitNum - machineBitNum;

if (idcBitNum <= 0 || machineBitNum <= 0 || sequenceBitNum <= 0) {

throw new IllegalArgumentException("error bit number");

}

this.maxSequenceValue = ~(-1 <

machineBitLeftOffset = sequenceBitNum;

idcBitLeftOffset = idcBitNum + sequenceBitNum;

timestampBitLeftOffset = idcBitNum + machineBitNum + sequenceBitNum;

this.idcId = idcId;

this.machineId = machineId;

}

/**

* 产生下一个ID

*/

public synchronized long nextId() {

long currentStamp = getTimeMill();

if (currentStamp

throw new RuntimeException(String.format("Clock moved backwards. Refusing to generate id for %d milliseconds", lastStamp - currentStamp));

}

//新的毫秒,序列从0开始,否则序列自增

if (currentStamp == lastStamp) {

sequence = (sequence + 1) & this.maxSequenceValue;

if (sequence == 0L) {

//Twitter源代码中的逻辑是循环,直到下一个毫秒

lastStamp = tilNextMillis();

//                throw new IllegalStateException("sequence over flow");

}

} else {

sequence = 0L;

}

lastStamp = currentStamp;

return (currentStamp - START_STAMP) <

}

private long getTimeMill() {

return System.currentTimeMillis();

}

private long tilNextMillis() {

long timestamp = getTimeMill();

while (timestamp <= lastStamp) {

timestamp = getTimeMill();

}

return timestamp;

}

④、项目效果图

四、项目结构图

五、补充

雪花算法的缺点:

1.毫秒数在高位,自增序列在低位,整个ID都是趋势递增的。

2.不依赖数据库等第三方系统,以服务的方式部署,稳定性更高,生成ID的性能也是非常高的。

3.可以根据自身业务特性分配bit位,非常灵活。

雪花算法的缺点:强依赖机器时钟,如果机器上时钟回拨,会导致发号重复或者服务会处于不可用状态。

java雪花_基于java实现的雪花算法相关推荐

  1. 租车java 查询_基于java实现租车管理系统

    概述 基于java + swing + JFrame 的图书馆管理系统,租车,还车,管理员管理用户,付款等. 部分代码 public class Login extends JFrame { priv ...

  2. 抽奖功能java开发_基于Java实现抽奖系统

    摘要:这篇Java开发技术栏目下的"基于Java实现抽奖系统",介绍的技术点是"抽奖系统.Java.抽奖.基于.系统.实现",希望对大家开发技术学习和问题解决有 ...

  3. java魔塔_基于java的魔塔游戏的设计与实现论文.docx

    毕业设计(论文)题目: 基于java的魔塔游戏的设计与实现 毕业设计(论文)要求及原始数据(资料): 1.了解和运用Java面向对象的特性: 2.熟练掌握模块化设计的思想,锻炼使用java语言的能力: ...

  4. 医院医生评价的java代码_基于JAVA的医院信息查询接口调用代码实例

    基于JAVA的医院信息查询接口调用代码实例 import java.io.BufferedReader; import java.io.DataOutputStream; import java.io ...

  5. 物联网 云端java架构_基于java的物联网架构实现

    基于java的多设备类型物联网架构实现 前言:19年11月开始从 [金融]行业转 [物联网],路途坎坷,一个人摸索前进,不过也学到了很多新的东西,交了很多好朋友,在此感谢各位! 以下是一些经验分享,希 ...

  6. java比价_基于JAVA的慢慢买比价网api调用代码实例

    基于JA V A的慢慢买比价网api调用代码实例 代码描述:基于JA V A的慢慢买比价网api调用代码实例 代码平台:聚合数据 import java.io.BufferedReader; impo ...

  7. 图像分割的java程序_基于java的图像分割(数字图像处理)

    [实例简介] 基于java的图像分割(数字图像处理),程序中包含 全局阈值分割,Roberts边缘检测分割,灰度图像,直方图. [实例截图] [核心代码] ImageProcess └── Image ...

  8. hannoi塔java程序_基于Java实现的Hannoi汉诺塔自动演示程序

    1 设计要求 设计GUI界面的Hannoi塔.汉诺塔中有三个座,名字分别为A,B,C.初始状态时A塔上有3个大小不等的盘子,这些盘子从座底到座顶按着大小顺序依次摆放在A座上.用户可以用鼠标选中盘子,然 ...

  9. 21点 小游戏 java代码_基于Java的21点扑克游戏的实现

    在上次写的比较牌点的扑克游戏上Java扑克游戏(多人多牌数比较游戏)的实现中,添加21点游戏规则,实现21点牌类游戏.具体实现步骤如下:[需要源代码的留QQ,大家一起探讨探讨哈,谢谢啦!] 抽象出规则 ...

  10. java 斗地主_基于java实现斗地主代码实例解析

    斗地主 规则: 1. 组装54张扑克牌 2. 将54张牌顺序打乱 3. 三个玩家参与游戏,三人交替摸牌,每人17张牌,最后三张留作底牌. 4. 查看三人各自手中的牌(按照牌的大小排序).底牌 手中扑克 ...

最新文章

  1. 未在本地计算机上注册“microsoft.ACE.oledb.12.0”提供程序
  2. BeautifulSoup_第二节
  3. 不要使用Android Studio的Git Commit了----记一次debug
  4. [20161031]rman备份与数据文件OS块.txt
  5. Flowable通过api查询流程返回流程图节点
  6. linux系统下压缩文件,Linux系统下文件的压缩.打包与解压
  7. 『TensorFlow』通过代码理解gan网络_中
  8. java 动软_动软代码生成器下载_2017动软代码生成器下载及相关推荐 - noYes软件大全...
  9. linux比较两个目录的差异
  10. [转]在一个工程中添加别的工程的中已创建好的对话框资源。
  11. IP地址专题六:计算相关地址
  12. Qt 递归安装父控件的所有子孙控件事件过滤器 遍历安装事件过滤器
  13. 2022年最全公关活动策划案例(共14份)
  14. Git 及 GitHub实用教程
  15. 大众点评产品分析报告
  16. js原生实现图片爆炸效果
  17. 什么?你连个三色渐变圆角按钮都需要UI切图?
  18. 511遇见易语言文本替换和子文本替换
  19. IT技术支持工程师岗位职责
  20. 浪潮nf5220服务器做系统,【浪潮NF5220参数】浪潮NF5220系列服务器参数-ZOL中关村在线...

热门文章

  1. QCon旧金山2016大会,议题发布及研讨会一瞥
  2. Android 解析新浪RSS新闻源 问题汇总和解决
  3. JCG836pro路由器刷入breed
  4. 2019届阿里巴巴春招前端面试经历
  5. Java转换ofd格式到pdf
  6. 我的博客开通啦,以后会记录一位IT女的学习生涯
  7. 如何批量修改文件名字的一部分?
  8. c++篇 cad.grx 入门,手动配置编译环境
  9. 三级管的三种工作状态
  10. 开源软件和商业软件版本的介绍:alpha、beta、rc、GA等等