MybatisPlus使用idworker解决雪花算法重复

<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
    <version>3.4.0</version>
</dependency>

<dependency>
    <groupId>com.imadcn.framework</groupId>
    <artifactId>idworker</artifactId>
    <version>1.5.0</version>
</dependency>

@Configurationd
public class IdAutoConfig {
    @Value("${mybatis-plus.zookeeper.serverLists:127.0.0.1:2181}")
    private String zkServerLists;

    @Bean
    public IdentifierGenerator idGenerator() {
        return new ImadcnIdentifierGenerator(zkServerLists);
    }
}

@Configuration
@MapperScan(
        basePackages = "com.script.idworker.mapper",
        sqlSessionFactoryRef = "sqlSessionFactory")
public class DataSourceConfig {
    @Value("${mybatis-plus.zookeeper.serverLists}")
    private String zkServerLists;

    @Bean(name = "dataSource")
    @Primary
    @ConfigurationProperties(prefix = "spring.datasource.druid")
    public DataSource getDataSource() {
        return DruidDataSourceBuilder.create().build();
    }

    @Bean(name = "sqlSessionFactory")
    @Primary
    public SqlSessionFactory sqlSessionFactory(@Qualifier("dataSource") DataSource datasource) throws Exception {
        MybatisSqlSessionFactoryBean sqlSessionFactory = new MybatisSqlSessionFactoryBean();
        sqlSessionFactory.setDataSource(datasource);
        MybatisConfiguration configuration = new MybatisConfiguration();
        // 驼峰转下划线
        configuration.setMapUnderscoreToCamelCase(true);
        sqlSessionFactory.setConfiguration(configuration);
        
        // 设置使用Mybatis的Snowflake算法生成id
        GlobalConfig globalConfig = new GlobalConfig();
        globalConfig.setIdentifierGenerator(new ImadcnIdentifierGenerator(zkServerLists));
        sqlSessionFactory.setGlobalConfig(globalConfig);
        
        return sqlSessionFactory.getObject();
    }
}

public synchronized long nextId() {
    long timestamp = timeGen();
    // 如果上一个timestamp与新产生的相等，则sequence加一(0-4095循环);
    if (lastTimestamp == timestamp) {
        // 对新的timestamp，sequence从0开始
        sequence = sequence + 1 & sequenceMask;
        // 毫秒内序列溢出
        if (sequence == 0) {
            // 阻塞到下一个毫秒,获得新的时间戳
            sequence = RANDOM.nextInt(100);
            timestamp = tilNextMillis(lastTimestamp);
        }
    } else {
        // 时间戳改变，毫秒内序列重置
        sequence = RANDOM.nextInt(100);
    }
    // 如果当前时间小于上一次ID生成的时间戳，说明系统时钟回退过这个时候应当抛出异常
    if (timestamp < lastTimestamp) {
        String message = String.format("Clock moved backwards. Refusing to generate id for %d milliseconds.",
                (lastTimestamp - timestamp));
        logger.error(message);
        throw new RuntimeException(message);
    }
    lastTimestamp = timestamp;
    // 移位并通过或运算拼到一起组成64位的ID
    // 1 + 41 + 10 + 22
    // 0 - 0000000000 0000000000 0000000000 0000000000 0 - 0000000000 - 000000000000
    return timestamp - epoch << timestampLeftShift | workerId << workerIdShift | sequence;
}

public long register() {
    InterProcessMutex lock = null;
    try {
        CuratorFramework client = (CuratorFramework) regCenter.getRawClient();
        lock = new InterProcessMutex(client, nodePath.getGroupPath());
        int numOfChildren = regCenter.getNumChildren(nodePath.getWorkerPath());
        if (numOfChildren < MAX_WORKER_NUM) {
            if (!lock.acquire(MAX_LOCK_WAIT_TIME_MS, TimeUnit.MILLISECONDS)) {
                String message = String.format("acquire lock failed after %s ms.", MAX_LOCK_WAIT_TIME_MS);
                throw new TimeoutException(message);
            }
            NodeInfo localNodeInfo = getLocalNodeInfo();
            List<String> children = regCenter.getChildrenKeys(nodePath.getWorkerPath());
            // 有本地缓存的节点信息，同时ZK也有这条数据
            if (localNodeInfo != null && children.contains(String.valueOf(localNodeInfo.getWorkerId()))) {
                String key = getNodePathKey(nodePath, localNodeInfo.getWorkerId());
                String zkNodeInfoJson = regCenter.get(key);
                NodeInfo zkNodeInfo = createNodeInfoFromJsonStr(zkNodeInfoJson);
                if (checkNodeInfo(localNodeInfo, zkNodeInfo)) {
                    // 更新ZK节点信息，保存本地缓存，开启定时上报任务
                    nodePath.setWorkerId(zkNodeInfo.getWorkerId());
                    zkNodeInfo.setUpdateTime(new Date());
                    updateZookeeperNodeInfo(key, zkNodeInfo);
                    saveLocalNodeInfo(zkNodeInfo);
                    executeUploadNodeInfoTask(key, zkNodeInfo);
                    return zkNodeInfo.getWorkerId();
                }
            }
            // 无本地信息或者缓存数据不匹配，开始向ZK申请节点机器ID
            for (int workerId = 0; workerId < MAX_WORKER_NUM; workerId++) {
                String workerIdStr = String.valueOf(workerId);
                if (!children.contains(workerIdStr)) { // 申请成功
                    NodeInfo applyNodeInfo = createNodeInfo(nodePath.getGroupName(), workerId);
                    nodePath.setWorkerId(applyNodeInfo.getWorkerId());
                    // 保存ZK节点信息，保存本地缓存，开启定时上报任务
                    saveZookeeperNodeInfo(nodePath.getWorkerIdPath(), applyNodeInfo);
                    saveLocalNodeInfo(applyNodeInfo);
                    executeUploadNodeInfoTask(nodePath.getWorkerIdPath(), applyNodeInfo);
                    return applyNodeInfo.getWorkerId();
                }
            }
        }
        throw new RegException("max worker num reached. register failed");
    } catch (RegException e) {
        throw e;
    } catch (Exception e) {
        logger.error("", e);
        throw new IllegalStateException(e.getMessage(), e);
    } finally {
        try {
            if (lock != null) {
                lock.release();
            }
        } catch (Exception ignored) {
            logger.error("", ignored);
        }
    }
}