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

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

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

代码实现

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