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命令来结合使用。
本文参与 腾讯云自媒体分享计划，分享自作者个人站点/博客。
原始发表：2019-01-25 ，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
相关产品与服务
云数据库 Redis
腾讯云数据库 Redis（TencentDB for Redis）是腾讯云打造的兼容 Redis 协议的缓存和存储服务。丰富的数据结构能帮助您完成不同类型的业务场景开发。支持主从热备，提供自动容灾切换、数据备份、故障迁移、实例监控、在线扩容、数据回档等全套的数据库服务。