Redis客戶端開發包：Jedis學習-入門，redisjedis

Redis客戶端開發包：Jedis學習-入門，redisjedis

添加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