快捷導(dǎo)航

springboot如何使用redis的incr創(chuàng)建分布式自增id

更新時(shí)間：2022年11月19日 14:24:01 作者：有點(diǎn)兒困

這篇文章主要介紹了springboot如何使用redis的incr創(chuàng)建分布式自增id，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

使用redis的incr創(chuàng)建分布式自增id

測試使用springboot加載類測試，使用本地redis, 模擬多線程去生成規(guī)律的自增id

@Component
public class Common implements CommandLineRunner {
? ? @Autowired
? ? private RedisTemplate redisTemplate;
?
? ? @Override
? ? public void run(String... args) throws Exception {
? ? ? ? long start = System.currentTimeMillis();
? ? ? ? Thread thread1 = new Thread(new Test1());
? ? ? ? Thread thread2 = new Thread(new Test1());
? ? ? ? Thread thread3 = new Thread(new Test1());
? ? ? ? thread1.start();
? ? ? ? thread2.start();
? ? ? ? thread3.start();
? ? ? ? long end = System.currentTimeMillis();
? ? ? ? System.out.println("耗時(shí)："+(end-start));
? ? }
?
? ? class Test1 implements Runnable{
?
? ? ? ? @Override
? ? ? ? public void run() {
? ? ? ? ? ? getId();
?
? ? ? ? }
?
? ? }
?
? ? public void getId(){
? ? ? ? synchronized (this) {
? ? ? ? ? ? RedisAtomicLong entityIdCounter = null;
?
? ? ? ? ? ? for(int i=0;i<10;i++){
? ? ? ? ? ? ? ? if(!redisTemplate.hasKey("ceid")){
? ? ? ? ? ? ? ? ? ? redisTemplate.opsForValue().increment("ceid", 1);
? ? ? ? ? ? ? ? ? ? System.out.println("test1使用redis緩存保存數(shù)據(jù)成功");
? ? ? ? ? ? ? ? ? ? entityIdCounter= new RedisAtomicLong("ceid", redisTemplate.getConnectionFactory());
? ? ? ? ? ? ? ? ? ? //incr 默認(rèn)初始值從0開始，
? ? ? ? ? ? ? ? ? ? //可以設(shè)置初始值，
? ? ? ? ? ? ? ? ? ? entityIdCounter.set(123);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? entityIdCounter=new RedisAtomicLong("ceid", redisTemplate.getConnectionFactory());
? ? ? ? ? ? ? ? long increment=0;
?
? ? ? ? ? ? ? ? increment = entityIdCounter.incrementAndGet();
? ? ? ? ? ? ? ? if (i == 5) {
? ? ? ? ? ? ? ? ? ? increment = entityIdCounter.decrementAndGet();
? ? ? ? ? ? ? ? ? ? System.out.println("test1:失敗，返回上個(gè)id");
? ? ? ? ? ? ? ? }else{
? ? ? ? ? ? ? ? ? ? System.out.println(increment);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
?
? ? ? ? }
? ? }
?
}

redis配置在application.properties中

# REDIS
# Redis數(shù)據(jù)庫索引（默認(rèn)為0）
spring.redis.database=0 ?
# Redis服務(wù)器地址 （默認(rèn)為127.0.0.1）
spring.redis.host=127.0.0.1
# Redis服務(wù)器連接端口 （默認(rèn)為6379）
spring.redis.port=6379 ?
# Redis服務(wù)器連接密碼（默認(rèn)為空）
spring.redis.password= ?
# 連接超時(shí)時(shí)間（毫秒）
spring.redis.timeout=2000ms

springboot redis自增編號控制踩坑

近段期間，公司　接手一個(gè)訂單號生成服務(wù)，規(guī)則的話已經(jīng)由項(xiàng)目經(jīng)理他們規(guī)定好了，主要是后面的四位數(shù)代表的關(guān)于當(dāng)前訂單號已經(jīng)執(zhí)行第幾個(gè)了。而這里面有一個(gè)要求就是支持分布式。

為了實(shí)現(xiàn)這個(gè)東西，剛開始我使用了redis的incr來解決這個(gè)問題，因?yàn)槲覀兒蠖碎_發(fā)用的是Spring boot，所以我網(wǎng)上找了一個(gè)代碼如下:

/**
     *
     * @param key
     * @param liveTime
     * @return
     */
    public Long incr(String key, long liveTime) {
        RedisAtomicLong entityIdCounter = new RedisAtomicLong(key, redisTemplate.getConnectionFactory());
        Long increment = entityIdCounter.getAndIncrement();

        if ((null == increment || increment.longValue() == 0) && liveTime > 0) {//初始設(shè)置過期時(shí)間
            entityIdCounter.expire(liveTime, TimeUnit.SECONDS);
        }

        return increment;
    }

結(jié)果測試的時(shí)候，看著后面的數(shù)很滿意，心里面有點(diǎn)小小的激動(dòng)哦～～

但是當(dāng)我將數(shù)據(jù)從小到大排序的時(shí)候，發(fā)現(xiàn)了一點(diǎn)異樣，即剛開始的幾個(gè)是存在問題的。

所以通過測試發(fā)現(xiàn)了，當(dāng)redis里面還沒有設(shè)置計(jì)時(shí)器的一剎那，分布式服務(wù)下，會存在前幾個(gè)重復(fù)的現(xiàn)象。