使用數據庫和Redis開發各系統獨立的自增ID生成器
作者：架構師筆記
在分布式系統，需要生成唯一ID的系統不止一個，這些ID的生成在各自業務內是獨立的，同時包含業務規則，如果要利用數據庫自增主鍵生成唯一ID，需要每個業務部門創建一張表來為唯一ID服務。
背景
使用業務場景：
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<SysIdRecord> records=sysIdRecordDao.getEnabledSysIdRecord(sysId);
if(records!=null&&records.isEmpty()) {
SysIdRecord record=records.get(0);
List<Integer> buf_ids=new ArrayList<>();
for(int i=1;i<record.getLenth+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<SysIdRecord> records=sysIdRecordDao.getEnabledSysIdRecord(sysId);
if(records==null||records.isEmpty()) {
SysIdRecord record=new SysIdRecord();
//TODO
sysIdRecordDao.save(record);
}
}
}
}
總結
這個設計的核心思想是數據庫控制各個子系統的起始值和步長，然后將值放到redis隊列中，從隊列中依此取值。當從redis中消耗掉后再次從數據庫中取一批值，依此循環。
責任編輯：張燕妮
來源：
今日頭條
