RocketMQ 4.x入门到进阶

RocketMQ 4.x使用（持续更新中......每周至少两章，不更新我吃屎）

• 第一章《安装搭建RocketMQ 4.x》
• 第二章《搭建RocketMQ可视化管理后台》

第一章《安装搭建RocketMQ 4.x》

安装搭建前置条件(参照官网https://rocketmq.apache.org/docs/quick-start/)

• 64bit OS, Linux/Unix/Mac is recommended;
• 64bit JDK 1.8+;
• Maven 3.2.x;
• Git;
• 4g+ free disk for Broker server

安装步骤

1. 下载安装包http://mirror.bit.edu.cn/apache/rocketmq/4.4.0/rocketmq-all-4.4.0-source-release.zip
2. 解压缩4.4.0源代码版本并构建二进制工件。

  > unzip rocketmq-all-4.4.0-source-release.zip
  > cd rocketmq-all-4.4.0/
  > mvn -Prelease-all -DskipTests clean install -U
  > cd distribution/target/apache-rocketmq

3. 以守护进程启动nameServer

  > nohup sh bin/mqnamesrv &
  > tail -f ~/logs/rocketmqlogs/namesrv.log
  The Name Server boot success...

4. 以守护进程启动broker（-n指定nameServer地址，nameServer端口9876，broker默认端口10911）

  > nohup sh bin/mqbroker -n localhost:9876 &
  > tail -f ~/logs/rocketmqlogs/broker.log 
  The broker[%s, 172.30.30.233:10911] boot success...

5. 关闭服务，注意关闭顺序

 > sh bin/mqshutdown broker
 The mqbroker(36695) is running...
 Send shutdown request to mqbroker(36695) OK

 > sh bin/mqshutdown namesrv
 The mqnamesrv(36664) is running...
 Send shutdown request to mqnamesrv(36664) OK

中间产生的问题
问题1：Please set the JAVA_HOME variable in your environment, We need java(x64)
解决：需要本地配置JAVA_HOME

JAVA_HOME="/Library/Java/JavaVirtualMachines/jdk1.8.0_171.jdk/Con
export JAVA_HOME
CLASS_PATH="$JAVA_HOME/lib"
PATH=".$PATH:$JAVA_HOME/bin"

测试

第二章《搭建RocketMQ可视化管理后台》

安装步骤

1. 下载 git clone https://github.com/apache/rocketmq-externals.git
2. 修改‎⁨⁨rocketmq-externals⁩ ▸ ⁨rocketmq-console⁩ ▸ ⁨src⁩ ▸ ⁨main⁩ ▸ ⁨resources⁩▸ application.properties

  > rocketmq.config.namesrvAddr=127.0.0.1:9876

3. 打包

  > cd rocketmq-externals/rocketmq-console
  > mvn clean package -Dmaven.test.skip=true

4. 启动 java -jar target/rocketmq-console-ng-1.0.0.jar
5. 访问 http://localhost:8080

中间产生的问题
问题1：打包失败
解决：检查pom文件

将<rocketmq.version>4.4.0-SNAPSHOT</rocketmq.version>
调整为<rocketmq.version>4.4.0</rocketmq.version>

问题2：启动失败

解决：检查pom文件Springboot版本

将 <version>1.4.3.RELEASE</version>
调整为<version>1.5.4.RELEASE</version>
然后重新打包，并启动