最开始我们都是编写while循环，通过consumer.nextDelivery方法获取下一条消息，然后进行消费处理。

其实还有另一种选择，使用自定义的Consumer，它更方便，解耦性更强，也是在实际工作中最常用的使用方式。

自定义Con实现只需要继承 DefaultConsumer 类，重写 handleDelivery 方法即可。

代码实现

• 自定义Con
  
• Con
  
• Pro
  
• 启动Con后,查看管控台
  
  
• 启动Pro,Con接收消息
  

文章来源: javaedge.blog.csdn.net，作者：JavaEdge.，版权归原作者所有，如需转载，请联系作者。

原文链接：javaedge.blog.csdn.net/article/details/108946688