God_zmd 2021-01-04 13:31 采纳率: 59.2%
浏览 515
已采纳

为什么rocketmq有同步发送消息,这不是和消息队列的异步原则冲突了嘛

为什么rocketmq有同步发送消息,这不是和消息队列的异步原则冲突了嘛,这不是违反了使用消息队列的初衷嘛

  • 写回答

1条回答 默认 最新

  • damoneric_guo 2021-01-04 16:49
    关注

    这主要是看应用场景,大部分场景都是异步的,有的时候确实要同步,肯定是适合场景越多越好,对吧,其实rocketmq还提供了第三种oneway方式,选择性更强对于整个系统都是很好的,具体三种方式如下:

    1.同步发送 ,需要同时等待

    SendResult sendResult = payProducer.getProducer().send(message);

    有返回值

    2.异步发送,异步线程发送出去消息,速度快

    sendCallback()

    
     
    1. payProducer.getProducer().send(message, new SendCallback() {

    2. @Override

    3. public void onSuccess(SendResult sendResult) {

    4. System.out.printf(sendResult.getSendStatus()+"");

    5. }

    6.  
    7. @Override

    8. public void onException(Throwable throwable) {

    9. //根据业务处理

    10. }

    11. });

    3.oneway  方式,只管发送,不在意是否成功,日志处理一般这样

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥100 set_link_state
  • ¥15 虚幻5 UE美术毛发渲染
  • ¥15 CVRP 图论 物流运输优化
  • ¥15 Tableau online 嵌入ppt失败
  • ¥100 支付宝网页转账系统不识别账号
  • ¥15 基于单片机的靶位控制系统
  • ¥15 真我手机蓝牙传输进度消息被关闭了,怎么打开?(关键词-消息通知)
  • ¥15 装 pytorch 的时候出了好多问题,遇到这种情况怎么处理?
  • ¥20 IOS游览器某宝手机网页版自动立即购买JavaScript脚本
  • ¥15 手机接入宽带网线,如何释放宽带全部速度