根據訂單號碼上鎖 java根據時間產生訂單編號

genie

1. package skdapp.cn.stream.common.generator;
   
2. 
   
3. import java.time.Instant;
   
4. import java.util.HashSet;
   
5. import java.util.Objects;
   
6. import java.util.Set;
   
7. import java.util.UUID;
   
8. import java.util.concurrent.Callable;
   
9. import java.util.concurrent.ExecutionException;
   
10. import java.util.concurrent.FutureTask;
    
11. import java.util.concurrent.ThreadLocalRandom;
    
12. import java.util.concurrent.atomic.AtomicInteger;
    
13. 
    
14. import org.apache.commons.lang3.time.FastDateFormat;
    
15. import org.springframework.util.StopWatch;
    
16. 
    
17. /**
    
18.   * 訂單編號策略
    
19.   *
    
20.   * @project common-utils
    
21.   * @fileName ODDGenerator.java
    
22.   * @Description
    
23.   * @author
    
24.   * @date 2023年12月08日
    
25.   * @version 1.0.0
    
26.   */
    
27. public abstract class ODDGenerator {
    
28.      private static final FastDateFormat pattern = FastDateFormat.getInstance("yyyyMMddHHmmss");
    
29.      private static final AtomicInteger atomicInteger = new AtomicInteger(1);
    
30.      private static ThreadLocal<StringBuilder> threadLocal = new ThreadLocal<StringBuilder>();
    
31. 
    
32.      /**
    
33.       * 長碼產生策略
    
34.       * 20201116114351753590384993
    
35.       * @param lock uuid
    
36.       * @return
    
37.       */
    
38.      public static String getC(String lock) {
    
39.          if (Objects.isNull(threadLocal.get())) {
    
40.              lock = Objects.isNull(lock) ? UUID.randomUUID().toString() : lock;
    
41.              StringBuilder builder = new StringBuilder(pattern.format(Instant.now().toEpochMilli()));// 取系統目前時間作為訂單編號前半部分
    
42.              builder.append(Math.abs(lock.hashCode()));// HASH-CODE
    
43.              builder.append(atomicInteger.getAndIncrement());// 自增順序
    
44.              threadLocal.set(builder);
    
45.          }
    
46.          return threadLocal.get().toString();
    
47.      }
    
48. 
    
49.      /**
    
50.       * 短碼產生策略
    
51.       * 1307891882965
    
52.       * @param lock
    
53.       * @return
    
54.       */
    
55.      public static String getD(String lock) {
    
56.          if (Objects.isNull(threadLocal.get())) {
    
57.              lock = Objects.isNull(lock) ? UUID.randomUUID().toString() : lock;
    
58.              StringBuilder builder = new StringBuilder(ThreadLocalRandom.current().nextInt(0, 999)); // 隨機數
    
59.              builder.append(Math.abs(lock.hashCode()));// HASH-CODE
    
60.              builder.append(atomicInteger.getAndIncrement());// 自增順序
    
61.              threadLocal.set(builder);
    
62.          }
    
63.          return threadLocal.get().toString();
    
64.      }
    
65. 
    
66.      /**
    
67.       * 1000個線程並發測試
    
68.       *
    
69.       * @param args
    
70.       * @throws InterruptedException
    
71.       * @throws ExecutionException
    
72.       */
    
73.      public static void main(String[] args) throws InterruptedException, ExecutionException {
    
74.          Set<String> set = new HashSet<String>();
    
75.          FutureTask<String> task = null;
    
76.          StopWatch watchTime = new StopWatch();
    
77.          watchTime.start();
    
78.          for (int i = 0; i < 1000; i++) {
    
79.              Callable<String> callable = new Callable<String>() {
    
80.                  @Override
    
81.                  public String call() throws Exception {
    
82.                      // System.out.println("目前執行緒:>>>>> ".concat(Thread.currentThread().getId()+""));
    
83.                      //return getC(null);
    
84.                      return getD(null);
    
85.                  }
    
86.              };
    
87.              task = new FutureTask<String>(callable);
    
88.              new Thread(task).start();
    
89.              set.add(task.get());
    
90.              System.out.println(task.get());
    
91.          }
    
92.          watchTime.stop();
    
93.          System.out.println(watchTime.getTotalTimeMillis());
    
94.          System.out.println(set.size());
    
95.      }
    
96. }

複製代碼