Jedis使用总结【pipeline】【分布式的id生成器】【分布式锁【watch】【multi】】【redis分布式】

设计模式 2020-09-05
一、 Pipeline

官方的说明是：starts a pipeline,which is a very efficient way to send lots of command and read all the responses when you finish sending them。简单点说pipeline适用于批处理。当有大量的操作需要一次性执行的时候，可以用管道。

示例：

[java]  view plain copy

在CODE上查看代码片

派生到我的代码片
  1. Jedis jedis = new Jedis(String, int);  
  2. Pipeline p = jedis.pipelined();  
  3. p.set(key,value);//每个操作都发送请求给redis-server  
  4. p.get(key,value);  
  5.   
  6. p.sync();//这段代码获取所有的response  

这里我进行了20w次连续操作（10w读，10w写），不用pipeline耗时：187242ms，用pipeline耗时：1188ms，可见使用管道后的性能上了一个台阶。看了代码了解到，管道通过一次性写入请求，然后一次性读取响应。也就是说jedis是：request response，request response，...；pipeline则是：request request... response response的方式。这样无需每次请求都等待server端的响应。


二、 跨jvm的id生成器 
谈到这个话题，首先要知道redis-server端是单线程来处理client端的请求的。
这样来实现一个id生成器就非常简单了，只要简单的调用jdeis.incr(key);就搞定了。
你或许会问，incr是原子操作吗，能保证不会出现并发问题吗，前面说过，server端是单线程处理请求的。

三、 【跨jvm的锁实现【watch】【multi】】
首先说下这个问题的使用场景，有些时候我们业务逻辑是在不同的jvm进程甚至是不同的物理机上的jvm处理的。这样如何来实现不同jvm上的同步问题呢，其实我们可以基于redis来实现一个锁。

暂时找到三种实现方式：
1. 通过jedis.setnx(key,value)实现

派生到我的代码片

     import java.util.Random;  
  1. import org.apache.commons.pool.impl.GenericObjectPool.Config;  
  2. import redis.clients.jedis.Jedis;  
  3. import redis.clients.jedis.JedisPool;  
  4. import redis.clients.jedis.Transaction;  
  5. /** 
  6.  * @author Teaey 
  7.  */  
  8. public class RedisLock {  
  9.     //加锁标志  
  10.     static final String LOCKED = "TRUE";  
  11.     final long ONE_MILLI_NANOS = 1000000L;  
  12.     //默认超时时间（毫秒）  
  13. long DEFAULT_TIME_OUT = 3000;  
  14. static JedisPool pool;  
  15. final Random r = new Random();  
  16. //锁的超时时间（秒），过期删除  
  17. int EXPIRE = 5 * 60;  
  18. static {  
  19.         pool = new JedisPool(new Config(), "host", 6379);  
  20.     }  
  21. private Jedis jedis;  
  22. private String key;  
  23. //锁状态标志  
  24. private boolean locked = false;  
  25.   
  26. public RedisLock(String key) {  
  27.         this.key = key;  
  28.         this.jedis = pool.getResource();  
  29.     }  
  30. boolean lock(long timeout) {  
  31. long nano = System.nanoTime();  
  32.         timeout *= ONE_MILLI_NANOS;  
  33. try {  
  34.             while ((System.nanoTime() - nano) < timeout) {  
  35.                 if (jedis.setnx(key, LOCKED) == 1) {  
  36.                     jedis.expire(key, EXPIRE);  
  37.                     locked = true;  
  38.                     return locked;  
  39.                 }  
  40.                 // 短暂休眠，nano避免出现活锁  
  41.                 Thread.sleep(3, r.nextInt(500));  
  42.             }  
  43.         } catch (Exception e) {  
  44.         }  
  45. return boolean lock() {  
  46. return lock(DEFAULT_TIME_OUT);  
  47. // 无论是否加锁成功，必须调用  
  48. void unlock() {  
  49. if (locked)  
  50.                 jedis.del(key);  
  51.         } finally {  
  52.             pool.returnResource(jedis);  
  53. }  
  54. 2. 通过事务(multi)实现  
  55. 由于采纳第一张方法，第二种跟第三种实现只贴了关键代码，望谅解。^_^  
  56.      boolean lock_2(long timeout) {  
  57. long nano = System.nanoTime();  
  58.         timeout *= ONE_MILLI_NANOS;  
  59. try {  
  60.             while ((System.nanoTime() - nano) < timeout) {  
  61.                 Transaction t = jedis.multi();  
  62.                 // 开启事务，当server端收到multi指令  
  63. // 会将该client的命令放入一个队列，然后依次执行，知道收到exec指令  
  64.                 t.getSet(key, LOCKED);  
  65.                 t.expire(key,108); list-style:decimal-leading-zero outside; color:inherit; line-height:18px; margin:0px!important; padding:0px 3px 0px 10px!important">                 String ret = (String) t.exec().get(0);  
  66.                 if (ret == null || ret.equals("UNLOCK")) {  
  67.                                      }  
  68. // 短暂休眠，nano避免出现活锁  
  69.                 Thread.sleep(500));  
  70.             }  
  71. catch (Exception e) {  
  72.         }  
  73. false;  
  74.     }  


3. 通过事务+监听实现

派生到我的代码片

    boolean lock_3(                    jedis.watch(key);  
  1. // 开启watch之后，如果key的值被修改，则事务失败，exec方法返回null  
  2.                 String value = jedis.get(key);  
  3. if (value == null || value.equals("UNLOCK")) {  
  4.                     Transaction t = jedis.multi();  
  5.                     t.setex(key, EXPIRE,153); font-weight:bold; background-color:inherit">if (t.exec() != null) {  
  6.                                              }  
  7.                 jedis.unwatch();  
  8.     }  

最终采用第一种实现，因为加锁只需发送一个请求，效率最高。

四、 【redis分布式】
    最后一个话题，jedis的分布式。在jedis的源码里发现了两种hash算法（MD5，MURMUR Hash(默认）），也可以自己实现redis.clients.util.Hashing接口扩展。

List<JedisShardInfo> hosts = new ArrayList();

派生到我的代码片

    //server1  
  1. JedisShardInfo host1 = new JedisShardInfo("",0); background-color:inherit">6380,0); background-color:inherit">2000);  
  2. //server2  
  3. JedisShardInfo host2 = 6381,108); list-style:decimal-leading-zero outside; color:inherit; line-height:18px; margin:0px!important; padding:0px 3px 0px 10px!important"> hosts.add(host1);  
  4. hosts.add(host2);  
  5. ShardedJedis jedis = new ShardedJedis(hosts);  
  6. jedis.set("key", "");  

相关文章

什么是设计模式？Design pattern--和生活结合更好理解
什么是设计模式一套被反复使用、多数人知晓的、经过分类编目...
面向对象设计原则一——单一职责原则
单一职责原则定义（Single Responsibility Principle，SRP）...
十分钟理解Java中的动态代理----强烈推荐
动态代理和CGLib代理分不清吗，看看这篇文章，写的非常好，强...
适配器模式-让不兼容的接口得以适配
适配器模式将一个类的接口转换成客户期望的另一个接口，使得...
策略模式-定义一个算法族
策略模式定义了一系列算法族，并封装在类中，它们之间可以互...
设计模式之高质量代码
设计模式讲的是如何编写可扩展、可维护、可读的高质量代码，...