需求是这样的:项目使用redis-queue搭建了一个消息推送系统,开启了24个进程,消费的时候有可能会出现消息推送失败,这时候想把已经存在于队列里的消息延迟个几秒再进行消费,应该怎么做了?
send 方法带有延迟消费时间的参数;要么你也可以在消费的回调函数那里 sleep 下
send 方法带有延迟消费时间的参数;要么你也可以在消费的回调函数那里 sleep 下