网页 综合 更新时间 2026-11-13 22:16:11

workerman/redis-queue-workerman手册

自动蜘蛛 www.workerman.net 正文约 567 字
基于Redis的消息队列,支持消息延迟处理。
https://github.com/walkor/redis-queue
$address 类似 redis://ip:6379,必须以redis开头.
消费失败是指业务抛出异常Exception或者Error。消费失败后消息会放到延迟队列等待重试,重试次数由 max_attempts控制,重试间隔由retry_seconds和max_attempts共同控制。比如max_attempts为5,retry_seconds为10,第1次重试间隔为1*10秒,第2次重试时间间隔为2*10秒,第3次重试时间间隔为3*10秒,以此类推直到重试5次。如果超过了max_attempts设置测重试次数,则消息放入key为{redis-queue}-failed(1.0.5版本之前为redis-queue-failed)的失败队列
支持更改内部数据结构$package的值,只需要将更改后的$package return 即可。例如当某个消息放生某种错误时不希望再次重试,代码类似
有时候一些项目运行在apache或者php-fpm环境,无法使用workerman/redis-queue项目,可以参考如下函数实现发送
其中,参数$redis为redis实例。例如redis扩展用法类似如下:
访问原文 返回搜索 https://www.workerman.net/doc/workerman/components/workerman-redis-queue.html
本页为82搜索生成的网页快照,内容来自站内索引;演示数据的原文链接仅作示例。