這篇文章將為大家詳細(xì)講解有關(guān)redis中管道機(jī)制的示例分析，小編覺(jué)得挺實(shí)用的，因此分享給大家做個(gè)參考，希望大家閱讀完這篇文章后可以有所收獲。

創(chuàng)新互聯(lián)公司成都網(wǎng)站建設(shè)按需開(kāi)發(fā)，是成都網(wǎng)站推廣公司,為成都除甲醛提供網(wǎng)站建設(shè)服務(wù),有成熟的網(wǎng)站定制合作流程，提供網(wǎng)站定制設(shè)計(jì)服務(wù)：原型圖制作、網(wǎng)站創(chuàng)意設(shè)計(jì)、前端HTML5制作、后臺(tái)程序開(kāi)發(fā)等。成都網(wǎng)站維護(hù)熱線：18982081108

Pipeline簡(jiǎn)介

Redis客戶(hù)端執(zhí)行一條命令：

• 發(fā)送命令

• 命令排隊(duì)

• 執(zhí)行命令

• 返回結(jié)果

其中發(fā)送命令和返回結(jié)果可以稱(chēng)為 Round Trip Time (RTT,往返時(shí)間)。在Redis中提供了批量操作命令，例如mget、mset等，有效地節(jié)約了RTT。但是大部分命令是不支持批量操作的。

為此Redis提供了一個(gè)稱(chēng)為管道(Pipeline) 的機(jī)制將一組Redis命令進(jìn)行組裝，通過(guò)一次 RTT 傳輸給 Redis,再將這些 Redis 命令的執(zhí)行結(jié)果按順序傳遞給客戶(hù)端。即使用pipeline執(zhí)行了n次命令，整個(gè)過(guò)程就只需要一次 RTT。

對(duì)Pipeline進(jìn)行性能測(cè)試

我們使用redis-benchmark 對(duì)Pipeline進(jìn)行性能測(cè)試，該工具提供了 -P 的選項(xiàng)，此選項(xiàng)表示使用管道機(jī)制處理 n 條Redis請(qǐng)求，默認(rèn)值為1。測(cè)試如下：

# 不使用管道執(zhí)行g(shù)et set 100000次請(qǐng)求
[root@iz2zeaf3cg1099kiidi06mz ~]# redis-benchmark -t get,set -q -n 100000
SET: 55710.31 requests per second
GET: 54914.88 requests per second
# 每次pipeline組織的命令個(gè)數(shù) 為 100
[root@iz2zeaf3cg1099kiidi06mz ~]# redis-benchmark -P 100 -t get,set -q -n 100000
SET: 1020408.19 requests per second
GET: 1176470.62 requests per second
# 每次pipeline組織的命令個(gè)數(shù) 為 10000
[root@iz2zeaf3cg1099kiidi06mz ~]# redis-benchmark -P 10000 -t get,set -q -n 100000
SET: 321543.41 requests per second
GET: 241545.89 requests per second

從上面測(cè)試可以看出，使用pipeline的情況下 Redis 每秒處理的請(qǐng)求數(shù)遠(yuǎn)大于 不使用 pipeline的情況。

當(dāng)然每次pipeline組織的命令個(gè)數(shù)不能沒(méi)有節(jié)制，否則一次組裝Pipeline數(shù)據(jù)量過(guò)大，一方面會(huì)增加 客戶(hù)端等待時(shí)間，另一方面會(huì)造成一定的網(wǎng)絡(luò)阻塞。

從上面的測(cè)試中也可以看出，如果一次pipeline組織的命令個(gè)數(shù)為 10000，但是它對(duì)應(yīng)的QPS 卻小于 一次pipeline命令個(gè)數(shù)為 100的。所以每次組織 Pipeline的命令個(gè)數(shù)不是越多越好，可以將一次包含大量命令的 Pipeline 拆分為 多個(gè)較小的 Pipeline 來(lái)完成。

Pipeline關(guān)于RTT的說(shuō)明

在官網(wǎng)上有一段這樣的描述:

大致意思就是 ：

Pipeline管道機(jī)制不單單是為了減少RTT的一種方式，它實(shí)際上大大提高了Redis的QPS。原因是，在沒(méi)有使用管道機(jī)制的情況下，從訪問(wèn)數(shù)據(jù)結(jié)構(gòu)和產(chǎn)生回復(fù)的角度來(lái)看，為每個(gè)命令提供服務(wù)是非常便宜的。但是從底層套接字的角度來(lái)看，這是非常昂貴的，這涉及read（）和write（）系統(tǒng)調(diào)用，從用戶(hù)態(tài)切換到內(nèi)核態(tài)，這種上下文切換開(kāi)銷(xiāo)是巨大。而使用Pipeline的情況下，通常使用單個(gè)read（）系統(tǒng)調(diào)用讀取許多命令，然后使用單個(gè)write（）系統(tǒng)調(diào)用傳遞多個(gè)回復(fù),這樣就提高了QPS

批量命令與Pipeline對(duì)比

• 批量命令是原子的，Pipeline 是非原子的

• 批量命令是一個(gè)命令多個(gè) key,Pipeline支持多個(gè)命令

• 批量命令是 Redis服務(wù)端實(shí)現(xiàn)的，而Pipeline需要服務(wù)端和客戶(hù)端共同實(shí)現(xiàn)

使用jedis執(zhí)行 pipeline

public class JedisUtils {
 private static final JedisUtils jedisutils = new JedisUtils();

 public static JedisUtils getInstance() {
 return jedisutils;
 }

 public JedisPool getPool(String ip, Integer port) {
 JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
 jedisPoolConfig.setMaxIdle(RedisConfig.MAX_IDLE);
 jedisPoolConfig.setMaxTotal(RedisConfig.MAX_ACTIVE);
 jedisPoolConfig.setMaxWaitMillis(RedisConfig.MAX_WAIT);
 jedisPoolConfig.setTestOnBorrow(true);
 jedisPoolConfig.setTestOnReturn(true);
 JedisPool pool = new JedisPool(jedisPoolConfig, ip, port,RedisConfig.TIMEOUT,RedisConfig.PASSWORD);
 return pool;
 }

 public Jedis getJedis(String ip, Integer port) {
 Jedis jedis = null;
 int count = 0;
 while (jedis == null && count < RedisConfig.RETRY_NUM) {
  try {
  jedis = getInstance().getPool(ip, port).getResource();
  } catch (Exception e) {
  System.out.println("get redis failed");
  }
  count++;
 }
 return jedis;
 }

 public void closeJedis(Jedis jedis) {
 if (jedis != null) {
  jedis.close();
 }
 }

 public static void main(String[] args) throws InterruptedException {
 Jedis jedis = JedisUtils.getInstance().getJedis("127.0.0.1", 6379);
 Pipeline pipeline = jedis.pipelined();
 pipeline.set("hello", "world");
 pipeline.incr("counter");
 System.out.println("還沒(méi)執(zhí)行命令");
 Thread.sleep(100000);
 System.out.println("這里才開(kāi)始執(zhí)行");
 pipeline.sync();
 }
}

在睡眠100s的時(shí)候查看 Redis，可以看到此時(shí)在pipeline中的命令并沒(méi)有執(zhí)行，命令都被放在一個(gè)隊(duì)列中等待執(zhí)行:

127.0.0.1:6379> get hello
(nil)
127.0.0.1:6379> get counter
(nil)

睡眠結(jié)束后，使用 pipeline.sync()完成此次pipeline對(duì)象的調(diào)用。

127.0.0.1:6379> get hello
"world"
127.0.0.1:6379> get counter
"1"

必須要執(zhí)行pipeline.sync() 才能最終執(zhí)行命令，當(dāng)然可以使用 pipeline.syncANdReturnAll回調(diào)機(jī)制將pipeline響應(yīng)命令進(jìn)行返回。

關(guān)于“Redis中管道機(jī)制的示例分析”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，使各位可以學(xué)到更多知識(shí)，如果覺(jué)得文章不錯(cuò)，請(qǐng)把它分享出去讓更多的人看到。

網(wǎng)站名稱(chēng)：Redis中管道機(jī)制的示例分析
URL網(wǎng)址：http://chinadenli.net/article42/iphjhc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供企業(yè)網(wǎng)站制作、網(wǎng)站設(shè)計(jì)、商城網(wǎng)站、微信公眾號(hào)、網(wǎng)站設(shè)計(jì)公司、

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)