背景

使用业务场景：

1.利用数据库自增主键生成唯一ID，无法满足各个系统独自生成自增的唯一ID需求。

在分布式系统，需要生成唯一ID的系统不止一个，这些ID的生成在各自业务内是独立的，同时包含业务规则，如果要利用数据库自增主键生成唯一ID，需要每个业务部门创建一张表来为唯一ID服务。

2.数据库自增主键无法满足性能要求。

而因为Redis的高性能和单线程特性，使它在这方面有独特的优势。

为了解决各个系统独自生成自增的唯一ID的需求，而又实现简单有效，做了如下设计。

各系统独立的自增ID生成器

数据库设计(mysql)

DROP TABLE IF EXISTS sys_id_record;

CREATE TABLE sys_id_record(

id INT UNSIGNED AUTO_INCREMENT,

sys_id VARCHAR(40) NOT NULL COMMENT 子系统ID,

sys_name VARCHAR(100) NOT NULL COMMENT 子系统名称,

id_from INT NOT NULL DEFAULT 1 COMMENT 子系统ID起始值,

lenth SMALLINT NOT NULL DEFAULT 10 COMMENT 子系统ID长度,

enabled VARCHAR(1) NOT NULL DEFAULT Y,

created_by VARCHAR(40) NOT NULL COMMENT 创建人,

created_date DATETIME COMMENT 创建时间,

updated_by VARCHAR(40) NOT NULL COMMENT 更新人,

updated_date DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT 更新时间,

PRIMARY KEY ( id )

)ENGINE=INNODB DEFAULT CHARSET=utf8;

主要代码

定义服务接口package com.davidwang456.test;

public interface IDGenerateService {

String getIDGenerateBySys(String sysId);

}接口服务实现package com.davidwang456.test;

import java.util.ArrayList;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.stereotype.Service;

@Service

public class IDGenerateServiceImpl implements IDGenerateService {

@Autowired

private SysIdRecordDao sysIdRecordDao;

@Autowired

private RedisTemplate redisTemplate;

@Override

public String getIDGenerateBySys(String sysId) {

init(sysId);

Object idSys=redisTemplate.opsForList().rightPop(sysId);

if(idSys==null) {

List records=sysIdRecordDao.getEnabledSysIdRecord(sysId);

if(records!=null&&records.isEmpty()) {

SysIdRecord record=records.get(0);

List buf_ids=new ArrayList<>();

for(int i=1;i

buf_ids.add(record.getIdFrom+i);

}

redisTemplate.opsForList().leftPushAll(sysId, buf_ids);

record.setIdFrom(record.getIdFrom()+record.getLenth());

sysIdRecordDao.save(record);

idSys=redisTemplate.opsForList().rightPop(sysId);

}

}

return sysId+":"+idSys;

}

private void init(String sysId) {

if(!redisTemplate.hasKey(sysId)) {

List records=sysIdRecordDao.getEnabledSysIdRecord(sysId);

if(records==null||records.isEmpty()) {

SysIdRecord record=new SysIdRecord();

//TODO

sysIdRecordDao.save(record);

}

}

}

}

总结

这个设计的核心思想是数据库控制各个子系统的起始值和步长，然后将值放到redis队列中，从队列中依此取值。当从redis中消耗掉后再次从数据库中取一批值，依此循环。