workerman/redis-queue 8进程 重复消费 同1个消息 怎么处理?

kspade

没有单独使用过workerman 我是一直在用webman,webman队列消费各种没毛病,但是我目前是二开一个其它项目,我想只要1个队列功能,我想用单个php文件实现(能实现吗?),群友推荐我用:workerman/redis-queue

我尝试用1个 :work.php 文件专门做队列消费,我是这样写的代码

截图

当我投递1条消息进去的时候就 会每个进程都消费了它1次(消费8次),请教一下workerman 中这应该怎么处理?

367 1 0
1个回答

nitron

这代码一看就是你执行了8次Timer::Add(),投递了8个任务,可不得消费了8次么

🔝