【Flowable实战】Flowable6.4.1自定义id生成

zhangdaiscott

1. 雪花Id生成器

1. /**
   
2. * 雪花算法生成id
   
3. * @author
   
4. *
   
5. */
   
6. public class Snowflake {
   
7. 
   
8.     private final static long TWEPOCH = 1288834974657L;
   
9. 
   
10.     // 机器标识位数
    
11.     private final static long WORKER_ID_BITS = 5L;
    
12. 
    
13.     // 数据中心标识位数
    
14.     private final static long DATA_CENTER_ID_BITS = 5L;
    
15. 
    
16.     // 机器ID最大值 31
    
17.     private final static long MAX_WORKER_ID = -1L ^ (-1L << WORKER_ID_BITS);
    
18. 
    
19.     // 数据中心ID最大值 31
    
20.     private final static long MAX_DATA_CENTER_ID = -1L ^ (-1L << DATA_CENTER_ID_BITS);
    
21. 
    
22.     // 毫秒内自增位
    
23.     private final static long SEQUENCE_BITS = 12L;
    
24. 
    
25.     // 机器ID偏左移12位
    
26.     private final static long WORKER_ID_SHIFT = SEQUENCE_BITS;
    
27. 
    
28.     private final static long DATA_CENTER_ID_SHIFT = SEQUENCE_BITS + WORKER_ID_BITS;
    
29. 
    
30.     // 时间毫秒左移22位
    
31.     private final static long TIMESTAMP_LEFT_SHIFT = SEQUENCE_BITS + WORKER_ID_BITS + DATA_CENTER_ID_BITS;
    
32. 
    
33.     private final static long SEQUENCE_MASK = -1L ^ (-1L << SEQUENCE_BITS);
    
34. 
    
35.     private long lastTimestamp = -1L;
    
36. 
    
37.     private long sequence = 0L;
    
38.     private final long workerId;
    
39.     private final long dataCenterId;
    
40.     private static volatile Snowflake snowflake = null;
    
41.     private static Object lock = new Object();
    
42. 
    
43.     //单例禁止new实例化
    
44.     private Snowflake(long workerId, long dataCenterId) {
    
45.         if (workerId > MAX_WORKER_ID || workerId < 0) {
    
46.             workerId = getRandom();
    
47.         }
    
48. 
    
49.         if (dataCenterId > MAX_DATA_CENTER_ID || dataCenterId < 0) {
    
50. 
    
51.             throw new IllegalArgumentException(String.format("%s 数据中心ID最大值 必须是 %d 到 %d 之间", dataCenterId, 0, MAX_DATA_CENTER_ID));
    
52.         }
    
53.         this.workerId = workerId;
    
54.         this.dataCenterId = dataCenterId;
    
55.     }
    
56. 
    
57.     /**
    
58.      * 获取单列
    
59.      *
    
60.      * @return
    
61.      */
    
62.     public static Snowflake getInstanceSnowflake() {
    
63.         if (snowflake == null) {
    
64.             synchronized (lock) {
    
65.                 long workerId ;
    
66.                 long dataCenterId = getRandom();
    
67.                 try {
    
68.                     //第一次使用获取mac地址的
    
69.                     workerId = getWorkerId();
    
70.                 } catch (Exception e) {
    
71.                     workerId = getRandom();
    
72.                 }
    
73.                 snowflake = new Snowflake(workerId, dataCenterId);
    
74.             }
    
75.         }
    
76.         return snowflake;
    
77.     }
    
78. 
    
79.     /**
    
80.      * 生成1-31之间的随机数
    
81.      *
    
82.      * @return
    
83.      */
    
84.     private static long getRandom() {
    
85.         int max = (int) (MAX_WORKER_ID);
    
86.         int min = 1;
    
87.         Random random = new Random();
    
88.         long result = random.nextInt(max - min) + min;
    
89.         return result;
    
90.     }
    
91. 
    
92.     public static String getSnowflakeId() throws Exception{
    
93.         return Snowflake.getInstanceSnowflake().nextId()+"";
    
94.     }
    
95. 
    
96.     private synchronized long nextId() throws Exception {
    
97.         long timestamp = time();
    
98.         if (timestamp < lastTimestamp) {
    
99.             throw new Exception("时钟向后移动，拒绝生成id  " + (lastTimestamp - timestamp) + " milliseconds");
    
100.         }
     
101. 
     
102.         if (lastTimestamp == timestamp) {
     
103.             // 当前毫秒内，则+1
     
104.             sequence = (sequence + 1) & SEQUENCE_MASK;
     
105.             if (sequence == 0) {
     
106.                 // 当前毫秒内计数满了，则等待下一秒
     
107.                 timestamp = tilNextMillis(lastTimestamp);
     
108.             }
     
109.         } else {
     
110.             sequence = 0;
     
111.         }
     
112.         lastTimestamp = timestamp;
     
113. 
     
114.         // ID偏移组合生成最终的ID，并返回ID
     
115.         long nextId = ((timestamp - TWEPOCH) << TIMESTAMP_LEFT_SHIFT)
     
116.                 | (dataCenterId << DATA_CENTER_ID_SHIFT) | (workerId << WORKER_ID_SHIFT) | sequence;
     
117. 
     
118.         return nextId;
     
119.     }
     
120. 
     
121.     private long tilNextMillis(final long lastTimestamp) {
     
122.         long timestamp = this.time();
     
123.         while (timestamp <= lastTimestamp) {
     
124.             timestamp = this.time();
     
125.         }
     
126.         return timestamp;
     
127.     }
     
128. 
     
129.     private long time() {
     
130.         return System.currentTimeMillis();
     
131.     }
     
132. 
     
133.     @SuppressWarnings("Duplicates")
     
134.     private static long getWorkerId() throws SocketException, UnknownHostException, NullPointerException {
     
135.         @SuppressWarnings("unused")
     
136.         InetAddress ip = InetAddress.getLocalHost();
     
137. 
     
138.         NetworkInterface network = null;
     
139.         Enumeration<NetworkInterface> en = NetworkInterface.getNetworkInterfaces();
     
140.         while (en.hasMoreElements()) {
     
141.             NetworkInterface nint = en.nextElement();
     
142.             if (!nint.isLoopback() && nint.getHardwareAddress() != null) {
     
143.                 network = nint;
     
144.                 break;
     
145.             }
     
146.         }
     
147. 
     
148.         @SuppressWarnings("ConstantConditions")
     
149.         byte[] mac = network.getHardwareAddress();
     
150. 
     
151.         Random rnd = new Random();
     
152.         byte rndByte = (byte) (rnd.nextInt() & 0x000000FF);
     
153. 
     
154.         // 取mac地址最后一位和随机数
     
155.         return ((0x000000FF & (long) mac[mac.length - 1]) | (0x0000FF00 & (((long) rndByte) << 8))) >> 6;
     
156.     }
     
157. 
     
158. 
     
159.     public static void main(String[] args) {
     
160.         long start = System.currentTimeMillis();
     
161.         try {
     
162.             for (int i = 0, len = 1000000; i < len; i++) {
     
163.                 //getSnowflakeId();
     
164.                 System.out.println(getSnowflakeId());
     
165.             }
     
166.         } catch (Exception e) {
     
167. 
     
168.         }
     
169.         System.out.println("100万耗时: " + (System.currentTimeMillis()-start) + "ms");
     
170. 
     
171.     }
     
172. }

复制代码

2. 实现接口重写方法

1. @Configuration
   
2. public class FlowableConfiguration implements EngineConfigurationConfigurer<SpringProcessEngineConfiguration>
   
3. {
   
4.     @Override
   
5.     public void configure(SpringProcessEngineConfiguration springProcessEngineConfiguration) {
   
6.         springProcessEngineConfiguration.setIdGenerator(new IdGenerator() {
   
7.             @Override
   
8.             public String getNextId() {
   
9.                 try {
   
10.                     return Snowflake.getSnowflakeId(); //id生成方法
    
11.                 }catch (Exception e) {
    
12.                 }
    
13.                 return null;
    
14.             }
    
15.         });
    
16.     }
    
17. }

复制代码

3. 完成