|
开始步骤，创建springboot项目
导入MQ客户端依赖
org.apache.rocketmq
rocketmq-client
4.4.0
消息发送者步骤分析
创建消息生产者producer，并制定生产者组名指定Nameserver地址启动producer创建消息对象，指定主题Topic、Tag和消息体发送消息关闭生产者producer
消息消费者步骤分析
创建消费者consumer，指定消费者组名指定Nameserver地址订阅主题Topic和Tag设置回调函数 处理消息启动消费者consumer
三种消息发送
1. 发送同步消息
这种可靠性同步地发送方式使用的比较广泛，比如：重要的消息通知，短信通知
public class SyncProducer {
public static void main(String[] args) throws Exception {
//1.创建消息生产者producer，并制定生产者组名
DefaultMQProducer producer = new DefaultMQProducer("group1");
//2.指定Nameserver地址
producer.setNamesrvAddr("一号服务器公网IP:9876;二号服务器公网IP:9876");
//3.启动producer
producer.start();
for (int i = 0; i |