Redis 高并发处理 - 好文

关于使用redis的好处，前面的博客都有提到，就不在一一赘述，但是平常在项目中一般使用redis来存储数据，在查询的时候直接查询redis，可以提高RT,不用与数据库交互，而且查询缓存效率很快，那么如果单单是放一次以供查询，或者使用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命令

关于setnx命令，redis操作手册可以看到该命令的效果：
setnx k
v;当k不存在的时候将k的值设置为v,如果k存在，则不做任何操作。如果设置成功返回1，设置失败返回0。如下图，用setnx命令对同一个key设置两次，第一次设置的时候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命令来结合使用。

热门工具换一换