以前的ssm项目整合了rabbitmq后，发送消息后控制台一直提示以下信息，而且项目关了。电脑重启之后，只要把项目运行起来就会继续提示。。。。。。。
2021-04-20 11:57:04 DEBUG org.springframework.amqp.rabbit.listener.BlockingQueueConsumer SimpleAsyncTaskExecutor-1: - Retrieving delivery for Consumer: tags=[{amq.ctag-KP8yWzYu5dN0GcycbqtYeg=bid_queues}], channel=Cached Rabbit Channel: PublisherCallbackChannelImpl: AMQChannel(amqp://admin@127.0.0.1:5672/,1), acknowledgeMode=MANUAL local queue size=0
2021-04-20 11:57:05 DEBUG org.springframework.amqp.rabbit.listener.BlockingQueueConsumer SimpleAsyncTaskExecutor-1: - Retrieving delivery for Consumer: tags=[{amq.ctag-KP8yWzYu5dN0GcycbqtYeg=bid_queues}], channel=Cached Rabbit Channel: PublisherCallbackChannelImpl: AMQChannel(amqp://admin@127.0.0.1:5672/,1), acknowledgeMode=MANUAL local queue size=0
13:52:15.262 [SimpleAsyncTaskExecutor-1] DEBUG o.s.a.r.l.BlockingQueueConsumer - Retrieving delivery for Consumer: tags=[{amq.ctag-g87xXP6OlKESlkM-PNNfSg=demo_queues}], channel=Cached Rabbit Channel: PublisherCallbackChannelImpl: AMQChannel(amqp://admin@192.168.1.136:5672/,1), acknowledgeMode=MANUAL local queue size=0
13:52:16.262 [SimpleAsyncTaskExecutor-1] DEBUG o.s.a.r.l.BlockingQueueConsumer - Retrieving delivery for Consumer: tags=[{amq.ctag-g87xXP6OlKESlkM-PNNfSg=demo_queues}], channel=Cached Rabbit Channel: PublisherCallbackChannelImpl: AMQChannel(amqp://admin@192.168.1.136:5672/,1), acknowledgeMode=MANUAL local queue size=0
13:52:17.263 [SimpleAsyncTaskExecutor-1] DEBUG o.s.a.r.l.BlockingQueueConsumer - Retrieving delivery for Consumer: tags=[{amq.ctag-g87xXP6OlKESlkM-PNNfSg=demo_queues}], channel=Cached Rabbit Channel: PublisherCallbackChannelImpl: AMQChannel(amqp://admin@192.168.1.136:5672/,1), acknowledgeMode=MANUAL local queue size=0
13:52:18.264 [SimpleAsyncTaskExecutor-1] DEBUG o.s.a.r.l.BlockingQueueConsumer - Retrieving delivery for Consumer: tags=[{amq.ctag-g87xXP6OlKESlkM-PNNfSg=demo_queues}], channel=Cached Rabbit Channel: PublisherCallbackChannelImpl: AMQChannel(amqp://admin@192.168.1.136:5672/,1), acknowledgeMode=MANUAL local queue size=0
13:52:19.264 [SimpleAsyncTaskExecutor-1] DEBUG o.s.a.r.l.BlockingQueueConsumer - Retrieving delivery for Consumer: tags=[{amq.ctag-g87xXP6OlKESlkM-PNNfSg=demo_queues}], channel=Cached Rabbit Channel: PublisherCallbackChannelImpl: AMQChannel(amqp://admin@192.168.1.136:5672/,1), acknowledgeMode=MANUAL local queue size=0
就是一直提示这个
题主解决了吗？
RabbitMQ消息监听程序异常时，消费者会向rabbitmq server发送Basic.Reject，表示消息拒绝接受，由于Spring默认requeue-rejected配置为true，消息会重新入队，然后rabbitmq server重新投递，造成了程序一直异常的情况。所以说了这么多，我们通过rabbitmq监听消息的时候，程序一定要添加try…catch语句!!!当然你也可以根据实际情况，选择设置requeue-rejected为false来丢弃消息。