您当前的位置: 首页 > 

java持续实践

暂无认证

  • 2浏览

    0关注

    746博文

    0收益

  • 0浏览

    0点赞

    0打赏

    0留言

私信
关注
热门博文

RocketMQ 发送消息的三种方式 消费消息的两种模式

java持续实践 发布时间:2021-04-04 13:37:36 ,浏览量:2

发送消息的三种方式:

  1. 同步发模式: 发送消息到mq中之后, 要一直等待mq返回结果才会运行接下来的代码.
  2. 异步发送模式: 消息发送后, 不会一直等待mq返回结果才执行下去, 而是会回调SendCallback 函数. 成功则回调onSuccess , 失败回调onException函数.
  3. 单向消息模式: sendOneway方法不会去管发送的结果, 发送了代码就会往下走了.

消费消息的两种模式:

  1. DefaultMQPushConsumer Broker 推送消息给消费方.
  2. DefaultMQPullConsumer 消费者主动发送请求到Broker去拉取消息.
关注
打赏
1658054974
查看更多评论
立即登录/注册

微信扫码登录

0.0362s