如何让RabbitMQ重新传递未确认的消息？

Question

我将不折不扣地学习以下教程：https://www.rabbitmq.com/tutorials/tutorial-two-java.html。

我以这样的方式启动RabbitMQ服务器：

docker pull rabbitmq
docker run -d --hostname my-rabbit-host --name my-rabbit -p 5672:5672 rabbitmq:3

我生成了两个消费者，当我Ctrl+C其中一个时，另一个正在运行的消费者不会接收到最初发往前一个消费者的消息。如何在Ctrl+C'ing从一个消费者中重新传递消息？

编辑：我现在正在通过'brew'安装RabbitMQ，但我仍然看到同样的问题。

brew update
brew install rabbitmq
/usr/local/sbin/rabbitmq-server &

Answer 1

不需要在消费者代码中放入sleep或类似的东西。在您提供的链接上，搜索以手动消息确认开头的段落，并查看那里的代码。关键是不要承认这个消息。如果您将autoACK标志设置为true，那么您可以调用任何您想要的内容，消息一收到就会被确认。因此，不要设置该标志，为了进行测试，您可以注释掉channel.basicack（Envelope.getDeliveryTag（）,false）；行，以便不进行手动ACK。因此当使用者退出时，消息仍将在队列中。