RabbitMQ消息监听程序异常时,消费者会向rabbitmq 服务器发送Basic.Reject,
表示消息拒绝接受,由于Spring默认requeue-rejected配置为true,消息会重新入队,然后rabbitmq 服务器重新投递,造成了程序一直异常的情况。
我们通过rabbitmq监听消息的时候,可以添加try{}catch{}语句 也可以选择设置requeue-rejected为false来丢弃消息。
RabbitMQ消息监听程序异常时,消费者会向rabbitmq 服务器发送Basic.Reject,
表示消息拒绝接受,由于Spring默认requeue-rejected配置为true,消息会重新入队,然后rabbitmq 服务器重新投递,造成了程序一直异常的情况。
我们通过rabbitmq监听消息的时候,可以添加try{}catch{}语句 也可以选择设置requeue-rejected为false来丢弃消息。