Redis并发问题
时间:2022-07-22
本文章向大家介绍Redis并发问题,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
我们都知道Redis 是单线程的,那么如果单单是放一次以供查询,或者使用list追加放入以供查询,基本上没有太大的问题。但是如果说要根据原有的数据进行计算,怎么样保证数据的一致性,这个就是一个比较棘手的问题,比如平常我们看到的最多的就是抢红包。
模拟高并发操作redis数据 我们假设用多线程去操作缓存中的price,正常的假设有两个线程来操作,每个线程的逻辑是对price加1,理论值是2,但是实际是两个线程同时取到了0,后面写入的时候都是覆盖,所以price在缓存中的值还是1.
Jedis client = new Jedis("127.0.0.1", 6379);
ExecutorService threadPool = Executors.newFixedThreadPool(10);
String key="priceTest";
client.set(key, "0");
for(int i=1;i<10;i++){
threadPool.submit(new Runnable() {
public void run() {
String key="priceTest";
Jedis client = new Jedis("127.0.0.1", 6379);
//判断key是否存在
if(client.exists(key)){
int b = Integer.parseInt(client.get(key));
System.out.println("======="+b);
String a = String.valueOf(b+1);
client.set(key, a);
}else{
};
}
});
}
System.out.println(client.get(key));
通过setnx我们可以在操作某一个key之前给其加锁(加入给price加锁,那么就设置一个lock.price,其他想操作price的线程都要先判断price是否有锁,如果有则等释放),为了防止某一个操作加完锁而没有释放,所以需要给锁加一个过期时间,自动释放
ExecutorService threadPool = Executors.newFixedThreadPool(10);
for(int i=1;i<10;i++){
threadPool.submit(new Runnable() {
public void run() {
String key="asdasdasdasdasd";
Jedis client = new Jedis("127.0.0.1", 6379);
//尝试获取锁
long lockStatue = client.setnx("lock"+key, "value");
System.out.println(lockStatue);
//如果获取不到锁
while(lockStatue==0){
//休眠300ms,再次尝试获取
try {
Thread.currentThread();
Thread.sleep(300);
//尝试重新获取锁
lockStatue = client.setnx("lock"+key, "value");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//如果获取到锁,设置一个三秒的过期时间,防止死锁
client.expire("lock"+key, 3000);
//判断key是否存在
if(client.exists(key)){
int b = Integer.parseInt(client.get(key));
System.out.println("======="+b);
String a = String.valueOf(b+1);
client.set(key, a);
}else{
client.set(key, "0");
};
System.out.println("开始释放锁");
//全部操作成功之后,释放锁
client.del("lock"+key);
}
});
}
如果害怕在setnx之后设置超时时间设置的时候连不上redis,可以将value设置一个时间,然后通过判断时间时候过期来进一步避免死锁。这是就需要getset命令来结合使用。
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- SpringBoot分组校验及自定义校验注解
- BERT详解
- 技术创作101训练营--一篇文章带你了解CSS基本用法和选择器知识
- 不可不知的 Java 序列化 | 技术创作101训练营
- 当我们做后仿时我们究竟在仿些什么(四)
- Elasticsearch: Rare Terms Aggregation
- Elasticsearch: 运用 Pinned query 来提高文档的排名 (7.5发行版新功能)
- leetcode树之从翻转二叉树
- DiskDB,一个不用网的数据库
- 何时用多线程?多线程需要加锁吗?线程数多少最合理?
- Spring Cloud @RefreshScope 刷新机制必知道
- “非主流”的纯前端性能优化
- CICD(二) Ansible
- JS Sequence Diagrams
- kubernetes(二十一) 微服务链路监控& 自动发布