RabbitMQ(二)——消息应答与消息持久化(Worker和NewTask)

Message acknowledgment(消息应答)        执行一个任务可能需要花费几秒钟,你可能会担心如果一个消费者在执行任务过程中挂掉了。基于现在的代码,一旦RabbitMQ将消息分发给了消费者,就会从内存中删除。在这种情况下,如果杀死正在执行任务的消费者,会丢失正在处理的消息,也会丢失已经分发给这个消费者但尚未处理的消息。        但是,我们不想丢失任何任务,如果有一个消费
相关文章
相关标签/搜索