https://blog.csdn.net/fayeyiwang/article/details/52128206
https://tech.meituan.com/2017/04/21/mt-leaf.html
關(guān)于訂單號(hào)的生成幢尚，有一些簡單的方案
1哈扮，數(shù)據(jù)庫自增長id
優(yōu)勢： 無需編碼
缺陷：
大表不能做水平分表余黎，否則插入刪除時(shí)容易出現(xiàn)問題
高并發(fā)下插入數(shù)據(jù)需要加入失誤機(jī)制
在業(yè)務(wù)操作父战得，子表（關(guān)聯(lián)表）插入時(shí)火俄，先要插入父表户侥，再插入子表
2在孝，時(shí)間戳+ 隨機(jī)數(shù)
優(yōu)勢： 編程簡單
缺陷： 隨機(jī)數(shù)存在重復(fù)問題恶导，即使在相同的時(shí)間戳下崭篡。每次插入數(shù)據(jù)庫前需要校驗(yàn)下是否已經(jīng)存在相同的數(shù)值挪哄。
3，時(shí)間戳+會(huì)員ID
優(yōu)勢： 同一時(shí)間琉闪，一個(gè)用戶不會(huì)存在2張訂單
缺陷： 會(huì)員ID也會(huì)透露出運(yùn)營數(shù)據(jù)迹炼，雞生蛋蛋生雞的問題
4，GUID/UUID
優(yōu)勢： 簡單
劣勢： 用戶不友好，索引關(guān)聯(lián)效率較低
5 snowflake方案：
snowflake是Twitter開源的分布式ID 生成算法斯入，結(jié)果是一個(gè)long型的ID
這種方案大致來說是一種以劃分明明空間（UUID也算砂碉，由于比較常見，所以單獨(dú)分析）來生成的ID 的一種算法刻两，這種方案把64-bit分貝劃分成多段增蹭，分開來提示機(jī)器，時(shí)間等磅摹；
其核心思想是： 使用41bit作為毫秒數(shù)滋迈，10bit作為機(jī)器的ID(5ge bit是數(shù)據(jù)中心，5個(gè)bit的機(jī)器ID),12bit 作為毫秒數(shù)內(nèi)的流水號(hào)户誓，最后一個(gè)符號(hào)位饼灿，永遠(yuǎn)是0.
比如在snowlake中的64-bit分別表示如下圖（圖片來自網(wǎng)絡(luò)）表示image
整個(gè)結(jié)構(gòu)是64位，所以我們?cè)贘ava中可以使用long來進(jìn)行存儲(chǔ)厅克。該算法實(shí)現(xiàn)基本就是二進(jìn)制操作赔退，單機(jī)每秒內(nèi)理論上最多可以生成1024(2^12),也就是409.6萬個(gè)ID(10244096=4194304)
0 - 0000000000 0000000000 0000000000 0000000000 0 - 00000 - 00000 - 000000000000
1位標(biāo)識(shí)， 由于long基本類型在java中是帶符號(hào)的证舟，最高位是符號(hào)位硕旗，正數(shù)是0，負(fù)數(shù)是1女责，所以id一般是正數(shù)漆枚，最高位是0
41位時(shí)間戳（毫秒級(jí)），注意抵知，41位時(shí)間戳不是存儲(chǔ)當(dāng)前時(shí)間的時(shí)間戳墙基，而是存儲(chǔ)時(shí)間戳的差值（當(dāng)前時(shí)間戳-開始時(shí)間戳）得到的值），這里的開始時(shí)間戳刷喜，一般是我們的id生成器開始使用的時(shí)間残制，由我們的程序開始指定（如下面程序的IdWorker 類的starttime屬性）。41位時(shí)間可以使用69年T = (1L << 41) / (1000L * 60 * 60 * 24 * 365) = 69
10 位的數(shù)據(jù)機(jī)器位掖疮，可以部署在1024個(gè)節(jié)點(diǎn)上初茶，包括5位datacenterId和3位workerid.10 -bit機(jī)器可以分別表示1024臺(tái)機(jī)器。如果我們對(duì)IDC劃分有需求浊闪，還可以將10-bit分5bit給IDC,分5-bit給工作機(jī)器恼布。這樣就可以表示32IDC,每個(gè)IDC下可以有32臺(tái)機(jī)器，可與根據(jù)自身需求定義搁宾。
12位序列： 毫秒內(nèi)的計(jì)數(shù)折汞，12位的計(jì)數(shù)順序號(hào)支持每個(gè)節(jié)點(diǎn)每毫秒（同一個(gè)機(jī)器，同一時(shí)間戳）產(chǎn)生4096個(gè)ID 序號(hào)盖腿，12個(gè)自增序列號(hào)可以表示2^12個(gè)ID,理論上snowflake方案的QPS約為409.6w/s,這種分配方式可以保證在任何一個(gè)IDC的任何一臺(tái)機(jī)器在任意毫秒內(nèi)生成的ID都是不同的爽待；
加起來剛好是64位，為一個(gè)long型；
優(yōu)點(diǎn)：
整體上按照時(shí)間自增排序堕伪，并且排序整個(gè)分布式系統(tǒng)內(nèi)不會(huì)產(chǎn)生ID碰撞（由數(shù)據(jù)中心ID和機(jī)器ID做區(qū)分）揖庄，并且效率高，輕測試欠雌，SnowFlaje每秒能產(chǎn)生26萬ID左右蹄梢。
毫秒數(shù)在高位，自增序列在低位富俄，整個(gè)ID都是趨勢遞增的
不依賴數(shù)據(jù)庫等第三方系統(tǒng)禁炒，以服務(wù)的方式部署，穩(wěn)定性更高霍比，生成ID 的性能也是非常高的
可以根據(jù)自身業(yè)務(wù)特性分配bit位幕袱，非常靈活。
缺點(diǎn)：
強(qiáng)依賴機(jī)器時(shí)鐘悠瞬，如果機(jī)器上時(shí)鐘回?fù)苊峭悖瑫?huì)導(dǎo)致發(fā)號(hào)重復(fù)或者服務(wù)處于不可用狀態(tài)
針對(duì)此，美團(tuán)做出了改進(jìn)：[https://github.com/Meituan-Dianping/Leaf](https://github.com/Meituan-Dianping/Leaf)
SnowFlake算法代碼
public class SnowflakeIdWorker {
// ==============================Fields==================
/** 開始時(shí)間截 (2019-08-06) */
private final long twepoch = 1565020800000L;
/** 機(jī)器id所占的位數(shù) */
private final long workerIdBits = 5L;
/** 數(shù)據(jù)標(biāo)識(shí)id所占的位數(shù) */
private final long datacenterIdBits = 5L;
/** 支持的最大機(jī)器id浅妆，結(jié)果是31 (這個(gè)移位算法可以很快的計(jì)算出幾位二進(jìn)制數(shù)所能表示的最大十進(jìn)制數(shù)) */
private final long maxWorkerId = -1L ^ (-1L << workerIdBits);
/** 支持的最大數(shù)據(jù)標(biāo)識(shí)id望迎，結(jié)果是31 */
private final long maxDatacenterId = -1L ^ (-1L << datacenterIdBits);
/** 序列在id中占的位數(shù) */
private final long sequenceBits = 12L;
/** 機(jī)器ID向左移12位 */
private final long workerIdShift = sequenceBits;
/** 數(shù)據(jù)標(biāo)識(shí)id向左移17位(12+5) */
private final long datacenterIdShift = sequenceBits + workerIdBits;
/** 時(shí)間截向左移22位(5+5+12) */
private final long timestampLeftShift = sequenceBits + workerIdBits + datacenterIdBits;
/** 生成序列的掩碼，這里為4095 (0b111111111111=0xfff=4095) */
private final long sequenceMask = -1L ^ (-1L << sequenceBits);
/** 工作機(jī)器ID(0~31) */
private long workerId;
/** 數(shù)據(jù)中心ID(0~31) */
private long datacenterId;
/** 毫秒內(nèi)序列(0~4095) */
private long sequence = 0L;
/** 上次生成ID的時(shí)間截 */
private long lastTimestamp = -1L;
//==============================Constructors====================
/**
* 構(gòu)造函數(shù)
* @param workerId 工作ID (0~31)
* @param datacenterId 數(shù)據(jù)中心ID (0~31)
*/
public SnowflakeIdWorker(long workerId, long datacenterId) {
if (workerId > maxWorkerId || workerId < 0) {
throw new IllegalArgumentException(String.format("worker Id can't be greater than %d or less than 0", maxWorkerId));
}
if (datacenterId > maxDatacenterId || datacenterId < 0) {
throw new IllegalArgumentException(String.format("datacenter Id can't be greater than %d or less than 0", maxDatacenterId));
}
this.workerId = workerId;
this.datacenterId = datacenterId;
}
// ==============================Methods=================================
/**
* 獲得下一個(gè)ID (該方法是線程安全的)
* @return SnowflakeId
*/
public synchronized long nextId() {
long timestamp = timeGen();
//如果當(dāng)前時(shí)間小于上一次ID生成的時(shí)間戳凌外，說明系統(tǒng)時(shí)鐘回退過這個(gè)時(shí)候應(yīng)當(dāng)拋出異常
if (timestamp < lastTimestamp) {
throw new RuntimeException(
String.format("Clock moved backwards. Refusing to generate id for %d milliseconds", lastTimestamp - timestamp));
}
//如果是同一時(shí)間生成的辩尊，則進(jìn)行毫秒內(nèi)序列
if (lastTimestamp == timestamp) {
sequence = (sequence + 1) & sequenceMask;
//毫秒內(nèi)序列溢出
if (sequence == 0) {
//阻塞到下一個(gè)毫秒,獲得新的時(shí)間戳
timestamp = tilNextMillis(lastTimestamp);
}
}
//時(shí)間戳改變，毫秒內(nèi)序列重置
else {
sequence = 0L;
}
//上次生成ID的時(shí)間截
lastTimestamp = timestamp;
//移位并通過或運(yùn)算拼到一起組成64位的ID
return ((timestamp - twepoch) << timestampLeftShift) //
| (datacenterId << datacenterIdShift) //
| (workerId << workerIdShift) //
| sequence;
}
/**
* 阻塞到下一個(gè)毫秒康辑，直到獲得新的時(shí)間戳
* @param lastTimestamp 上次生成ID的時(shí)間截
* @return 當(dāng)前時(shí)間戳
*/
protected long tilNextMillis(long lastTimestamp) {
long timestamp = timeGen();
while (timestamp <= lastTimestamp) {
timestamp = timeGen();
}
return timestamp;
}
/**
* 返回以毫秒為單位的當(dāng)前時(shí)間
* @return 當(dāng)前時(shí)間(毫秒)
*/
protected long timeGen() {
return System.currentTimeMillis();
}
//==============================Test=============================================
/** 測試 */
public static void main(String[] args) {
SnowflakeIdWorker idWorker = new SnowflakeIdWorker(0, 0);
for (int i = 0; i < 1000; i++) {
long id = idWorker.nextId();
System.out.println(Long.toBinaryString(id));
System.out.println(id);
}
}
}
snowflake實(shí)現(xiàn)方式1
apache.commons.lang3包
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.6</version>
</dependency>
工具類
package com.datalook.util.common;
import org.apache.commons.lang3.time.DateFormatUtils;
import java.util.Date;
/**
*
* @Title: 訂單號(hào)生成
* @ClassName:OrderIdUtils.java
* @Description:
*
* @Copyright 2016-2017 - Powered By 研發(fā)中心
* @author: 王延飛
* @date:2018年3月22日 下午7:43:30
* @version V1.0
*/
public class OrderIdUtils {
// 最近的時(shí)間戳
private long lastTimestamp=0;
//機(jī)器id 2位
private final String machineId;
// 0摄欲，并發(fā)控制
private long sequence = 0L;
// 序列號(hào)的最大值
private final int sequenceMax = 9999;
public OrderIdUtils(String machineId) {
this.machineId = machineId;
}
/**
* 生成訂單號(hào)
*/
public synchronized String nextId(){
Date now=new Date();
String time= DateFormatUtils.format(now,"yyMMddHHmmssSSS");
long timestamp = now.getTime();
if (this.lastTimestamp == timestamp) {
// 如果上一個(gè)timestamp與新產(chǎn)生的相等，則sequence加一(0-4095循環(huán));
// 對(duì)新的timestamp疮薇，sequence從0開始
this.sequence = this.sequence + 1 % this.sequenceMax;
if (this.sequence == 0) {
// 重新生成timestamp
timestamp = this.tilNextMillis(this.lastTimestamp);
}
} else {
this.sequence = 0;
}
this.lastTimestamp= timestamp;
StringBuilder sb=new StringBuilder(time).append(machineId).append(leftPad(sequence,4));
return sb.toString();
}
/**
* 補(bǔ)碼
* @param i
* @param n
* @return
*/
private String leftPad(long i,int n){
String s = String.valueOf(i);
StringBuilder sb=new StringBuilder();
int c=n-s.length();
c=c<0?0:c;
for (int t=0;t<c;t++){
sb.append("0");
}
return sb.append(s).toString();
}
/**
* 等待下一個(gè)毫秒的到來, 保證返回的毫秒數(shù)在參數(shù)lastTimestamp之后
*/
private long tilNextMillis(long lastTimestamp) {
long timestamp = System.currentTimeMillis();
while (timestamp <= lastTimestamp) {
timestamp = System.currentTimeMillis();
}
return timestamp;
}
// 這里讀取的是配置文件
// 機(jī)器id(我這里是01,正式環(huán)境建議使用機(jī)器IP)
// 注意：分布式環(huán)境,注意每臺(tái)機(jī)器的id要保證不同;也可以使用機(jī)器ip,映射成一個(gè)數(shù)字編號(hào)（如01:192.168.55.12）
private static String myid= SysConstant.LOCAL_MACHINE_ID;
// 示例
private static OrderIdUtils instance = new OrderIdUtils(myid);
public static OrderIdUtils getInstance() {
return instance;
}
/**
*
* @Title: 獲取訂單號(hào)
* @return String
* @Description:
*
* @author: 王延飛
* @date: 2018年3月22日 下午7:56:56
*/
public static String getOrderNumber() {
OrderIdUtils orderId = OrderIdUtils.getInstance();
String nextId = orderId.nextId();
return nextId;
}
/**
* 調(diào)用
*/
public static void main(String[] args) {
OrderIdUtils orderId= OrderIdUtils.getInstance();
String nextId = orderId.nextId();
int length = nextId.length();
System.out.println(nextId);
System.out.println(length);
}
}
snowflake實(shí)現(xiàn)方式2
引入hutool依賴
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-captcha</artifactId>
<version>5.0.6</version>
</dependency>
ID 生成器
public class IdGenerator {
private long workerId = 0;
@PostConstruct
void init() {
try {
workerId = NetUtil.ipv4ToLong(NetUtil.getLocalhostStr());
log.info("當(dāng)前機(jī)器 workerId: {}", workerId);
} catch (Exception e) {
log.warn("獲取機(jī)器 ID 失敗", e);
workerId = NetUtil.getLocalhost().hashCode();
log.info("當(dāng)前機(jī)器 workerId: {}", workerId);
}
}
/**
* 獲取一個(gè)批次號(hào)胸墙，形如 2019071015301361000101237
* <p>
* 數(shù)據(jù)庫使用 char(25) 存儲(chǔ)
*
* @param tenantId 租戶ID，5 位
* @param module 業(yè)務(wù)模塊ID按咒，2 位
* @return 返回批次號(hào)
*/
public synchronized String batchId(int tenantId, int module) {
String prefix = DateTime.now().toString(DatePattern.PURE_DATETIME_MS_PATTERN);
return prefix + tenantId + module + RandomUtil.randomNumbers(3);
}
@Deprecated
public synchronized String getBatchId(int tenantId, int module) {
return batchId(tenantId, module);
}
/**
* 生成的是不帶-的字符串迟隅，類似于：b17f24ff026d40949c85a24f4f375d42
*
* @return
*/
public String simpleUUID() {
return IdUtil.simpleUUID();
}
/**
* 生成的UUID是帶-的字符串，類似于：a5c8a5e8-df2b-4706-bea4-08d0939410e3
*
* @return
*/
public String randomUUID() {
return IdUtil.randomUUID();
}
private Snowflake snowflake = IdUtil.createSnowflake(workerId, 1);
public synchronized long snowflakeId() {
return snowflake.nextId();
}
public synchronized long snowflakeId(long workerId, long dataCenterId) {
Snowflake snowflake = IdUtil.createSnowflake(workerId, dataCenterId);
return snowflake.nextId();
}
/**
* 生成類似：5b9e306a4df4f8c54a39fb0c
* <p>
* ObjectId 是 MongoDB 數(shù)據(jù)庫的一種唯一 ID 生成策略胖齐，
* 是 UUID version1 的變種，詳細(xì)介紹可見：服務(wù)化框架－分布式 Unique ID 的生成方法一覽嗽冒。
*
* @return
*/
public String objectId() {
return ObjectId.next();
}
}
public static void main(String[] args) {
for (int i = 0; i <1000 ; i++) {
OrderIdUtils orderIdUtils=OrderIdUtils.getInstance();
String nextId=orderIdUtils.nextId();
int length=nextId.length();
System.out.println(nextId);
System.out.println(length);
}
}
}
