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();
事務和管道都是非同步的,個人感覺,在管道中再進行事務呼叫,沒有必要,不如直接進行事務模式。
分散式中,連線池的效能比直連的效能略好(見後續測試部分)。
分散式呼叫中不支援事務。
因為事務是在服務器端實現,而在分散式中,每批次的呼叫物件都可能訪問不同的機器,所以,沒法進行事務。
總結
分散式中,連線池方式呼叫不但執行緒安全外,根據上面的測試資料,也可以看出連線池比直連的效率更好。
經測試分散式中用到的機器越多,呼叫會越慢。