使用RedisAtomicLong优化性能问题
更新时间:2022年11月23日 08:35:07 作者:饭团小哥哥iop
这篇文章主要介绍了使用RedisAtomicLong优化性能问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
RedisAtomicLong优化性能
在项目中许多过这样的需求,记录留做备忘。
需要创建一个递增序列,这个序列会提供给多个应用来使用,这样就需要保持序列的原子递增。
RedisAtomicLong
spring-data-redis包中提供的,可以对数据中的Long类型进行原子性操作的类,下面是这个类的头:
/**
* 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> {我们可以看到java.util.concurrent.atomic.AtomicLong,和java自带的atomic包一样进行原子性操作,两者不同的是:
AtomicLong只能在一个应用中使用RedisAtomicLong可以在所有与Redis有连接的应用中使用
开始优化
应用初始化时创建RedisAtomicLong实例。
//
// 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();
}
}测试代码
public static String tradeIdIncRedisKey = "order:orderid_inc";
@Test
public long generateId(){
return redisSequenceFactory.generate(tradeIdIncRedisKey,1);
}以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。
相关文章
java异常处理执行顺序详解try catch finally
try catch语句是java语言用于捕获异常并进行处理的标准方式,对于try catch及try catch finally执行顺序必须有深入的了解2021-10-10
Java+Selenium调用JavaScript的方法详解
这篇文章主要为大家讲解了java在利用Selenium操作浏览器网站时候,有时会需要用的JavaScript的地方,代码该如何实现呢?快跟随小编一起学习一下吧2023-01-01
关于springboot忽略接口,参数注解的使用ApiIgnore
这篇文章主要介绍了关于springboot忽略接口,参数注解的使用ApiIgnore,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-07-07
Java String源码contains题解重复叠加字符串匹配
这篇文章主要为大家介绍了Java String源码contains题解重复叠加字符串匹配示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2022-11-11


最新评论