redis是一個著名的key-value儲存系統，也是nosql中的最常見的一種。其實，個人認為，redis最強大的地方不在於其儲存，而在於其強大的快取作用。

我們可以把它想象成一個巨大的(多借點叢集，聚合多借點的記憶體)的Map，也就是Key-Value。

所以，我們可以把它做成快取元件。

官方推薦的java版客戶端是jedis，非常強大和穩定，支援事務、管道及有jedis自身實現。我們對redis資料的操作，都可以通過jedis來完成。

那我們就來看一看，jedis不同的呼叫方式：

(1)普通同步方式

這是一種最簡單和最基礎的呼叫方式，對於簡單的資料存取需求，我們可以通過這種方式呼叫。

public void jedisNormal() {
    Jedis jedis = new Jedis("localhost");
    long start = System.currentTimeMillis();
    for (int i = 0; i < 100000; i++) {
        String result = jedis.set("n" + i, "n" + i);
    }
    long end = System.currentTimeMillis();
    System.out.println("Simple SET: " + ((end - start)/1000.0) + " seconds");
    jedis.disconnect();
}
//每次set之後都可以返回結果，標記是否成功。
 

(2)事務方式(Transactions)

所謂事務，即一個連續操作，是否執行是一個事務，要麼完成，要麼失敗，沒有中間狀態。

而redis的事務很簡單，他主要目的是保障，一個client發起的事務中的命令可以連續的執行，而中間不會插入其他client的命令，也就是事務的連貫性。

public void jedisTrans() {
    Jedis jedis = new Jedis("localhost");
    long start = System.currentTimeMillis();
    Transaction tx = jedis.multi();
    for (int i = 0; i < 100000; i++) {
        tx.set("t" + i, "t" + i);
    }
    List<Object> results = tx.exec();
    long end = System.currentTimeMillis();
    System.out.println("Transaction SET: " + ((end - start)/1000.0) + " seconds");
    jedis.disconnect();
}
//我們呼叫jedis.watch(…)方法來監控key，如果呼叫後key值發生變化，則整個事務會執行失敗。另外，事務中某個操作失敗，並不會回滾其他操作。這一點需要注意。還有，我們可以使用discard()方法來取消事務。
 

(3)管道(Pipelining)

管道是一種兩個程序之間單向通訊的機制。

那再redis中，為何要使用管道呢？有時候，我們需要採用非同步的方式，一次傳送多個指令，並且，不同步等待其返回結果。這樣可以取得非常好的執行效率。

public void jedisPipelined() {
    Jedis jedis = new Jedis("localhost");
    Pipeline pipeline = jedis.pipelined();
    long start = System.currentTimeMillis();
    for (int i = 0; i < 100000; i++) {
        pipeline.set("p" + i, "p" + i);
    }
    List<Object> results = pipeline.syncAndReturnAll();
    long end = System.currentTimeMillis();
    System.out.println("Pipelined SET: " + ((end - start)/1000.0) + " seconds");
    jedis.disconnect();
}

(4)管道中呼叫事務

對於，事務以及管道，這兩個概念我們都清楚了。

在某種需求下，我們需要非同步執行命令，但是，又希望多個命令是有連續的，所以，我們就採用管道加事務的呼叫方式。jedis是支援在管道中呼叫事務的。

public void jedisCombPipelineTrans() {
    jedis = new Jedis("localhost"); 
    long start = System.currentTimeMillis();
    Pipeline pipeline = jedis.pipelined();
    pipeline.multi();
    for (int i = 0; i < 100000; i++) {
        pipeline.set("" + i, "" + i);
    }
    pipeline.exec();
    List<Object> results = pipeline.syncAndReturnAll();
    long end = System.currentTimeMillis();
    System.out.println("Pipelined transaction: " + ((end - start)/1000.0) + " seconds");
    jedis.disconnect();
}
//效率上可能會有所欠缺

(5)分散式直連同步呼叫

這個是分散式直接連線，並且是同步呼叫，每步執行都返回執行結果。類似地，還有非同步管道呼叫。

其實就是分片。

public void jedisShardNormal() {
    List<JedisShardInfo> shards = Arrays.asList(
            new JedisShardInfo("localhost",6379),
            new JedisShardInfo("localhost",6380));
 
    ShardedJedis sharding = new ShardedJedis(shards);
 
    long start = System.currentTimeMillis();
    for (int i = 0; i < 100000; i++) {
        String result = sharding.set("sn" + i, "n" + i);
    }
    long end = System.currentTimeMillis();
    System.out.println("[email protected] SET: " + ((end - start)/1000.0) + " seconds");
 
    sharding.disconnect();
}

(6)分散式直連非同步呼叫

public void jedisShardpipelined() {
    List<JedisShardInfo> shards = Arrays.asList(
            new JedisShardInfo("localhost",6379),
            new JedisShardInfo("localhost",6380));
 
    ShardedJedis sharding = new ShardedJedis(shards);
 
    ShardedJedisPipeline pipeline = sharding.pipelined();
    long start = System.currentTimeMillis();
    for (int i = 0; i < 100000; i++) {
        pipeline.set("sp" + i, "p" + i);
    }
    List<Object> results = pipeline.syncAndReturnAll();
    long end = System.currentTimeMillis();
    System.out.println("[email protected] SET: " + ((end - start)/1000.0) + " seconds");
 
    sharding.disconnect();
}

(7)分散式連線池同步呼叫

如果，你的分散式呼叫程式碼是執行線上程中，那麼上面兩個直連呼叫方式就不合適了，因為直連方式是非執行緒安全的，這個時候，你就必須選擇連線池呼叫。

連線池的呼叫方式，適合大規模的redis叢集，並且多客戶端的操作。

public void jedisShardSimplePool() {
    List<JedisShardInfo> shards = Arrays.asList(
            new JedisShardInfo("localhost",6379),
            new JedisShardInfo("localhost",6380));
 
    ShardedJedisPool pool = new ShardedJedisPool(new JedisPoolConfig(), shards);
 
    ShardedJedis one = pool.getResource();
 
    long start = System.currentTimeMillis();
    for (int i = 0; i < 100000; i++) {
        String result = one.set("spn" + i, "n" + i);
    }
    long end = System.currentTimeMillis();
    pool.returnResource(one);
    System.out.println("[email protected] SET: " + ((end - start)/1000.0) + " seconds");
 
    pool.destroy();
}

(8)分散式連線池非同步呼叫

public void jedisShardPipelinedPool() {
    List<JedisShardInfo> shards = Arrays.asList(
            new JedisShardInfo("localhost",6379),
            new JedisShardInfo("localhost",6380));
 
    ShardedJedisPool pool = new ShardedJedisPool(new JedisPoolConfig(), shards);
 
    ShardedJedis one = pool.getResource();
 
    ShardedJedisPipeline pipeline = one.pipelined();
 
    long start = System.currentTimeMillis();
    for (int i = 0; i < 100000; i++) {
        pipeline.set("sppn" + i, "n" + i);
    }
    List<Object> results = pipeline.syncAndReturnAll();
    long end = System.currentTimeMillis();
    pool.returnResource(one);
    System.out.println("[email protected] SET: " + ((end - start)/1000.0) + " seconds");
    pool.destroy();
}

(9)需要注意的地方

• 事務和管道都是非同步模式。在事務和管道中不能同步查詢結果。比如下面兩個呼叫，都是不允許的：

• Transaction tx = jedis.multi();
   for (int i = 0; i < 100000; i++) {
       tx.set("t" + i, "t" + i);
   }
   System.out.println(tx.get("t1000").get());  //不允許
   
   List<Object> results = tx.exec();
   
   …
   …
   
   Pipeline pipeline = jedis.pipelined();
   long start = System.currentTimeMillis();
   for (int i = 0; i < 100000; i++) {
       pipeline.set("p" + i, "p" + i);
   }
   System.out.println(pipeline.get("p1000").get()); //不允許
   
   List<Object> results = pipeline.syncAndReturnAll();

  
  
  

• 事務和管道都是非同步的，個人感覺，在管道中再進行事務呼叫，沒有必要，不如直接進行事務模式。

• 分散式中，連線池的效能比直連的效能略好(見後續測試部分)。

• 分散式呼叫中不支援事務。

• 因為事務是在伺服器端實現，而在分散式中，每批次的呼叫物件都可能訪問不同的機器，所以，沒法進行事務。

(10)總結

• 分散式中，連線池方式呼叫不但執行緒安全外，根據上面的測試資料，也可以看出連線池比直連的效率更好。

• 經測試分散式中用到的機器越多，呼叫會越慢。