良许Linux教程网 干货合集 数据库和Redis开发各系统独立的自增ID生成器使用方法

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

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

image-20220306121923118

而因为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 records=sysIdRecordDao.getEnabledSysIdRecord(sysId);
           if(records==null||records.isEmpty()) {
               SysIdRecord record=new SysIdRecord();
               //TODO
               sysIdRecordDao.save(record);
           }
       }

   }

}

总结

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

以上就是良许教程网为各位朋友分享的Linu系统相关内容。想要了解更多Linux相关知识记得关注公众号“良许Linux”,或扫描下方二维码进行关注,更多干货等着你 !

img
本文由 良许Linux教程网 发布,可自由转载、引用,但需署名作者且注明文章出处。如转载至微信公众号,请在文末添加作者公众号二维码。
良许

作者: 良许

良许,世界500强企业Linux开发工程师,公众号【良许Linux】的作者,全网拥有超30W粉丝。个人标签:创业者,CSDN学院讲师,副业达人,流量玩家,摄影爱好者。
上一篇
下一篇

发表评论

邮箱地址不会被公开。 必填项已用*标注

联系我们

联系我们

公众号:良许Linux

在线咨询: QQ交谈

邮箱: yychuyu@163.com

关注微信
微信扫一扫关注我们

微信扫一扫关注我们

关注微博
返回顶部