前言:

1)队列需是持久化队列;

2)acknowledge设置为手动确认模式,即manual;

3)消费者接收到消息后,手动给当前信道channel反馈接收情况;

 

1、acknowledge设置为手动确认模式;

007 消费者可靠接收消息实现

 

2、定义队列;

007 消费者可靠接收消息实现

 

3、定义生产者;

007 消费者可靠接收消息实现

 

4、定义消费者;

007 消费者可靠接收消息实现

5、测试结果;

1)若返回true,消息正常从队列删除掉;

007 消费者可靠接收消息实现

2)若返回false,消息则仍旧停留在队列中;

007 消费者可靠接收消息实现

6、demo地址;

https://github.com/haishui211/rabbitmqRep.git

相关文章: