rabbitmq五种模式

1、简单模式

简单模式&＃xff1a;一个生产者&＃xff0c;一个消费者

2、工作队列模式

一个生产者&＃xff0c;多个消费者&＃xff0c;每个消费者获取到的消息唯一&＃xff08;消费者彼此竞争成为接收者&＃xff09;

channel.setbasicQos(1);

3、发布订阅模式

一个生产者发送的消息会被多个消费者获取。

交换机为fanout

4、路由模式

发送消息到交换机并且要指定路由key &＃xff0c;消费者将队列绑定到交换机时需要指定路由key

交换机为direct 并指定路由key

5、topic通配符模式

将路由键和某模式进行匹配&＃xff0c;此时队列需要绑定在一个模式上

交换机为topic模式&＃xff0c;路由key可选 *&＃xff08;匹配明确的一个单词&＃xff09;  或 #(匹配0到多个单词)

手动应答

channel.basicAck();

deliveryTag:该消息的index
multiple&＃xff1a;是否批量.true:将一次性ack所有小于deliveryTag的消息。

&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

channel.basicNack(delivery.getEnvelope().getDeliveryTag(), false, true);

deliveryTag:该消息的indexmultiple&＃xff1a;是否批量.true:将一次性拒绝所有小于deliveryTag的消息。requeue&＃xff1a;被拒绝的是否重新入队列

&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

channel.basicReject(delivery.getEnvelope().getDeliveryTag(), false);

deliveryTag:该消息的index
requeue&＃xff1a;被拒绝的是否重新入队列

&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

channel.basicConsume(QUEUE_NAME, true, consumer);

autoAck&＃xff1a;是否自动ack&＃xff0c;如果不自动ack&＃xff0c;需要使用channel.ack、channel.nack、channel.basicReject 进行消息应答

注&＃xff1a;

channel.basicNack 与 channel.basicReject 的区别在于basicNack可以拒绝多条消息&＃xff0c;而basicReject一次只能拒绝一条消息