快捷導(dǎo)航

springboot多節(jié)點(diǎn)應(yīng)用里的雪花算法唯一性詳解

更新時(shí)間：2024年12月31日 09:12:42 作者：張占嶺

雪花算法在單節(jié)點(diǎn)下唯一,但在多副本Kubernetes環(huán)境中可能重復(fù),通過修改Pod名稱生成workId,解決了這個(gè)問題,同時(shí)避免了第三方組件和網(wǎng)絡(luò)請求,本文給大家介紹springboot多節(jié)點(diǎn)應(yīng)用里的雪花算法唯一性,感興趣的朋友一起看看吧

雪花算法的唯一性，在單個(gè)節(jié)點(diǎn)中是可以保證的，對應(yīng)kubernetes中的應(yīng)用，如果是橫向擴(kuò)展后，進(jìn)行多副本的情況下，可能出現(xiàn)重復(fù)的ID，這需要我們按著pod_name進(jìn)行一個(gè)workId的生成，我還是建議通過不引入第三方組件和網(wǎng)絡(luò)請求的前提下解決這個(gè)問題，所以我修改了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  # 獲取當(dāng)前 Pod 的名稱

字符串(0~1024)數(shù)字方法，通過掩碼的方式

public static int stringToNumber(String input) {
        // 使用CRC32計(jì)算字符串的哈希值
        CRC32 crc = new CRC32();
        byte[] bytes = input.getBytes(StandardCharsets.UTF_8);
        crc.update(bytes);
        // 獲取哈希值并限制在0到1023之間
        long hashValue = crc.getValue();
        return (int) (hashValue % 1024);
    }

獲取服務(wù)器機(jī)器碼

/**
	 * 獲取機(jī)器碼.
	 * @return
	 */
	public static String getUniqueMachineId() {
		StringBuilder uniqueId = new StringBuilder();
		try {
			// 獲取本機(jī)的IP地址
			InetAddress localHost = InetAddress.getLocalHost();
			uniqueId.append(localHost.getHostAddress()).append("_");
			// 獲取網(wǎng)絡(luò)接口并獲取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("_");
				}
			}
			// 添加系統(tǒng)信息作為補(bǔ)充
			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生成器的改進(jìn)

@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();
	}

到此這篇關(guān)于springboot~多節(jié)點(diǎn)應(yīng)用里的雪花算法唯一性的文章就介紹到這了,更多相關(guān)springboot雪花算法唯一性內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: