springboot多节点应用里的雪花算法唯一性详解
作者:张占岭
雪花算法在单节点下唯一,但在多副本Kubernetes环境中可能重复,通过修改Pod名称生成workId,解决了这个问题,同时避免了第三方组件和网络请求,本文给大家介绍springboot多节点应用里的雪花算法唯一性,感兴趣的朋友一起看看吧
雪花算法的唯一性,在单个节点中是可以保证的,对应kubernetes中的应用,如果是横向扩展后,进行多副本的情况下,可能出现重复的ID,这需要我们按着pod_name进行一个workId的生成,我还是建议通过不引入第三方组件
和网络请求的前提下解决这个问题,所以我修改了kubernetes的yaml文件。
- k8s的yaml配置
apiVersion: apps/v1 kind: Deployment metadata: name: my-app spec: replicas: 3 selector: matchLabels: app: my-app template: metadata: labels: app: my-app spec: containers: - name: my-container image: my-image:latest env: - name: POD_NAME valueFrom: fieldRef: fieldPath: metadata.name # 获取当前 Pod 的名称
- 字符串(0~1024)数字方法,通过掩码的方式
public static int stringToNumber(String input) { // 使用CRC32计算字符串的哈希值 CRC32 crc = new CRC32(); byte[] bytes = input.getBytes(StandardCharsets.UTF_8); crc.update(bytes); // 获取哈希值并限制在0到1023之间 long hashValue = crc.getValue(); return (int) (hashValue % 1024); }
- 获取服务器机器码
/** * 获取机器码. * @return */ public static String getUniqueMachineId() { StringBuilder uniqueId = new StringBuilder(); try { // 获取本机的IP地址 InetAddress localHost = InetAddress.getLocalHost(); uniqueId.append(localHost.getHostAddress()).append("_"); // 获取网络接口并获取MAC地址 Enumeration<NetworkInterface> networkInterfaces = NetworkInterface.getNetworkInterfaces(); while (networkInterfaces.hasMoreElements()) { NetworkInterface networkInterface = networkInterfaces.nextElement(); byte[] mac = networkInterface.getHardwareAddress(); if (mac != null) { for (int i = 0; i < mac.length; i++) { uniqueId.append(String.format("%02X", mac[i])); if (i < mac.length - 1) { uniqueId.append("-"); } } uniqueId.append("_"); } } // 添加系统信息作为补充 String osName = System.getProperty("os.name"); String osVersion = System.getProperty("os.version"); String userName = System.getProperty("user.name"); uniqueId.append(osName).append("_").append(osVersion).append("_").append(userName); } catch (Exception e) { e.printStackTrace(); } return uniqueId.toString(); }
- ID生成器的改进
@Slf4j public class IdUtils { static SnowFlakeGenerator snowFlakeGenerator; public static String generateId() { if (snowFlakeGenerator == null) { long podNameCode = stringToNumber(Optional.ofNullable(System.getenv("POD_NAME")).orElse(stringToNumber(getUniqueMachineId()))); log.debug("podNameCode:{}", podNameCode); snowFlakeGenerator = new SnowFlakeGenerator(podNameCode); } return snowFlakeGenerator.hexNextId(); }
到此这篇关于springboot~多节点应用里的雪花算法唯一性的文章就介绍到这了,更多相关springboot雪花算法唯一性内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!