Redis队列和阻塞队列的实现
更新时间：2023年11月10日 11:22:06 作者：xdscode
本文主要介绍了Redis队列和阻塞队列的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
redis 队列的优点是轻量级，业务足够简单时不需要使用rabbitMq这样专业的消息中间件；缺点是弹出队列中的元素时，即使该消息处理失败也无法再次进行消费
Redis队列 List
简单演示如下
普通的redis队列，为了实现业务，通常会使用while进行循环，这样的话没有消息时依旧会频繁的执行循环，造成cpu的空转，所以一般会在代码中增加sleep来解决该问题，但因此又会造成消息延迟问题。
阻塞队列可以很好的解决这些问题。
Redis阻塞队列
redis队列提供了 “阻塞式” 拉取消息的命令：BRPOP / BLPOP，这里的 B 指的是阻塞（Block）。如果队列为空，消费者在拉取消息时就「阻塞等待」，一旦有新消息过来，就通知消费者立即处理新消息。
阻塞队列实现：
使用 BRPOP 这种阻塞式方式拉取消息时，还支持传入一个「超时时间」，如果设置为 0，则表示不设置超时，直到有新消息才返回，否则会在指定的超时时间后返回 NULL
下面是某业务完整的消费者代码
注意：
- 阻塞时间结束后代码会继续向下执行
- 如果设置的超时时间太长，这个连接太久没有活跃过，可能会被 Redis Server 判定为无效连接，之后 Redis Server 会强制把这个客户端踢下线。所以，客户端要有处理机制。实际项目中redis连接超时时间远大于20s，因此正常情况不会出现redis超时问题。以防万一增加redis异常捕获，出现异常时杀掉当前进程，同时supervisord会自动重新拉起该进程
到此这篇关于Redis队列和阻塞队列的实现的文章就介绍到这了,更多相关Redis队列和阻塞队列内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
一些业务背景下，业务要求单号需要有区分不同的前缀，那么在分布式的架构下如何自定义单号而且还能保证唯一呢？本文就来详细的介绍一下2021-09-09
本文主要介绍了Redis Server启动过程的详细步骤，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-02-02
Redis 为我们提供了位图这一数据结构,每个用户每天的登录记录只占据一位,365天就是365位,仅仅需要46字节就可存储,极大地节约了存储空间,这篇文章主要介绍了Redis的BitMap使用操作命令,需要的朋友可以参考下2023-10-10
这篇文章主要介绍了redis反序列化报错原因分析以及解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-03-03
在Redis集群模式中,哨兵模式是一种常用的方案,本文主要介绍了Redis哨兵监控的使用,具有一定的参考价值,感兴趣的可以了解一下2023-11-11
本文主要介绍了Redis序列化转换类型报错的解决，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-04-04
这篇文章主要介绍了Redis数据结构SortedSet的底层原理解析，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-07-07
这篇文章主要介绍了SpringBoot集成redis错误问题，本文给大家分享完美解决方法，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2022-02-02
本文主要介绍了Redis脑裂导致数据丢失的解决，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-01-01
本文主要介绍了redis中bind配置的详细步骤，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-07-07
最新评论