jedis操作redis的幾種常見方式

Redis是一個著名的key-value存儲系統，也是nosql中的最常見的一種，以下是本站小編搜索整理的關於jedis操作redis的幾種常見方式，需要的朋友們一起看看吧!想了解更多相關信息請持續關注我們應屆畢業生考試網!

　　前言

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

for (int i = 0; i < 100000; i++) {

String result = ("n" + i, "n" + i);

}

long end = entTimeMillis();

tln("Simple SET: " + ((end - start)/1000.0) + " seconds");

onnect();

}

//每次set之後都可以返回結果，標記是否成功。

　　(2)事務方式(Transactions)

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

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

public void jedisTrans() {

Jedis jedis = new Jedis("localhost");

long start = entTimeMillis();

Transaction tx = i();

for (int i = 0; i < 100000; i++) {

("t" + i, "t" + i);

}

List<Object> results = ();

long end = entTimeMillis();

tln("Transaction SET: " + ((end - start)/1000.0) + " seconds");

onnect();

}

//我們調用h(…)方法來監控key，如果調用後key值發生變化，則整個事務會執行失敗。另外，事務中某個操作失敗，並不會回滾其他操作。這一點需要注意。還有，我們可以使用discard()方法來取消事務。

　　(3)管道(Pipelining)

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

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

public void jedisPipelined() {

Jedis jedis = new Jedis("localhost");

Pipeline pipeline = lined();

long start = entTimeMillis();

for (int i = 0; i < 100000; i++) {

("p" + i, "p" + i);

}

List<Object> results = AndReturnAll();

long end = entTimeMillis();

tln("Pipelined SET: " + ((end - start)/1000.0) + " seconds");

onnect();

}

　　(4)管道中調用事務

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

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

public void jedisCombPipelineTrans() {

jedis = new Jedis("localhost");

long start = entTimeMillis();

Pipeline pipeline = lined();

i();

for (int i = 0; i < 100000; i++) {

("" + i, "" + i);

}

();

List<Object> results = AndReturnAll();

long end = entTimeMillis();

tln("Pipelined transaction: " + ((end - start)/1000.0) + " seconds");

onnect();

}

//效率上可能會有所欠缺

　　(5)分佈式直連同步調用

這個是分佈式直接連接，並且是同步調用，每步執行都返回執行結果。類似地，還有異步管道調用。

其實就是分片。

public void jedisShardNormal() {

List<JedisShardInfo> shards = st(

new JedisShardInfo("localhost",6379),

new JedisShardInfo("localhost",6380));

ShardedJedis sharding = new ShardedJedis(shards);

long start = entTimeMillis();

for (int i = 0; i < 100000; i++) {

String result = ("sn" + i, "n" + i);

}

long end = entTimeMillis();

tln("Simple@Sharing SET: " + ((end - start)/1000.0) + " seconds");

onnect();

}

　　(6)分佈式直連異步調用

public void jedisShardpipelined() {

List<JedisShardInfo> shards = st(

new JedisShardInfo("localhost",6379),

new JedisShardInfo("localhost",6380));

ShardedJedis sharding = new ShardedJedis(shards);

ShardedJedisPipeline pipeline = lined();

long start = entTimeMillis();

for (int i = 0; i < 100000; i++) {

("sp" + i, "p" + i);

}

List<Object> results = AndReturnAll();

long end = entTimeMillis();

tln("Pipelined@Sharing SET: " + ((end - start)/1000.0) + " seconds");

onnect();

}

　　(7)分佈式連接池同步調用

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

連接池的調用方式，適合大規模的redis集羣，並且多客户端的操作。

public void jedisShardSimplePool() {

List<JedisShardInfo> shards = st(

new JedisShardInfo("localhost",6379),

new JedisShardInfo("localhost",6380));

ShardedJedisPool pool = new ShardedJedisPool(new JedisPoolConfig(), shards);

ShardedJedis one = esource();

long start = entTimeMillis();

for (int i = 0; i < 100000; i++) {

String result = ("spn" + i, "n" + i);

}

long end = entTimeMillis();

rnResource(one);

tln("Simple@Pool SET: " + ((end - start)/1000.0) + " seconds");

roy();

}

　　(8)分佈式連接池異步調用

public void jedisShardPipelinedPool() {

List<JedisShardInfo> shards = st(

new JedisShardInfo("localhost",6379),

new JedisShardInfo("localhost",6380));

ShardedJedisPool pool = new ShardedJedisPool(new JedisPoolConfig(), shards);

ShardedJedis one = esource();

ShardedJedisPipeline pipeline = lined();

long start = entTimeMillis();

for (int i = 0; i < 100000; i++) {

("sppn" + i, "n" + i);

}

List<Object> results = AndReturnAll();

long end = entTimeMillis();

rnResource(one);

tln("Pipelined@Pool SET: " + ((end - start)/1000.0) + " seconds");

roy();

}

　　(9)需要注意的地方

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

Transaction tx = i();

for (int i = 0; i < 100000; i++) {

("t" + i, "t" + i);

}

tln(("t1000")()); //不允許

List<Object> results = ();

…

…

Pipeline pipeline = lined();

long start = entTimeMillis();

for (int i = 0; i < 100000; i++) {

("p" + i, "p" + i);

}

tln(("p1000")()); //不允許

List<Object> results = AndReturnAll();

事務和管道都是異步的，個人感覺，在管道中再進行事務調用，沒有必要，不如直接進行事務模式。

分佈式中，連接池的性能比直連的性能略好(見後續測試部分)。

分佈式調用中不支持事務。

因為事務是在服務器端實現，而在分佈式中，每批次的調用對象都可能訪問不同的機器，所以，沒法進行事務。

　　總結

分佈式中，連接池方式調用不但線程安全外，根據上面的測試數據，也可以看出連接池比直連的效率更好。

經測試分佈式中用到的機器越多，調用會越慢。