詳解redis是如何實現(xiàn)隊列消息的ack
更新時間：2017年04月04日 10:43:07 作者：Daniel Cai
這篇文章主要介紹了關于redis是如何實現(xiàn)隊列消息的ack的相關資料，文中介紹的非常詳細，需要的朋友可以參考借鑒，下面來一起看看吧。
前言
由于公司提供的隊列實在太過而且還限制不能使用其他隊列，但為了保證數(shù)據(jù)安全性需要一個可以有ack功能的隊列。
原生的redis中通過L/R PUSH/POP方式來實現(xiàn)隊列的功能，這個當然是沒辦法滿足需求的（沒有ack功能），所以需要自己對redis的list（隊列）做個小小的調整。
大體思路為在POP時將pop出的數(shù)據(jù)放到備份的地方，當有ACK請求（確認消息被消耗）后將備份的信息刪除掉；每次在pop前需要檢查備份隊列中有沒有過期的數(shù)據(jù)沒有ack的，如果有則PUSH到list中后再從list中POP出來。
以下腳本使用lua實現(xiàn)，只需要在執(zhí)行前加載到redis中即可。
消息本身需要包含id屬性
push沒什么問題，原生即可（此處以LPUSH為例）
pop時腳本
local not_empty = function(x)
return (type(x) == "table") and (not x.err) and (#x ~= 0)
end
local qName = ARGV[1] --隊列名稱
local currentTime = ARGV[2] --當前時間，這個需要從外部傳入，不能使用redis自身時間，如果使用自身時間可能導致redis本身的backup在重放請求時出現(xiàn)不一致性
local considerAsFailMaxTimeSpan = ARGV[3] --超時時間設定，當消息超過一定時間還沒有ack則認為此消息需要再次入隊
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時候比較簡單，只需要將指定id從set和hash中刪除即可
local key = ARGV[1]
local qName=ARGV[2]
redis.call('ZREM', qName..'BACKUP', key)
redis.call('HDEL', qName..'CONTEXT', key)在程序中使用前需要顯示load這兩個腳本，后面直接調用這兩個腳本的sha值即可執(zhí)行。
總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對腳本之家的支持。
相關文章
這篇文章主要介紹了redis服務啟動與停止方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-01-01
本文主要介紹了Redisson 加鎖解鎖的實現(xiàn)，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2022-08-08
這篇文章主要給大家介紹了關于Redis基礎學習之管道機制的相關資料，文中通過示例代碼介紹的非常詳細，對大家學習或者使用Redis具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2018-11-11
這篇文章主要介紹了 Redis Set 集合的實例詳解的相關資料,Redis的Set是string類型的無序集合。集合成員是唯一的，并且不重復，需要的朋友可以參考下2017-08-08
這篇文章主要介紹了Win10下通過Ubuntu安裝Redis,在安裝Ubuntu需要先打開Windows功能，接著創(chuàng)建一個用戶及密碼，本文給大家介紹的非常詳細，需要的朋友可以參考下2022-04-04
這篇文章以圖文結合的方式詳解Windows下使用Redis緩存工具的方法，感興趣的小伙伴們可以參考一下2015-12-12
這篇文章主要介紹了redis的五大數(shù)據(jù)類型實現(xiàn)原理，本文給大家分享五大數(shù)據(jù)類型的應用場景分析,需要的朋友可以參考下2021-08-08
Redis特殊數(shù)據(jù)類型Geospatial地理空間
這篇文章主要為大家介紹了Redis特殊數(shù)據(jù)類型Geospatial地理空間，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-05-05
內存碎片是指在內存分配的時候,產生的不能重復利用的空間,本文主要介紹了Redis 內存碎片原因及清理,具有一定的參考價值,感興趣的可以了解一下2024-06-06
在實際生產環(huán)境中為保證Redis的服務連續(xù)性和可靠性,需要設計一個高可用架構,本文就來介紹一下Redis高可用的三種實現(xiàn)方式,主要包括主從復制模式,Redis Sentinel模式和Redis Cluster模式,感興趣的可以了解一下2023-12-12