詳解redis是如何實(shí)現(xiàn)隊(duì)列消息的ack
前言
由于公司提供的隊(duì)列實(shí)在太過(guò)而且還限制不能使用其他隊(duì)列，但為了保證數(shù)據(jù)安全性需要一個(gè)可以有ack功能的隊(duì)列。
原生的redis中通過(guò)L/R PUSH/POP方式來(lái)實(shí)現(xiàn)隊(duì)列的功能，這個(gè)當(dāng)然是沒(méi)辦法滿足需求的（沒(méi)有ack功能），所以需要自己對(duì)redis的list（隊(duì)列）做個(gè)小小的調(diào)整。
大體思路為在POP時(shí)將pop出的數(shù)據(jù)放到備份的地方，當(dāng)有ACK請(qǐng)求（確認(rèn)消息被消耗）后將備份的信息刪除掉；每次在pop前需要檢查備份隊(duì)列中有沒(méi)有過(guò)期的數(shù)據(jù)沒(méi)有ack的，如果有則PUSH到list中后再?gòu)膌ist中POP出來(lái)。
以下腳本使用lua實(shí)現(xiàn)，只需要在執(zhí)行前加載到redis中即可。
消息本身需要包含id屬性
push沒(méi)什么問(wèn)題，原生即可（此處以LPUSH為例）
pop時(shí)腳本
local not_empty = function(x)
return (type(x) == "table") and (not x.err) and (#x ~= 0)
end
local qName = ARGV[1] --隊(duì)列名稱
local currentTime = ARGV[2] --當(dāng)前時(shí)間，這個(gè)需要從外部傳入，不能使用redis自身時(shí)間，如果使用自身時(shí)間可能導(dǎo)致redis本身的backup在重放請(qǐng)求時(shí)出現(xiàn)不一致性
local considerAsFailMaxTimeSpan = ARGV[3] --超時(shí)時(shí)間設(shè)定，當(dāng)消息超過(guò)一定時(shí)間還沒(méi)有ack則認(rèn)為此消息需要再次入隊(duì)
local zsetName= qName ..'BACKUP'
local hashName= qName ..'CONTEXT'
local tmp = redis.call('ZRANGEBYSCORE',zsetName , '-INF', tonumber(currentTime) - tonumber(considerAsFailMaxTimeSpan), 'LIMIT', 0, 1)
if (not_empty(tmp)) then
redis.call('ZREM', zsetName, tmp[1]) --此處拿出的為消息的唯一id
redis.call('LPUSH', qName, redis.call('HGET', hashName, tmp[1]))
end
tmp = redis.call('RPOP', qName)
if (tmp) then
local msg = cjson.decode(tmp)
local id = msg['id']
redis.call('ZADD', zsetName, tonumber(currentTime), id)
redis.call('HSET',hashName , id, tmp)
end
return tmpack時(shí)候比較簡(jiǎn)單，只需要將指定id從set和hash中刪除即可
local key = ARGV[1]
local qName=ARGV[2]
redis.call('ZREM', qName..'BACKUP', key)
redis.call('HDEL', qName..'CONTEXT', key)在程序中使用前需要顯示load這兩個(gè)腳本，后面直接調(diào)用這兩個(gè)腳本的sha值即可執(zhí)行。
總結(jié)
以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作能帶來(lái)一定的幫助，如果有疑問(wèn)大家可以留言交流，謝謝大家對(duì)腳本之家的支持。
相關(guān)文章
一文詳解如何停止/重啟/啟動(dòng)Redis服務(wù)
Redis是當(dāng)前比較熱門的NOSQL系統(tǒng)之一,它是一個(gè)key-value存儲(chǔ)系統(tǒng),這篇文章主要給大家介紹了關(guān)于如何停止/重啟/啟動(dòng)Redis服務(wù)的相關(guān)資料,文中通過(guò)代碼介紹的非常詳細(xì),需要的朋友可以參考下2024-03-03
這篇文章主要介紹了在K8s上部署Redis集群的方法步驟，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-04-04
無(wú)法啟動(dòng)Redis打開(kāi)redis-server閃退的問(wèn)題解決辦法
正常開(kāi)啟redis服務(wù),首先要啟動(dòng)redis-server.exe,但是閃退,導(dǎo)致無(wú)法開(kāi)啟redis服務(wù),這篇文章主要給大家介紹了關(guān)于無(wú)法啟動(dòng)Redis打開(kāi)redis-server閃退問(wèn)題的解決辦法,需要的朋友可以參考下2024-07-07
Redis為什么默認(rèn)有16個(gè)數(shù)據(jù)庫(kù)問(wèn)題
這篇文章主要介紹了Redis為什么默認(rèn)有16個(gè)數(shù)據(jù)庫(kù)問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-02-02
這篇文章主要給大家介紹了關(guān)于Redis連接超時(shí)異常的處理方法，文中通過(guò)示例代碼以及圖文介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-07-07
redis緩存數(shù)據(jù)庫(kù)中數(shù)據(jù)的方法
這篇文章主要為大家詳細(xì)介紹了redis緩存數(shù)據(jù)庫(kù)中數(shù)據(jù)的方法，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-07-07
因?yàn)?Redis 官方只提供了命令行版的 Redis 客戶端 redis-cli，以至于我們?cè)谑褂玫臅r(shí)候會(huì)比較麻煩，而且命令行版的客戶端看起來(lái)也不夠直觀，下面是我這些年使用過(guò)的一些 Redis 可視化客戶端，分享給大家2021-06-06
在 主從架構(gòu)Redis搭建主從集群 中,一個(gè)slave節(jié)點(diǎn)掛了無(wú)影響,但是master節(jié)點(diǎn)掛了,就無(wú)法進(jìn)行寫操作了,影響高可用,Redis 提供了哨兵（Sentinel）機(jī)制來(lái)實(shí)現(xiàn)主從集群的自動(dòng)故障恢復(fù),本文給大家介紹了Redis 搭建哨兵集群的操作步驟,需要的朋友可以參考下2023-08-08
Redis和Lua實(shí)現(xiàn)分布式限流器的方法詳解
這篇文章主要給大家介紹了關(guān)于Redis和Lua實(shí)現(xiàn)分布式限流器的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家學(xué)習(xí)或者使用Redis和Lua具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-06-06
Redis是完全開(kāi)源免費(fèi)的，遵守BSD協(xié)議，是一個(gè)高性能的key-value數(shù)據(jù)庫(kù),下面這篇文章主要給大家介紹了關(guān)于Redis去重的3種不同方法,需要的朋友可以參考下2021-11-11