溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點(diǎn)擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

Redis利用Pipeline加速查詢速度的方法

發(fā)布時間:2020-09-25 17:00:38 來源:腳本之家 閱讀:284 作者:sjf0115 欄目:數(shù)據(jù)庫

1. RTT

Redis 是一種基于客戶端-服務(wù)端模型以及請求/響應(yīng)協(xié)議的TCP服務(wù)。這意味著通常情況下 Redis 客戶端執(zhí)行一條命令分為如下四個過程:

  • 發(fā)送命令
  • 命令排隊
  • 命令執(zhí)行
  • 返回結(jié)果

客戶端向服務(wù)端發(fā)送一個查詢請求,并監(jiān)聽Socket返回,通常是以阻塞模式,等待服務(wù)端響應(yīng)。服務(wù)端處理命令,并將結(jié)果返回給客戶端。客戶端和服務(wù)端通過網(wǎng)絡(luò)進(jìn)行連接。這個連接可以很快,也可能很慢。無論網(wǎng)絡(luò)如何延遲,數(shù)據(jù)包總是能從客戶端到達(dá)服務(wù)端,服務(wù)端返回數(shù)據(jù)給客戶端。

這個時間被稱為 RTT (Round Trip Time),例如上面過程的發(fā)送命令和返回結(jié)果兩個過程。當(dāng)客戶端需要連續(xù)執(zhí)行多次請求時很容易看到這是如何影響性能的(例如,添加多個元素到同一個列表中)。例如,如果 RTT 時間是250毫秒(網(wǎng)絡(luò)連接很慢的情況下),即使服務(wù)端每秒能處理100k的請求量,那我們每秒最多也只能處理4個請求。如果使用的是本地環(huán)回接口,RTT 就短得多,但如如果需要連續(xù)執(zhí)行多次寫入,這也是一筆很大的開銷。

下面我們看一下執(zhí)行 N 次命令的模型:

Redis利用Pipeline加速查詢速度的方法

2. Pipeline

我們可以使用 Pipeline 改善這種情況。Pipeline 并不是一種新的技術(shù)或機(jī)制,很多技術(shù)上都使用過。RTT 在不同網(wǎng)絡(luò)環(huán)境下會不同,例如同機(jī)房和同機(jī)房會比較快,跨機(jī)房跨地區(qū)會比較慢。Redis 很早就支持 Pipeline 技術(shù),因此無論你運(yùn)行的是什么版本,你都可以使用 Pipeline 操作 Redis。

Pipeline 能將一組 Redis 命令進(jìn)行組裝,通過一次 RTT 傳輸給 Redis,再將這組 Redis 命令按照順序執(zhí)行并將結(jié)果返回給客戶端。上圖沒有使用 Pipeline 執(zhí)行了 N 條命令,整個過程需要 N 次 RTT。下圖為使用 Pipeline 執(zhí)行 N 條命令,整個過程僅需要 1 次 RTT:

Redis利用Pipeline加速查詢速度的方法

Redis 提供了批量操作命令(例如 mget,mset等),有效的節(jié)約了RTT。但大部分命令是不支持批量操作的。

3. Java Pipeline

Jedis 也提供了對 Pipeline 特性的支持。我們可以借助 Pipeline 來模擬批量刪除,雖然不會像 mget 和 mset 那樣是一個原子命令,但是在絕大數(shù)情況下可以使用:

public void mdel(List<String> keys){
 Jedis jedis = new Jedis("127.0.0.1");
 // 創(chuàng)建Pipeline對象
 Pipeline pipeline = jedis.pipelined();
 for (String key : keys){
  // 組裝命令
  pipeline.del(key);
 }
 // 執(zhí)行命令
 pipeline.sync();
}

4. 性能測試

下表給出了不同網(wǎng)絡(luò)環(huán)境下非 Pipeline 和 Pipeline 執(zhí)行 10000 次 set 操作的效果:

網(wǎng)絡(luò) 延遲 非Pipeline Pipeline
本機(jī) 0.17ms 573ms 134ms
內(nèi)網(wǎng)服務(wù)器 0.41ms 1610ms 240ms
異地機(jī)房 7ms 78499ms 1104ms

因測試環(huán)境不同可能會得到不同的測試數(shù)據(jù),本測試 Pipeline 每次攜帶 100 條命令。

我們可以從上表中得出如下結(jié)論:

  • Pipeline 執(zhí)行速度一般比逐條執(zhí)行要快。
  • 客戶端和服務(wù)端的網(wǎng)絡(luò)延時越大,Pipeline 的效果越明顯。

5. 批量命令與Pipeline對比

下面我們看一下批量命令與 Pipeline 的區(qū)別:

  • 原生批量命令是原子的,Pipeline 是非原子的。
  • 原生批量命令是一個命令對應(yīng)多個 key,Pipeline 支持多個命令。
  • 原生批量命令是 Redis 服務(wù)端支持實(shí)現(xiàn)的,而 Pipeline 需要服務(wù)端和客戶端的共同實(shí)現(xiàn)。

6. 注意點(diǎn)

使用 Pipeline 發(fā)送命令時,每次 Pipeline 組裝的命令個數(shù)不能沒有節(jié)制,否則一次組裝的命令數(shù)據(jù)量過大,一方面會增加客戶端的等待時間,另一方面會造成一定的網(wǎng)絡(luò)阻塞,可以將一次包含大量命令的 Pipeline 拆分成多個較小的 Pipeline 來完成。

好了,以上就是這篇文章的全部內(nèi)容了,希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,謝謝大家對億速云的支持。

向AI問一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI