您当前的位置: 首页 >  rabbitmq

RabbitMQ实战-消费者自定义监听

发布时间:2020-10-07 04:51:08 ,浏览量:0

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

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

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

代码实现
  • 自定义Con
  • Con
  • Pro
  • 启动Con后,查看管控台
  • 启动Pro,Con接收消息
关注
打赏
1688896170
查看更多评论

暂无认证

  • 0浏览

    0关注

    115984博文

    0收益

  • 0浏览

    0点赞

    0打赏

    0留言

私信
关注
热门博文
立即登录/注册

微信扫码登录

0.0426s