ITPub博客

首页 > 数据库 > 数据库开发技术 > 如何使用数据库和Redis开发各系统独立的自增ID生成器

如何使用数据库和Redis开发各系统独立的自增ID生成器

数据库开发技术 作者:安全剑客 时间:2020-09-02 10:16:31 0 删除 编辑
在分布式系统,需要生成唯一ID的系统不止一个,这些ID的生成在各自业务内是独立的,同时包含业务规则,如果要利用数据库自增主键生成唯一ID,需要每个业务部门创建一张表来为唯一ID服务。

而因为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) { 
            Listrecords=sysIdRecordDao.getEnabledSysIdRecord(sysId); 
            if(records!=null&&records.isEmpty()) { 
                SysIdRecord record=records.get(0); 
                 
                Listbuf_ids=new ArrayList<>(); 
                for(int i=1;i<1record.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))="" listrecords=sysIdRecordDao.getEnabledSysIdRecord(sysId); 
            if(records==null||records.isEmpty()) { 
                SysIdRecord record=new SysIdRecord(); 
                //TODO 
                sysIdRecordDao.save(record); 
            } 
        } 
 
    } 
 
}
总结

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

原文地址:

来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/31559985/viewspace-2716475/,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论

注册时间:2018-11-01

  • 博文量
    1443
  • 访问量
    1010134