最开始我们都是编写while循环,通过consumer.nextDelivery方法获取下一条消息,然后进行消费处理。
其实还有另一种选择,使用自定义的Consumer,它更方便,解耦性更强,也是在实际工作中最常用的使用方式。
自定义Con实现只需要继承 DefaultConsumer 类,重写 handleDelivery 方法即可。
代码实现-
自定义Con
-
Con
-
Pro
-
启动Con后,查看管控台
-
启动Pro,Con接收消息
最开始我们都是编写while循环,通过consumer.nextDelivery方法获取下一条消息,然后进行消费处理。
其实还有另一种选择,使用自定义的Consumer,它更方便,解耦性更强,也是在实际工作中最常用的使用方式。
自定义Con实现只需要继承 DefaultConsumer 类,重写 handleDelivery 方法即可。
代码实现微信扫码登录