雪花算法工具类
代码如下:

package org.jeecg.common.util;

import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.net.NetUtil;
import cn.hutool.core.util.IdUtil;
import org.apache.commons.lang3.StringUtils;

/**
 * @Description:雪花算法生成分布式id,需要引入hutooljar包
 * @Author: jeecg-boot
 * @Date: 2025-09-03
 * @Version: V1.0
 */
public class SnowflakeUtil {
    // 终端ID
    private static final Long WORKER_ID = resolveWorkerId();
    // 数据中心ID
    private static final Long DATA_CENTER_ID = resolveDataCenterId();
    // 单例 Snowflake 实例(线程安全)
    private static final Snowflake SNOWFLAKE = new Snowflake(WORKER_ID, DATA_CENTER_ID, true);

    /**
     * 获取雪花ID
     */
    public static synchronized String getSnowflake() {
        return SNOWFLAKE.nextIdStr();
        //return IdUtil.getSnowflake(WORKER_ID,DATA_CENTER_ID).nextIdStr();
    }

    /**
     * 根据 Pod Name(HOSTNAME) 生成 WorkerId(保证同 Node 下 Pod 不同)
     */
    private static Long resolveWorkerId() {
        Long id=null;
        try {
            // 使用 IP 地址计算
            String ip = NetUtil.getLocalhostStr();
            return Long.parseLong(ip.split("\\.")[3]) & 0x1F;
        } catch (Exception e) {
            id=0L;
        }
        return id;
    }

    /**
     * 根据 Node IP 生成 DataCenterId(保证同一物理机一样)
     */
    private static Long resolveDataCenterId() {
        Long id=null;
        try {
            // 使用 IP 地址计算
            String ip = NetUtil.getLocalhostStr();
            id= (long) (ip.hashCode() & 0x1F);
        } catch (Exception e) {
            id=0L;
        }
        return id;
    }

    //测试
    public static void main(String[] args) {
        String uuid = getSnowflake();
        System.out.println(uuid);
    }

}
Logo

DAMO开发者矩阵,由阿里巴巴达摩院和中国互联网协会联合发起,致力于探讨最前沿的技术趋势与应用成果,搭建高质量的交流与分享平台,推动技术创新与产业应用链接,围绕“人工智能与新型计算”构建开放共享的开发者生态。

更多推荐