1.资源下载

官网：下载 | RocketMQ

这里选择使用编译后可以直接用的 

下载后解压：略

 

2.更改配置

主要是更改 conf/broker.conf 的配置，记得添加上下面这几行，否则消息发送失败

autoCreateTopicEnable=true # 支持自动创建topic
namesrvAddr=127.0.0.1:9876 # namespace地址
brokerIP1=192.168.0.179 # 这里是broker地址

不添加这几行可能出现以下问题

原文参考：RocketMQ连接报错RemotingConnectException: connect to ＜172.17.0.1:10:109011＞解决_org.apache.rocketmq.remoting.exception.remotingcon_zhangzengxiu的博客-CSDN博客

3.配置环境变量 

需要配置 java,maven,rocketmq的环境变量，可以参照这里配置

 

# java环境变量配置
export JAVA_HOME=/usr/lib/java-1.8/jdk1.8.0_321
export JRE_HOME=${JAVA_HOME}/jre
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib
export PATH=${JAVA_HOME}/bin:$PATH

# rocketMq环境变量配置
export ROCKETMQ_HOME=/data/rocketMq/rocketmq-all-5.1.0-bin-release
export PATH=${PATH}:${ROCKETMQ_HOME}/bin

MAVEN_HOME=/data/maven/apache-maven-3.8.4
export MAVEN_HOME
export PATH=${PATH}:${MAVEN_HOME}/bin

配置好之后刷新一下才会生效

source /etc/profile

5.启动Namesrv

一定要先启动namesrv，因为消息服务器是注册到命名服务器上的

nohup mqnamesrv &

6.启动Broker

启动消息服务器，同时指定刚刚修改过的conf文件，不然还是会读取原本默认的阿里外网IP，还是会报错。

nohup sh mqbroker -n localhost:9876 -c ../conf/broker.conf &

7.部署可视化控制台

1.下载文件

通过下面链接进入下载

GitHub - apache/rocketmq-dashboard: The state-of-the-art Dashboard of Apache RoccketMQ provides excellent monitoring capability. Various graphs and statistics of events, performance and system information of clients and application is evidently made available to the user.

 2.构建与运行

先构建，后运行

mvn clean package -Dmaven.test.skip=true
java -jar target/rocketmq-dashboard-1.0.1-SNAPSHOT.jar

运行后访问部署那台机器的ip加上端口号即可进入，端口号可以更改配置文件

 

 

8.测试消息生产与消费

1.生产消息

在rocketmq的bin目录下运行

tools.shorg.apache.rocketmq.example.quickstart.Producer

会发送1000条测试数据

 2.消费消息

在rocketmq的bin目录下运行

tools.shorg.apache.rocketmq.example.quickstart.Consumer