脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 数据库 → Redis → redis实现队列消息的ack

详解redis是如何实现队列消息的ack

 更新时间：2017年04月04日 10:43:07   作者：Daniel Cai  
这篇文章主要介绍了关于redis是如何实现队列消息的ack的相关资料，文中介绍的非常详细，需要的朋友可以参考借鉴，下面来一起看看吧。

前言

由于公司提供的队列实在太过而且还限制不能使用其他队列，但为了保证数据安全性需要一个可以有ack功能的队列。

原生的redis中通过L/R PUSH/POP方式来实现队列的功能，这个当然是没办法满足需求的（没有ack功能），所以需要自己对redis的list（队列）做个小小的调整。

大体思路为在POP时将pop出的数据放到备份的地方，当有ACK请求（确认消息被消耗）后将备份的信息删除掉；每次在pop前需要检查备份队列中有没有过期的数据没有ack的，如果有则PUSH到list中后再从list中POP出来。

以下脚本使用lua实现，只需要在执行前加载到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在重放请求时出现不一致性
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这两个脚本，后面直接调用这两个脚本的sha值即可执行。

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作能带来一定的帮助，如果有疑问大家可以留言交流，谢谢大家对脚本之家的支持。

相关文章

  • 一文详解如何停止/重启/启动Redis服务

    一文详解如何停止/重启/启动Redis服务

    Redis是当前比较热门的NOSQL系统之一,它是一个key-value存储系统,这篇文章主要给大家介绍了关于如何停止/重启/启动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个数据库问题

    Redis为什么默认有16个数据库问题

    这篇文章主要介绍了Redis为什么默认有16个数据库问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2023-02-02
  • Redis连接超时异常的处理方法

    Redis连接超时异常的处理方法

    这篇文章主要给大家介绍了关于Redis连接超时异常的处理方法，文中通过示例代码以及图文介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
    2020-07-07
  • redis缓存数据库中数据的方法

    redis缓存数据库中数据的方法

    这篇文章主要为大家详细介绍了redis缓存数据库中数据的方法，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2022-07-07
  • Redis可视化客户端小结

    Redis可视化客户端小结

    因为 Redis 官方只提供了命令行版的 Redis 客户端 redis-cli，以至于我们在使用的时候会比较麻烦，而且命令行版的客户端看起来也不够直观，下面是我这些年使用过的一些 Redis 可视化客户端，分享给大家
    2021-06-06
  • Redis 搭建哨兵集群的操作步骤

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

    在 主从架构Redis搭建主从集群 中,一个slave节点挂了无影响,但是master节点挂了,就无法进行写操作了,影响高可用,Redis 提供了哨兵（Sentinel）机制来实现主从集群的自动故障恢复,本文给大家介绍了Redis 搭建哨兵集群的操作步骤,需要的朋友可以参考下
    2023-08-08
  • Redis和Lua实现分布式限流器的方法详解

    Redis和Lua实现分布式限流器的方法详解

    这篇文章主要给大家介绍了关于Redis和Lua实现分布式限流器的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用Redis和Lua具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
    2019-06-06
  • Redis去重的3种不同方法汇总

    Redis去重的3种不同方法汇总

    Redis是完全开源免费的，遵守BSD协议，是一个高性能的key-value数据库,下面这篇文章主要给大家介绍了关于Redis去重的3种不同方法,需要的朋友可以参考下
    2021-11-11

最新评论