springboot~多节点应用里的雪花算法唯一性

雪花算法的唯一性，在单个节点中是可以保证的，对应kubernetes中的应用，如果是横向扩展后，进行多副本的情况下，大概出现重复的ID，这需要我们按着pod_name进行一个workId的生成，我照旧发起通过不引入第三方组件和网络哀求的条件下解决这个标题，以是我修改了kubernetes的yaml文件。

• k8s的yaml设置
  

1. apiVersion: apps/v1
2. kind: Deployment
3. metadata:
4.   name: my-app
5. spec:
6.   replicas: 3
7.   selector:
8.     matchLabels:
9.       app: my-app
10.   template:
11.     metadata:
12.       labels:
13.         app: my-app
14.     spec:
15.       containers:
16.       - name: my-container
17.         image: my-image:latest
18.         env:
19.         - name: POD_NAME
20.           valueFrom:
21.             fieldRef:
22.               fieldPath: metadata.name  # 获取当前 Pod 的名称

复制代码

• 字符串(0~1024)数字方法，通过掩码的方式
  

1. public static int stringToNumber(String input) {
2.         // 使用CRC32计算字符串的哈希值
3.         CRC32 crc = new CRC32();
4.         byte[] bytes = input.getBytes(StandardCharsets.UTF_8);
5.         crc.update(bytes);
6.         
7.         // 获取哈希值并限制在0到1023之间
8.         long hashValue = crc.getValue();
9.         return (int) (hashValue % 1024);
10.     }

复制代码

• 获取服务器机器码
  

1. /**
2.          * 获取机器码.
3.          * @return
4.          */
5.         public static String getUniqueMachineId() {
6.                 StringBuilder uniqueId = new StringBuilder();
8.                 try {
9.                         // 获取本机的IP地址
10.                         InetAddress localHost = InetAddress.getLocalHost();
11.                         uniqueId.append(localHost.getHostAddress()).append("_");
13.                         // 获取网络接口并获取MAC地址
14.                         Enumeration<NetworkInterface> networkInterfaces = NetworkInterface.getNetworkInterfaces();
15.                         while (networkInterfaces.hasMoreElements()) {
16.                                 NetworkInterface networkInterface = networkInterfaces.nextElement();
17.                                 byte[] mac = networkInterface.getHardwareAddress();
18.                                 if (mac != null) {
19.                                         for (int i = 0; i < mac.length; i++) {
20.                                                 uniqueId.append(String.format("%02X", mac[i]));
21.                                                 if (i < mac.length - 1) {
22.                                                         uniqueId.append("-");
23.                                                 }
24.                                         }
25.                                         uniqueId.append("_");
26.                                 }
27.                         }
29.                         // 添加系统信息作为补充
30.                         String osName = System.getProperty("os.name");
31.                         String osVersion = System.getProperty("os.version");
32.                         String userName = System.getProperty("user.name");
33.                         uniqueId.append(osName).append("_").append(osVersion).append("_").append(userName);
35.                 }
36.                 catch (Exception e) {
37.                         e.printStackTrace();
38.                 }
40.                 return uniqueId.toString();
41.         }

复制代码

• ID生成器的改进
  

1. @Slf4j
2. public class IdUtils {
4.         static SnowFlakeGenerator snowFlakeGenerator;
6.         public static String generateId() {
7.                 if (snowFlakeGenerator == null) {
8.                         long podNameCode = stringToNumber(Optional.ofNullable(System.getenv("POD_NAME")).orElse(stringToNumber(getUniqueMachineId())));
9.                         log.debug("podNameCode:{}", podNameCode);
10.                         snowFlakeGenerator = new SnowFlakeGenerator(podNameCode);
12.                 }
13.                 return snowFlakeGenerator.hexNextId();
14.         }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。