Rocket MQ 的三种消息发送(同步、异步、单向)和消息订阅
消息发送步骤和逻辑分析
一、同步发送
注:
topic下面可以包含多个tag,
nameserver的地址如果要指定多个,可直接用 “ ;” 隔开,并在后面加上待添加的ip:9876即可 ,如 " ip1:9876;ip2:9876"
安装rocketmq-console监控台来查看mq状态
二、异步发送
如果性能和时间有要求的话可以选择异步发送,同步的效率较异步相比降低了10%左右,当然也可能有少量数据丢失
上图的第16行 改成下图内容,就启动了异步发送,其它都一样
三、单向消息
四、消息订阅