如何利用数据库和Redis为每个系统开发独立的自增ID生成器 DROPTABLEIFEXISTSsys_id_re
这个设计的核心思想是数据库控制各个子系统的起始值和步长,然后将值放到redis队列中,从队列中依此取值。当从redis中消耗掉后再次从数据库中取一批值,依此循环。
总结
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<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 records=sysIdRecordDao.getEnabledSysIdRecord(sysId); if(records==null||records.isEmpty()) { SysIdRecord record=new SysIdRecord(); //TODO sysIdRecordDao.save(record); } } } }
接口服务实现
package com.davidwang456.test; public interface IDGenerateService { String getIDGenerateBySys(String sysId); }
定义服务接口
主要代码
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;
数据库设计(mysql)
各系统独立的自增ID生成器
为了解决各个系统独自生成自增的唯一ID的需求,而又实现简单有效,做了如下设计。
而因为Redis的高性能和单线程特性,使它在这方面有独特的优势。