RocketMQ-安装

服务安装

下载

https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.2.0/rocketmq-all-4.2.0-source-release.zip

安装

1.解压

2.进入主目录通过maven打包

mvn -Prelease-all -DskipTests clean install -U

设置环境变量

1.执行 /usr/libexec/java_home -V 查看jdk安装目录

1.进入主目录下的 进入主目录下的 rocketmq-all-4.3.0/distribution/target/apache-rocketmq/bin

3.编辑 vim runbroker.sh  runserver.sh 文件 删除2,3行 第一行改为你的jdk安装目录

[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=$HOME/jdk/java
[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java
[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!"

启动namesrv

1.进入主目录下的 进入主目录下的 rocketmq-all-4.3.0/distribution/target/apache-rocketmq/bin

 

2.启动 nohup sh mqnamesrv &

3.查看启动日志 tail -fn 200 nohup.out

启动broker

1.进入主目录下的 rocketmq-all-4.3.0/distribution/target/apache-rocketmq/bin

 2.将vi runbroker.cmd

改为双引号包裹

3.执行 nohup sh mqbroker -n localhost:9876 &

4.自动创建Topic启动防止出现No route info for this topic

nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true &

检查是否启动成功

执行 sh mqadmin clusterList -n localhost:9876

管理页面安装 

下载

https://github.com/apache/rocketmq-externals

安装

1.解压

2.打开

3.使用maven打包下载文件中的

4.进入rocketmq-console-ng项目根目录，执行：mvn clean package -Dmaven.test.skip=true

2种设置地址的方式

通过环境变量

设置namesrv环境变量：export NAMESRV_ADDR="localhost:9876

通过修改源码

rocketmq-console/src/main/resources/application.properties

rocketmq.config.namesrvAddr=localhost:9876 然后重新打包

执行:mvn -Prelease-all -DskipTests clean install -U

运行

 命令

服务关闭

关闭namesrv服务：sh bin/mqshutdown namesrv

关闭broker服务 ：sh bin/mqshutdown broker