RocketMQ 基本概念：https://www.jianshu.com/p/b43b00971d95

一、环境准备

1.1 JAVA环境

1.1.1 检查Java环境

（1）输入命令 Java -version
（2）显示jdk版本

1.1.2 下载JDK

如果没有java环境，需要下载安装。jdk11下载地址：
https://www.oracle.com/java/technologies/javase-jdk11-downloads.html
选择了如图安装包：

JDK11的Linux版本下载

由于Oracle官网下载JDK需要登录，所以需要下载后通过XFtp等工具上传到服务器：

上传安装包

1.1.3 安装JDK

1. 使用命令解压
   [ec2-user@ip-172-31-36-224 ~]$ sudo tar -zxvf jdk-11.0.9_linux-x64_bin.tar.gz
2. cd /etc/local，需要先sudo mkdir /ect/local
3. sudo mkdir java kidir java/jdk11
4. cd java/jdk11
5. 将解压后的jdk11.0.3下的所有文件移动到/etc/local/java/jdk11目录下
   sudo mv /home/ec2-user/jdk-11.0.9/* ./
6. 编辑属性文件sudo vim /etc/profile ,然后按insert
   文末添加内容

    JAVA_HOME=/etc/local/java/jdk11
    JRE_HOME=$JAVA_HOME/lib
    PATH=$JAVA_HOME/bin:$PATH
    export JAVA_HOME JRE_HOME PATH

添加后的示例如图：

7. 编辑好后
   按ESC,然后输入:wq，进行保存退出。
   注：我们在linux系统中更新了配置文件profile文件以后，并不会立即生效，需要我们执行一下相关的命令才会立即生效：
   • 方法一：让/etc/profile文件修改后立即生效 ,可以使用如下命令: # . /etc/profile 注意: . 和 /etc/profile 有空格；
   • 方法二：让/etc/profile文件修改后立即生效 ,可以使用如下命令: # source /etc/profile。
8. 测试安装的 java，如果看到如下信息证明成功。

[ec2-user@ip-172-31-36-224 ~]$ java -version
java version "11.0.9" 2020-10-20 LTS
Java(TM) SE Runtime Environment 18.9 (build 11.0.9+7-LTS)
Java HotSpot(TM) 64-Bit Server VM 18.9 (build 11.0.9+7-LTS, mixed mode)
[ec2-user@ip-172-31-36-224 ~]$ 

二、RocketMQ部署

2.1 下载rocketmq

可通过命令或者在官网下载：
wget http://mirrors.hust.edu.cn/apache/rocketmq/4.7.1/rocketmq-all-4.7.1-bin-release.zip下载。
官网：http://rocketmq.apache.org/dowloading/releases

官网下载

2.2 解压Rocketmq

输入命令 unzip rocketmq-all-4.6.0-bin-release.zip -d ./rocketmq
可将rocketmq解压到当前目录的rocketmq文件夹内.

[ec2-user@ip-172-31-36-224 ~]$ ll
total 190888
-rw-rw-r-- 1 ec2-user ec2-user 181608904 Nov  2 21:56 jdk-11.0.9_linux-x64_bin.tar.gz
-rw-rw-r-- 1 ec2-user ec2-user  13854396 Jun 29 01:52 rocketmq-all-4.7.1-bin-release.zip
[ec2-user@ip-172-31-36-224 ~]$ unzip rocketmq-all-4.7.1-bin-release.zip -d ./rocketmq

2.3 脚本方式安装（推荐）

上面2个步骤，也可以采用下面的脚本方式替代安装。
安装脚本：

ver=4.7.1
yum -y install zip unzip
wget -c http://mirrors.hust.edu.cn/apache/rocketmq/${ver}/rocketmq-all-${ver}-bin-release.zip -P /opt

unzip /opt/rocketmq-all-${ver}-bin-release.zip -d /data
rm -rf /opt/rocketmq
/bin/mv /opt/rocketmq-all-${ver}-bin-release /data/rocketmq

mkdir -p /opt/rocketmq/logs
mkdir -p /opt/rocketmq/store/{commitlog,consumequeue,index}

pushd /opt/rocketmq/conf
sed -i 's#${user.home}#/opt/rocketmq#g' *.xml
popd     

2.4 几个维护脚本

几个维护脚本，包括了启动nameserver、broker和停止这2个服务的脚本。

2.4.1 启动namesrv

sudo cat << EOF >> 1start_rocketmq_namesrv_single.sh
#!/bin/sh
sudo sh /data/rocketmq-all-4.7.1-bin-release/bin/mqnamesrv &
EOF

执行上面脚本会看到创建了sh文件1start_rocketmq_namesrv_single.sh：

[ec2-user@ip-172-31-36-224 rocketmq_sh]$ ll
total 12
-rwxrwxrwx 1 ec2-user ec2-user  71 Nov  3 04:11 1start_rocketmq_namesrv_single.sh

2.4.2 启动broker

sudo cat << EOF >> 2start_broker.sh
#!/bin/sh
sudo sh /data/rocketmq-all-4.7.1-bin-release/bin/mqbroker -n localhost:9876 -c /data/rocketmq-all-4.7.1-bin-release/conf/broker.conf autoCreateTopicEnable=true &
EOF

对应生成文件2start_broker.sh。命令后面的autoCreateTopicEnable=true表示可以自动创建Topic，正常来说默认就支持，如果发现调用有不能创建Topic的错误可以配置一下。

2.4.3 停止namesrv和broker

sudo cat << EOF >> 3shut_mqnamesrv.sh
cd /opt/rocketmq
sudo sh /data/rocketmq-all-4.7.1-bin-release/bin/mqshutdown broker
sudo sh /data/rocketmq-all-4.7.1-bin-release/bin/mqshutdown namesrv
EOF

对应文件3shut_mqnamesrv.sh。

注意：cat是在文件中添加内容，如果想修改内容，重复执行上面的命令会在文件中末尾追加内容，需要删除文件后重新执行上面的写入文件的操作。

2.5 踩坑

1. 当RocketMQ4.7.1遇到JDK11后却出现了无法启动nameserver的问题。
   原因就是RocketMQ仍然是按着JDK8的配置做为启动的。以下脚本修改配置文件支持jdk11。

cd /home/ec2-user/rocketmq/rocketmq-all-4.7.1-bin-release

pushd bin
sed -i 's#-XX\:+UseConcMarkSweepGC##g' runserver.sh
sed -i 's#-XX\:+UseCMSCompactAtFullCollection##g' runserver.sh
sed -i 's#-XX\:+PrintGCDetails##g' runserver.sh
sed -i 's#-XX\:-UseParNewGC##g' runserver.sh
sed -i 's#-Xloggc\:#-Xlog\:gc\:#g' *.sh
sed -i 's#-XX\:+PrintGCDateStamps##g' runbroker.sh
sed -i 's#-XX\:+PrintGCApplicationStoppedTime##g' runbroker.sh
sed -i 's#-XX\:+PrintAdaptiveSizePolicy##g' runbroker.sh
sed -i 's#-XX\:+PrintGCDetails##g' runbroker.sh
sed -i '/UseGCLogFileRotation/d' *.sh
sed -i '/java.ext.dirs/d' *.sh
popd

2. 如果启动报错需要配置JAVA_HOME
   修改bin目录下文件：runbroker.sh、runserver.sh、tools.sh。

• 将其中的这三行注释掉：

[ ! -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)!"

• 将 export JAVA_HOME替换为export JAVA_HOME=你的JAVA_HOME路径
  修改Java home
  3.如果提示错误：

[ec2-user@ip-172-31-36-224rocketmq-all-4.7.1-bin-release]$sudo sh bin/mqnamesrv
[0.023s][info][gc]UsingG1
Error:Couldnotfindorloadmainclassorg.apache.rocketmq.namesrv.NamesrvStartup
Causedby:java.lang.ClassNotFoundException:org.apache.rocketmq.namesrv.NamesrvStartup

• 将CLASSPATH修改：
  export CLASSPATH=${BASE_DIR}/lib/rocketmq-broker-4.7.0.jar:${BASE_DIR}/lib/*:${BASE_DIR}/conf:${CLASSPATH}