Rocket MQ 的三种消息发送(同步、异步、单向)和消息订阅

消息发送步骤和逻辑分析

Rocket MQ 的三种消息发送(同步、异步、单向)和消息订阅

一、同步发送

Rocket MQ 的三种消息发送(同步、异步、单向)和消息订阅

注:

topic下面可以包含多个tag,

nameserver的地址如果要指定多个,可直接用  “ ;” 隔开,并在后面加上待添加的ip:9876即可 ,如 " ip1:9876;ip2:9876"

安装rocketmq-console监控台来查看mq状态

二、异步发送 

如果性能和时间有要求的话可以选择异步发送,同步的效率较异步相比降低了10%左右,当然也可能有少量数据丢失

上图的第16行 改成下图内容,就启动了异步发送,其它都一样

Rocket MQ 的三种消息发送(同步、异步、单向)和消息订阅

三、单向消息

Rocket MQ 的三种消息发送(同步、异步、单向)和消息订阅 四、消息订阅

Rocket MQ 的三种消息发送(同步、异步、单向)和消息订阅