为什么rocketmq有同步发送消息,这不是和消息队列的异步原则冲突了嘛,这不是违反了使用消息队列的初衷嘛
1条回答 默认 最新
- damoneric_guo 2021-01-04 16:49关注
这主要是看应用场景,大部分场景都是异步的,有的时候确实要同步,肯定是适合场景越多越好,对吧,其实rocketmq还提供了第三种oneway方式,选择性更强对于整个系统都是很好的,具体三种方式如下:
1.同步发送 ,需要同时等待
SendResult sendResult = payProducer.getProducer().send(message);
有返回值
2.异步发送,异步线程发送出去消息,速度快
sendCallback()
-
payProducer.getProducer().send(message, new SendCallback() {
-
@Override
-
public void onSuccess(SendResult sendResult) {
-
System.out.printf(sendResult.getSendStatus()+"");
-
}
-
@Override
-
public void onException(Throwable throwable) {
-
//根据业务处理
-
}
-
});
3.oneway 方式,只管发送,不在意是否成功,日志处理一般这样
本回答被题主选为最佳回答 , 对您是否有帮助呢?解决 1无用 -
悬赏问题
- ¥15 ads仿真结果在圆图上是怎么读数的
- ¥20 Cotex M3的调试和程序执行方式是什么样的?
- ¥20 java项目连接sqlserver时报ssl相关错误
- ¥15 一道python难题3
- ¥15 用matlab 设计一个不动点迭代法求解非线性方程组的代码
- ¥15 牛顿斯科特系数表表示
- ¥15 arduino 步进电机
- ¥20 程序进入HardFault_Handler
- ¥15 oracle集群安装出bug
- ¥15 关于#python#的问题:自动化测试