jedis操作redis的幾種常見方式總結(jié)

更新時間：2017年05月23日 12:00:08 作者：Enjoy_Code

Redis是一個著名的key-value存儲系統(tǒng)，也是nosql中的最常見的一種，這篇文章主要給大家總結(jié)了關(guān)于在java中jedis操作redis的幾種常見方式，文中給出了詳細(xì)的示例代碼供大家參考學(xué)習(xí)，需要的朋友們下面來一起看看吧。

前言

Redis是一個著名的key-value存儲系統(tǒng)，也是nosql中的最常見的一種。其實，個人認(rèn)為，redis最強大的地方不在于其存儲，而在于其強大的緩存作用。

我們可以把它想象成一個巨大的(多借點集群，聚合多借點的內(nèi)存)的Map，也就是Key-Value。

所以，我們可以把它做成緩存組件。

官方推薦的Java版客戶端是jedis，非常強大和穩(wěn)定，支持事務(wù)、管道及有jedis自身實現(xiàn)。我們對redis數(shù)據(jù)的操作，都可以通過jedis來完成。

那我們就來看一看，jedis不同的調(diào)用方式：

(1)普通同步方式

這是一種最簡單和最基礎(chǔ)的調(diào)用方式，對于簡單的數(shù)據(jù)存取需求，我們可以通過這種方式調(diào)用。

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之后都可以返回結(jié)果，標(biāo)記是否成功。

(2)事務(wù)方式(Transactions)

所謂事務(wù)，即一個連續(xù)操作，是否執(zhí)行是一個事務(wù)，要么完成，要么失敗，沒有中間狀態(tài)。

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

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(); 
} 
//我們調(diào)用jedis.watch(…)方法來監(jiān)控key，如果調(diào)用后key值發(fā)生變化，則整個事務(wù)會執(zhí)行失敗。另外，事務(wù)中某個操作失敗，并不會回滾其他操作。這一點需要注意。還有，我們可以使用discard()方法來取消事務(wù)。

(3)管道(Pipelining)

管道是一種兩個進(jìn)程之間單向通信的機(jī)制。

那再redis中，為何要使用管道呢？有時候，我們需要采用異步的方式，一次發(fā)送多個指令，并且，不同步等待其返回結(jié)果。這樣可以取得非常好的執(zhí)行效率。

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)管道中調(diào)用事務(wù)

對于，事務(wù)以及管道，這兩個概念我們都清楚了。

在某種需求下，我們需要異步執(zhí)行命令，但是，又希望多個命令是有連續(xù)的，所以，我們就采用管道加事務(wù)的調(diào)用方式。jedis是支持在管道中調(diào)用事務(wù)的。

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)分布式直連同步調(diào)用

這個是分布式直接連接，并且是同步調(diào)用，每步執(zhí)行都返回執(zhí)行結(jié)果。類似地，還有異步管道調(diào)用。

其實就是分片。

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("Simple@Sharing SET: " + ((end - start)/1000.0) + " seconds"); 
 
 sharding.disconnect(); 
}

(6)分布式直連異步調(diào)用

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("Pipelined@Sharing SET: " + ((end - start)/1000.0) + " seconds"); 
 
 sharding.disconnect(); 
}

(7)分布式連接池同步調(diào)用

如果，你的分布式調(diào)用代碼是運行在線程中，那么上面兩個直連調(diào)用方式就不合適了，因為直連方式是非線程安全的，這個時候，你就必須選擇連接池調(diào)用。

連接池的調(diào)用方式，適合大規(guī)模的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("Simple@Pool SET: " + ((end - start)/1000.0) + " seconds"); 
 
 pool.destroy(); 
}

(8)分布式連接池異步調(diào)用

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("Pipelined@Pool SET: " + ((end - start)/1000.0) + " seconds"); 
 pool.destroy(); 
}

(9)需要注意的地方

事務(wù)和管道都是異步模式。在事務(wù)和管道中不能同步查詢結(jié)果。比如下面兩個調(diào)用，都是不允許的：

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();

事務(wù)和管道都是異步的，個人感覺，在管道中再進(jìn)行事務(wù)調(diào)用，沒有必要，不如直接進(jìn)行事務(wù)模式。

分布式中，連接池的性能比直連的性能略好(見后續(xù)測試部分)。

分布式調(diào)用中不支持事務(wù)。

因為事務(wù)是在服務(wù)器端實現(xiàn)，而在分布式中，每批次的調(diào)用對象都可能訪問不同的機(jī)器，所以，沒法進(jìn)行事務(wù)。

總結(jié)

分布式中，連接池方式調(diào)用不但線程安全外，根據(jù)上面的測試數(shù)據(jù)，也可以看出連接池比直連的效率更好。

經(jīng)測試分布式中用到的機(jī)器越多，調(diào)用會越慢。

好了，以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對腳本之家的支持。

您可能感興趣的文章: