发送消息的三种方式:
- 同步发模式: 发送消息到mq中之后, 要一直等待mq返回结果才会运行接下来的代码.
- 异步发送模式: 消息发送后, 不会一直等待mq返回结果才执行下去, 而是会回调SendCallback 函数. 成功则回调onSuccess , 失败回调onException函数.
- 单向消息模式: sendOneway方法不会去管发送的结果, 发送了代码就会往下走了.
消费消息的两种模式:
- DefaultMQPushConsumer Broker 推送消息给消费方.
- DefaultMQPullConsumer 消费者主动发送请求到Broker去拉取消息.