使用RedisAtomicLong優(yōu)化性能問(wèn)題

更新時(shí)間：2022年11月23日 08:35:07 作者：飯團(tuán)小哥哥iop

這篇文章主要介紹了使用RedisAtomicLong優(yōu)化性能問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

RedisAtomicLong優(yōu)化性能

在項(xiàng)目中許多過(guò)這樣的需求，記錄留做備忘。

需要?jiǎng)?chuàng)建一個(gè)遞增序列，這個(gè)序列會(huì)提供給多個(gè)應(yīng)用來(lái)使用，這樣就需要保持序列的原子遞增。

RedisAtomicLong

spring-data-redis包中提供的，可以對(duì)數(shù)據(jù)中的Long類型進(jìn)行原子性操作的類，下面是這個(gè)類的頭：

/**
?* Atomic long backed by Redis. Uses Redis atomic increment/decrement and watch/multi/exec operations for CAS
?* operations.
?* ?* @see java.util.concurrent.atomic.AtomicLong
?* @author Costin Leau
?* @author Thomas Darimont
?* @author Christoph Strobl
?* @author Mark Paluch
?*/
public class RedisAtomicLong extends Number implements Serializable, BoundKeyOperations<String> {

我們可以看到j(luò)ava.util.concurrent.atomic.AtomicLong，和java自帶的atomic包一樣進(jìn)行原子性操作，兩者不同的是：

AtomicLong只能在一個(gè)應(yīng)用中使用
RedisAtomicLong可以在所有與Redis有連接的應(yīng)用中使用

開(kāi)始優(yōu)化

應(yīng)用初始化時(shí)創(chuàng)建RedisAtomicLong實(shí)例。

?//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by Fernflower decompiler)
//

package com.jiu.common.redis;

import java.util.ArrayList;
import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.support.atomic.RedisAtomicLong;

public class RedisSequenceFactory {
? ? private static final Logger log = LoggerFactory.getLogger(RedisSequenceFactory.class);
? ? @Autowired
? ? private ObjectRedisTemplate<Integer> redisTemplate;

? ? public RedisSequenceFactory() {
? ? }

? ? public void set(String key, long value) {
? ? ? ? RedisAtomicLong counter = new RedisAtomicLong(key, this.redisTemplate.getConnectionFactory());
? ? ? ? counter.set(value);
? ? }

? ? public long generate(String key, int increment) {
? ? ? ? RedisAtomicLong counter = new RedisAtomicLong(key, this.redisTemplate.getConnectionFactory());
? ? ? ? return counter.addAndGet((long)increment);
? ? }

? ? public List<Long> generateBatch(String key, int increment, int size) {
? ? ? ? RedisAtomicLong counter = new RedisAtomicLong(key, this.redisTemplate.getConnectionFactory());
? ? ? ? long max = counter.addAndGet((long)(increment * size));
? ? ? ? long min = max - (long)(increment * (size - 1));
? ? ? ? List<Long> list = new ArrayList();
? ? ? ? list.add(min);

? ? ? ? for(int i = 1; i < size; ++i) {
? ? ? ? ? ? list.add(min + (long)(increment * i));
? ? ? ? }

? ? ? ? return list;
? ? }

? ? public long queryValue(String key) {
? ? ? ? Integer val = (Integer)this.redisTemplate.get(key);
? ? ? ? return val == null ? 0L : (long)val.intValue();
? ? }
}

測(cè)試代碼

public static String tradeIdIncRedisKey = "order:orderid_inc";
? ? ?@Test
? ? public long generateId(){
? ? ? ? return redisSequenceFactory.generate(tradeIdIncRedisKey,1);
? ? }

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: