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

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

这主要是看应用场景,大部分场景都是异步的,有的时候确实要同步,肯定是适合场景越多越好,对吧,其实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  方式,只管发送,不在意是否成功,日志处理一般这样