添加Jedis依賴 我們可以使用以下三種方式來添加Jedis依賴。 1、下載jar文件 從http://search.maven.org/下載最近的jedis包和Apache Commons Pool 2 2.0依賴包。 2、從源碼中構建 以下方式會構建最新的Jedis版本。 首先、克隆GitHub ...
添加Jedis依賴
我們可以使用以下三種方式來添加Jedis依賴。
1、下載jar文件
從http://search.maven.org/下載最近的jedis包和Apache Commons Pool 2 2.0依賴包。
2、從源碼中構建
以下方式會構建最新的Jedis版本。
首先、克隆GitHub項目
很簡單,在命令行輸入git clone git://github.com/xetorthio/jedis.git
命令即可。
然後、使用maven構建項目
在使用maven打包之前,需要先通過單元測試,我們可以運行make package命令完成單元測試和打包工作。
3、配置maven依賴
Jedis通過Sonatype,被髮布為一個Maven依賴,我們可以在pom.xml文件中添加以下xml片段來配置Jedis依賴
<dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.8.0</version> <type>jar</type> <scope>compile</scope> </dependency>
添加完後,在工程的maven依賴庫中可以看到以下兩個jar文件:
基本使用示例
在多線程環境中使用Jedis
你不應該在不同的線程中使用同一個Jedis對象實例,否則會遇到各種奇怪的錯誤。
同樣的,針對每個線程都創建一個Jedis實例也不是很合適,因為這意味著會有許多sockets和connections,也會造成奇怪的錯誤。
一個Jedis實例存線上程安全問題,為了避免這個問題,我們應該使用Jedis池(JedisPool),它是線程安全的。使用JedisPool,我們不僅可以避免那些奇怪的錯誤,還能取得良好的性能。
可以使用以下代碼片段初始化一個JedisPool:
JedisPool pool = new JedisPool(new JedisPoolConfig(), "localhost");
JedisPoolConfig對象包含了一些預設的連接池配置,我們可以通過查看其構造方法瞭解其具體預設配置信息,如下代碼:
public JedisPoolConfig() { // defaults to make your life with connection pool easier :) setTestWhileIdle(true); setMinEvictableIdleTimeMillis(60000); setTimeBetweenEvictionRunsMillis(30000); setNumTestsPerEvictionRun(-1); }
另外,JedisPool是基於Commons Pool 2的,所以我們也可以瞭解一下Commons Pool的配置,詳見http://commons.apache.org/proper/commons-pool/apidocs/org/apache/commons/pool2/impl/GenericObjectPoolConfig.html。
下麵給出一個完整的例子,註意要先啟動redis服務端:
package cn.edu.hdu.jedisdemo; import java.util.Set; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; public class App { public static void main(String[] args) { JedisPool pool = new JedisPool(new JedisPoolConfig(), "localhost"); // / Jedis implements Closable. Hence, the jedis instance will be // auto-closed after the last statement. try (Jedis jedis = pool.getResource()) { // / ... do stuff here ... for example jedis.set("foo", "bar"); String foobar = jedis.get("foo"); jedis.zadd("sose", 0, "car"); jedis.zadd("sose", 0, "bike"); Set<String> sose = jedis.zrange("sose", 0, -1); System.out.println(foobar); System.out.println(sose); } // / ... when closing your application: pool.close(); } }
如果你的JAVA版本不支持try-with-resource語法,我們可以使用Jedis.close()
Jedis jedis = null; try { jedis = pool.getResource(); /// ... do stuff here ... for example jedis.set("foo", "bar"); String foobar = jedis.get("foo"); jedis.zadd("sose", 0, "car"); jedis.zadd("sose", 0, "bike"); Set<String> sose = jedis.zrange("sose", 0, -1); } finally { if (jedis != null) { jedis.close(); } } /// ... when closing your application: pool.destroy();
主從配置
主伺服器負責接收寫數據請求,並且將數據改變複製給從伺服器,來保持數據一致性。
從伺服器(不一定是必須的)負責接受讀數據請求,來減輕主伺服器的壓力。
主從同步的過程
建立主從關係後,slave 會建立和 master 的連接,然後發送 sync 命令。master會啟動一個後臺進程,將資料庫快照保存到文件中,同時master主進程開始收集寫命令並緩存起來。當後臺完成寫文件後,master伺服器會將快照文件發給slave伺服器,slave伺服器會將快照文件恢復到slave的記憶體資料庫上。完成快照恢復後,master將緩存的寫命令轉發給slave,slave更新記憶體資料庫。然後,後續master的寫命令會通過開始建立的連接發送給slave來完成數據同步。
主從關係的特點
master伺服器下麵可以有多個slave伺服器,slave伺服器下麵也可以有多個slave伺服器,可以形成樹狀結構
主從複製不會阻塞master伺服器,但會阻塞slave伺服器
啟用主從關係
我們可以通過以下兩種方式啟用主從關係:
1、通過各個redis伺服器的配置文件來配置主從關係
slaveof 192.168.1.35 6379 # 指定master主伺服器的ip和埠
優缺點:簡單,但是配置文件是在伺服器啟動時載入的,所以伺服器啟動後就不能線上修改了。
2、通過調用slaveOf方法,傳入ip地址和埠號,
jedis.slaveOf("localhost", 6379); // if the master is on the same PC which runs your code jedis.slaveOf("192.168.1.35", 6379);
優點:可以線上修改redis伺服器的主從關係
關閉主從關係,提升一個從伺服器為主伺服器
當一個主伺服器宕機的時候,我們希望能將一個從伺服器升級為主伺服器。
為此,我們需要先關閉原先的主從關係,然後(假定我們有多個從伺服器),將其餘從伺服器配置到新的主伺服器上。
slave1jedis.slaveofNoOne(); //取消主伺服器關聯,自己成為主伺服器 slave2jedis.slaveof("192.168.1.36", 6379); //指定主伺服器的ip和埠
參考資料:
https://github.com/xetorthio/jedis/wiki
http://www.tuicool.com/articles/Uruyemf