多線程下使用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);


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM