亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

詳解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（隊列）做個小小的調(diào)整。

大體思路為在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 tmp

ack時候比較簡單，只需要將指定id從set和hash中刪除即可

 local key = ARGV[1]
 local qName=ARGV[2]
 redis.call('ZREM', qName..'BACKUP', key)
 redis.call('HDEL', qName..'CONTEXT', key)

在程序中使用前需要顯示load這兩個腳本，后面直接調(diào)用這兩個腳本的sha值即可執(zhí)行。

總結

以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學習或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對腳本之家的支持。

相關文章

  • 一文詳解如何停止/重啟/啟動Redis服務

    一文詳解如何停止/重啟/啟動Redis服務

    Redis是當前比較熱門的NOSQL系統(tǒng)之一,它是一個key-value存儲系統(tǒng),這篇文章主要給大家介紹了關于如何停止/重啟/啟動Redis服務的相關資料,文中通過代碼介紹的非常詳細,需要的朋友可以參考下
    2024-03-03
  • 在K8s上部署Redis集群的方法步驟

    在K8s上部署Redis集群的方法步驟

    這篇文章主要介紹了在K8s上部署Redis集群的方法步驟，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
    2021-04-04
  • 無法啟動Redis打開redis-server閃退的問題解決辦法

    無法啟動Redis打開redis-server閃退的問題解決辦法

    正常開啟redis服務,首先要啟動redis-server.exe,但是閃退,導致無法開啟redis服務,這篇文章主要給大家介紹了關于無法啟動Redis打開redis-server閃退問題的解決辦法,需要的朋友可以參考下
    2024-07-07
  • Redis為什么默認有16個數(shù)據(jù)庫問題

    Redis為什么默認有16個數(shù)據(jù)庫問題

    這篇文章主要介紹了Redis為什么默認有16個數(shù)據(jù)庫問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
    2023-02-02
  • Redis連接超時異常的處理方法

    Redis連接超時異常的處理方法

    這篇文章主要給大家介紹了關于Redis連接超時異常的處理方法，文中通過示例代碼以及圖文介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面來一起學習學習吧
    2020-07-07
  • redis緩存數(shù)據(jù)庫中數(shù)據(jù)的方法

    redis緩存數(shù)據(jù)庫中數(shù)據(jù)的方法

    這篇文章主要為大家詳細介紹了redis緩存數(shù)據(jù)庫中數(shù)據(jù)的方法，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
    2022-07-07
  • Redis可視化客戶端小結

    Redis可視化客戶端小結

    因為 Redis 官方只提供了命令行版的 Redis 客戶端 redis-cli，以至于我們在使用的時候會比較麻煩，而且命令行版的客戶端看起來也不夠直觀，下面是我這些年使用過的一些 Redis 可視化客戶端，分享給大家
    2021-06-06
  • Redis 搭建哨兵集群的操作步驟

    Redis 搭建哨兵集群的操作步驟

    在 主從架構Redis搭建主從集群 中,一個slave節(jié)點掛了無影響,但是master節(jié)點掛了,就無法進行寫操作了,影響高可用,Redis 提供了哨兵（Sentinel）機制來實現(xiàn)主從集群的自動故障恢復,本文給大家介紹了Redis 搭建哨兵集群的操作步驟,需要的朋友可以參考下
    2023-08-08
  • Redis和Lua實現(xiàn)分布式限流器的方法詳解

    Redis和Lua實現(xiàn)分布式限流器的方法詳解

    這篇文章主要給大家介紹了關于Redis和Lua實現(xiàn)分布式限流器的相關資料，文中通過示例代碼介紹的非常詳細，對大家學習或者使用Redis和Lua具有一定的參考學習價值，需要的朋友們下面來一起學習學習吧
    2019-06-06
  • Redis去重的3種不同方法匯總

    Redis去重的3種不同方法匯總

    Redis是完全開源免費的，遵守BSD協(xié)議，是一個高性能的key-value數(shù)據(jù)庫,下面這篇文章主要給大家介紹了關于Redis去重的3種不同方法,需要的朋友可以參考下
    2021-11-11

最新評論