订单ID设计 | 伈情的博客
订单ID生成规则设计
<订单ID生成工具类>
<订单ID生成算法：包含属性与每个属性固定的二进制位数为：unix时间戳占用39bit+订单版本号2bit+分库5bit+分表5bit+机器号6bit+自增序号6bit=63bit>
unix时间戳区间如下：
{
100000000000000000000000000000000000000
274877906944
111111111111111111111111111111111111111
549755813887
}
历史时间与系统最大支撑时间计算公式：
历史时间=系统上线时间-274877906944
最大支撑时间=系统上线时间+549755813887
时间戳为满足订单号为long型，二进制位为定长39bit，且生成订单号长度固定为19位，因此经过计算得出时间区间为：历史时间：1191474093056>
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 | /** * <订单ID生成工具类> * <订单ID生成算法：包含属性与每个属性固定的二进制位数为：unix时间戳占用39bit+订单版本号2bit+分库5bit+分表5bit+机器号6bit+自增序号6bit=63bit> * * <unix时间戳为满足订单号为long型，二进制位为定长39bit，且生成订单号长度固定为19位，因此经过计算得出时间区间为：历史时间：1191474093056 → 2007-10-4 13:01:33，系统上线时间：1466352000000 → 2016-6-20 00:00:00，最大支撑时间：2016107813887 → 2033-11-20 21:56:53，可支撑时间为：2033年-2016年=17年> * unix时间戳区间如下： { 100000000000000000000000000000000000000 274877906944 111111111111111111111111111111111111111 549755813887 } 历史时间与系统最大支撑时间计算公式： 历史时间=系统上线时间-274877906944 最大支撑时间=系统上线时间+549755813887 * * * @author yunhaibin * @version [版本号, 2016-6-15] * @see [相关类/方法] * @since [产品/模块版本] */ public class IdGenerate { /** * twepoch 历史时间 */ private final static long twepoch = 1191474093056L; private final long workerId; private long idVersion = 0L; private long database = 0L; private long dbTable = 0L; private long sequence = 0L; private final static long idVersionBits = 2L; private final static long databaseBits = 5L; private final static long dbTableBits = 5L; private final static long workerIdBits = 6L; private final static long sequenceBits = 6L; private final static long workerIdShift = sequenceBits; private final static long dbTableShift = workerIdShift + sequenceBits; private final static long databaseShift = dbTableShift + dbTableBits; private final static long idVersionShift = databaseShift + databaseBits; private final static long timestampLeftShift = idVersionShift + idVersionBits; public final static long maxIdVersion = -1L ^ -1L << idVersionBits; public final static long maxDatabase = -1L ^ -1L << databaseBits; public final static long maxDbTable = -1L ^ -1L << dbTableBits; public final static long maxWorkerId = -1L ^ -1L << workerIdBits; public final static long sequenceMask = -1L ^ -1L << sequenceBits; private long lastTimestamp = -1L; /** * <默认构造函数> */ public IdGenerate(final long workerId) { // 获取当前机器IP最后的尾数 // this.workerId = GetMachineID.MACHINEID % 64; this.workerId = workerId; if (workerId > maxWorkerId || workerId < 0) { throw new IllegalArgumentException(String.format("worker Id can't be greater than %d or less than 0", maxWorkerId)); } } /** * <默认构造函数> * @param workerId 机器标识 * @param database 分库信息 * @param dbTable 分表信息 * @param idVersion 订单版本号 * */ public IdGenerate(final long workerId, long database, final long dbTable, final long idVersion) { // 获取当前机器IP最后的尾数 // this.workerId = GetMachineID.MACHINEID % 64; this.workerId = workerId; this.database = database; this.dbTable = dbTable; this.idVersion = idVersion; if (workerId > maxWorkerId || workerId < 0) { throw new IllegalArgumentException(String.format("worker Id can't be greater than %d or less than 0", maxWorkerId)); } if (database > maxDatabase || database < 0) { throw new IllegalArgumentException(String.format("database can't be greater than %d or less than 0", maxDatabase)); } if (dbTable > maxDbTable || dbTable < 0) { throw new IllegalArgumentException(String.format("dbTable can't be greater than %d or less than 0", maxDbTable)); } if (idVersion > maxIdVersion || idVersion < 0) { throw new IllegalArgumentException(String.format("idVersion can't be greater than %d or less than 0", maxIdVersion)); } } /** * <生成唯一ID> * <功能详细描述> * @return * @see [类、类#方法、类#成员] */ public synchronized long nextId() { long timestamp = this.timeGen(); if (this.lastTimestamp == timestamp) { this.sequence = (this.sequence + 1) & sequenceMask; if (this.sequence == 0) { System.out.println("###########" + sequenceMask); timestamp = this.tilNextMillis(this.lastTimestamp); } } else { this.sequence = 0; } if (timestamp < this.lastTimestamp) { try { throw new Exception(String.format("Clock moved backwards. Refusing to generate id for %d milliseconds", this.lastTimestamp - timestamp)); } catch (Exception e) { e.printStackTrace(); } } this.lastTimestamp = timestamp; long nextId = ((timestamp - twepoch << timestampLeftShift)) // long nextId = ((1466352000000L - twepoch << timestampLeftShift)) | (this.idVersion << idVersionShift) | (this.database << databaseShift) | (this.dbTable << dbTableShift) | (this.workerId << workerIdShift) | (this.sequence); // System.out.println("timestamp:" + timestamp + ",timestampLeftShift:" // + timestampLeftShift + ",nextId:" + nextId + ",workerId:" // + workerId + ",sequence:" + sequence); return nextId; } /** * <根据生成的唯一ID获取此ID生成的时间> * <功能详细描述> * @param id 唯一ID * @return unix时间戳 * @see [类、类#方法、类#成员] */ public long getIdTime(long id) { return (id >> timestampLeftShift) + twepoch; } /** * <根据生成的唯一ID获取此ID的版本号> * <功能详细描述> * @param id 唯一ID * @return 订单版本号 * @see [类、类#方法、类#成员] */ public long getIdVersion(long id) { return ((id >> timestampLeftShift << timestampLeftShift) ^ id) >> idVersionShift; } /** * <根据生成的唯一ID获取此ID的分库信息> * <功能详细描述> * @param id 唯一ID * @return 分库信息 * @see [类、类#方法、类#成员] */ public long getIdDatabase(long id) { return ((id >> idVersionShift << idVersionShift) ^ id) >> databaseShift; } /** * <根据生成的唯一ID获取此ID的分表信息> * <功能详细描述> * @param id 唯一ID * @return 分表信息 * @see [类、类#方法、类#成员] */ public long getIdDbTable(long id) { return ((id >> databaseShift << databaseShift) ^ id) >> dbTableShift; } /** * <根据生成的唯一ID获取此ID生成的机器号> * <功能详细描述> * @param id 唯一ID * @return 机器号 * @see [类、类#方法、类#成员] */ public long getIdWorkerId(long id) { return ((id >> dbTableShift << dbTableShift) ^ id) >> workerIdBits; } /** * <根据生成的唯一ID获取此ID生成的自增序号> * <功能详细描述> * @param id 唯一ID * @return 自增序号 * @see [类、类#方法、类#成员] */ public long getIdSequence(long id) { return ((id >> sequenceBits << sequenceBits) ^ id); } private long tilNextMillis(final long lastTimestamp) { long timestamp = this.timeGen(); while (timestamp <= lastTimestamp) { timestamp = this.timeGen(); } return timestamp; } /** * <获取订单ID对应的所有属性信息> * <功能详细描述> * @param id * @return OrderIdInfo * @see [类、类#方法、类#成员] */ public OrderIdInfo getOrderIdInfo(long id) { OrderIdInfo orderIdInfo = new OrderIdInfo(); orderIdInfo.setId(id); orderIdInfo.setTime(this.getIdTime(id)); orderIdInfo.setIdVersion(this.getIdVersion(id)); orderIdInfo.setDatabase(this.getIdDatabase(id)); orderIdInfo.setDbTable(this.getIdDbTable(id)); orderIdInfo.setWorkerId(this.getIdWorkerId(id)); orderIdInfo.setSequence(this.getIdSequence(id)); return orderIdInfo; } private long timeGen() { return System.currentTimeMillis(); } public static void main(String[] args) { IdGenerate worker = new IdGenerate(55, 28, 11, 0); long id = worker.nextId(); OrderIdInfo orderIdInfo = new OrderIdInfo(); orderIdInfo = worker.getOrderIdInfo(id); System.out.println(orderIdInfo.getId()); System.out.println(orderIdInfo.getTime()); System.out.println(DateUtil.dateFormat(new Date(orderIdInfo.getTime()), "yyyy-MM-dd HH:mm:ss")); System.out.println(orderIdInfo.getIdVersion()); System.out.println(orderIdInfo.getDatabase()); System.out.println(orderIdInfo.getDbTable()); System.out.println(orderIdInfo.getWorkerId()); System.out.println(orderIdInfo.getSequence()); // System.out.println("ID:" + id); // System.out.println("ID full binary:" + Long.toBinaryString(id)); // System.out.println("Unix time:" + worker.getIdTime(id)); // System.out.println("Date time:" + DateUtil.dateFormat(new Date(worker.getIdTime(id)), "yyyy-MM-dd HH:mm:ss")); // System.out.println("IdVe |
