多线程下使用Jedis


  在不同的线程中使用相同的Jedis实例会发生奇怪的错误。

  但是创建太多的实现也不好因为这意味着会建立很多sokcet连接,也会导致奇怪的错误发生。

  单一Jedis实例不是线程安全的。

  为了避免这些问题,可以使用JedisPool, JedisPool是一个线程安全的网络连接池。可以用JedisPool创建一些可靠Jedis实例,可以从池中拿到Jedis的实例。这种方式可以解决那些问题并且会实现高效的性能。


【初始化JedisPool】
  JedisPool pool = new JedisPool(new JedisPoolConfig(), "localhost");
可以以静态的方式处理以上代码,它是线程安全的。


JedisPoolConfig包含了许多有用的redis指定的连接池的默认参数。比如,如果一个连接300秒内没有任何的返回Jedis将关闭这个连接。


01 Jedis jedis = pool.getResource();
02 try {
03 //随便做一些对于redis的操作
04 jedis.set("foo", "bar");
05 String foobar = jedis.get("foo");
06 jedis.zadd("sose", 0, "car"); jedis.zadd("sose", 0, "bike");
07 Set<String> sose = jedis.zrange("sose", 0, -1);
08 } finally {
09 //这里很重要,一旦拿到的jedis实例使用完毕,必须要返还给池中
10 pool.returnResource(jedis);
11 }
12 //程序关闭时,需要调用关闭方法
13 pool.destroy();


【设置主/从分布】
启用同步复制
Redis主要为了主/从分布而构建。这意味着"write"请求必须要指向"master", "master"会同步复制改变的内容到"slave". "read"请求可以(不是必须的)被指向"slave",缓解"master"的读写压力.
可以按以下的步骤使用"master". 为了启用同步复制,有两个方式去告诉"slave"将"slaveOf"到一个给定的"master":
1.在redis server的config文件(redis.conf)指明
2.在拿到的jedis实例中调用"slaveOf"方法并指定IP和端口


1 jedis.slaveOf("192.168.1.35", 6379);
注意:"slave"也是一个redis server,也可以接收"write"请求并不会报错,但是改变不会被同步复制,所以如果弄反了jedis的实例则一些操作会被覆盖.


禁用同步复制/master失败后,提升slave
如果"master"down掉,可以提升"slave"成为新的"master".首先试着禁用同步复制离线的"master",如果有几个"slave",启用同步复制其余的"slave"到新的"master".
1 slave1jedis.slaveofNoOne();
2 slave2jedis.slaveOf("192.168.1.36", 6379);

优质内容筛选与推荐>>
1、java Thread方法解析: sleep join wait notify notifyAll
2、C#中的集合(二)
3、ExecutorService生命周期
4、Impression of Team Foundation Server 2010
5、Ajax调用WebService(一)


长按二维码向我转账

受苹果公司新规定影响,微信 iOS 版的赞赏功能被关闭,可通过二维码转账支持公众号。

    阅读
    好看
    已推荐到看一看
    你的朋友可以在“发现”-“看一看”看到你认为好看的文章。
    已取消,“好看”想法已同步删除
    已推荐到看一看 和朋友分享想法
    最多200字,当前共 发送

    已发送

    朋友将在看一看看到

    确定
    分享你的想法...
    取消

    分享想法到看一看

    确定
    最多200字,当前共

    发送中

    网络异常,请稍后重试

    微信扫一扫
    关注该公众号