本次demo是由docker拉取的rocketmq镜像
0. 前置提示
此次教程会占用一些端口如8080，最好不要冲突
可以预先在Linux上创建文件夹
/root/data/namesrv/logs
/root/data/namesrv/store
/root/conf
/root/data/broker/logs
/root/data/broker/store
1. 安装Namesrv
- 拉取rocketmq镜像
docker pull rocketmqinc/rocketmq:4.4.0
- 启动容器
docker run -d -p 9876:9876 -v /root/data/namesrv/logs:/root/logs -v /root/data/namesrv/store:/root/store --name rmqnamesrv -e "MAX_POSSIBLE_HEAP=100000000" rocketmqinc/rocketmq:4.4.0 sh mqnamesrv
补充说明：/root/data/namesrv/logs此类:前的路径为Linux上的文件路径用来映射镜像中原路径,可以自行改变。
2. 安装broker服务器
- 拉取镜像
此镜像与上一步相同，如已拉取无需重复。 - 创建broker.conf文件
- 在/root/conf目录下创建broker.conf文件
- 在broker.conf中写入如下内容
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
brokerIP1 = {本地外网 IP}
brokerIP1修改为自己宿主机的IP
- 启动容器
docker run -d -p 10911:10911 -p 10909:10909 -v /root/data/broker/logs:/root/logs -v /root/data/broker/store:/root/store -v /root/conf/broker.conf:/opt/rocketmq-4.4.0/conf/broker.conf --name rmqbroker --link rmqnamesrv:namesrv -e "NAMESRV_ADDR=namesrv:9876" -e "MAX_POSSIBLE_HEAP=200000000" rocketmqinc/rocketmq:4.4.0 sh mqbroker -c /opt/rocketmq-4.4.0/conf/broker.conf
3. 安装rocketmq控制台
- 拉取镜像
docker pull pangliang/rocketmq-console-ng
- 启动容器
docker run -e "JAVA_OPTS=-Drocketmq.namesrv.addr={本地外网 IP}:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false" -p 8080:8080 -t pangliang/rocketmq-console-ng
- 访问页面
localhost:8080
4. 创建springboot工程
- 发送模式
发布订阅模式，广播模式 - 引入依赖
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.1.0</version>
</dependency>
<!--用到了这个依赖的相关功能（非必要）-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
- 配置生产者
server:
port: 8081
rocketmq:
name-server: 127.0.0.1:9876
producer:
group: my-producer-group
name-server配置为自己的rocketmq地址
- 构建生产者
@RestController
public class Producer {
@Autowired
private RocketMQTemplate rocketMQTemplate;
@GetMapping("/send")
public void send(){
rocketMQTemplate.convertAndSend("first-topic","Hello,消息队列！");
}
}
- 配置消费者（创建一个相同的springboot工程）
server:
port: 8082
rocketmq:
name-server: 127.0.0.1:9876
name-server配置为自己的rocketmq地址
- 构建消费者
@Component
@RocketMQMessageListener(topic = "first-topic",consumerGroup = "my-consumer-group")
@Slf4j
public class Consumer implements RocketMQListener<String> {
@Override
public void onMessage(String message) {
System.out.println("收到消息:"+ message);
}
}
6. 补充
异常说明
在客户端的 Producer 运行起来准备发送消息时抛异常如下
“ No route info of this topic ” 异常产生的原因可能是，自己当时的原因恰好是第三条：
Broker 禁止自动创建 Topic，且用户没有通过手工方式创建 Topic
Broker 没有正确连接到 Name Server
Producer 没有正确连接到 Name Server
解决办法
排查1：Broker 禁止自动创建 Topic，且用户没有通过手工方式创建 Topic：
可以在 Rocket_HOME/distribution/target/apache-rocketmq 下执行 " sh bin/mqbroker -m " 来查看 broker 的配置参数
autoCreateTopicEnable=true 证明是没有问题的
排查2：Broker 没有正确连接到 Name Server
启动 broker 的时候，只要看到了 The broker[localhost.localdomain, 192.168.58.129:10911] boot success. serializeType=JSON and name server is localhost:9876 字样就说明是成功的
排查3：Producer 没有正确连接到 Name Server
查看防护墙开放的端口，此时没有 9876
设置防火墙开放9876 端口
重新加载 firewall，修改配置后，必须重新加载才能生效：firewall-cmd --reload
再次查看防火墙开放的端口，此时已有 9876
异常处理参考链接：(5条消息) RocketMQ 常见异常处理_蚩尤后裔-CSDN博客
