消息确认可以让 RabbitMQ 知道消费者已经接受并处理完消息。但是如果消息本身或者消息的处理过程出现问题怎么办?需要一种机制,通知RabbitMQ,这个消息,我无法处理,请让别的消费者处理。这里就有两种机制,Reject 和 Nack。
reject
reject在拒绝消息时,可以使用requeue标识。
1.requeue为true,消息会重新回到队列中,并通过轮循机制推送给消费者(可能是多个)。
这里需要注意的是,拒绝这条消息的消费者同样会在再次推送的消费者列表中。这个下面会再演示下。
2.requeue为false时,这条消息会直接被丢弃。
//带二个参数为requeue
channel.basicReject(envelope.getDeliveryTag(), true);
nack
跟reject方式类似,也同样的可以指定requeue.不同的是,nack可以一次性拒绝多条消息。
//带二个参数为requeue
channel.basicNack(envelope.getDeliveryTag(),
requeue=true场景演示
创建一个生产者,生产10条消息到A队列,
A队列开3个消费者:消费者A,消费者B,消费者reject/nack,拒绝时指定requeue为true
一.10条消息通过轮循机制分别投递到三个消费者中。下一次接受到消息的将会是消费者B,不过暂时没有可消费的消息了.
二.消费者reject/nack拒绝消息3,6,9,队列再次通过轮循机制推送消息,第一步的轮循中,消费者B会先消费消息.所以,消息3会推送到消费者B。消息6还会跑到消费者reject/nack中。消息9被消费者A消费。
三.消费者reject/nack最后一次拒绝消息6,消息6最后又被队列重新投递到消费B中。
结束......
requeue=false场景演示
创建一个生产者,生产10条消息到A队列,A队列开3个消费者:消费者A,消费者B,消费者reject/nack,拒绝时指定requeue为false。
一.10条消息通过轮循机制分别投递到三个消费者中。消费者reject/nack指定不把消息重新放回队列。3,6,9会被直接丢弃。
结束......