02、RocketMQ 实战 - Linux下安装RocketMQ 4.9.2
一、安装JDK1.8
RocketMQ是使用Java开发的，所以需要在Linux系统内安装JDK环境。主要有下面几个步骤：
- a. 从官网下载JDK1.8： Java Downloads | Oracle
- b. 将下载好的JDK安装包上传到Linux服务器中并解压缩，笔者这里是/java目录下
[admin@admin /]$ cd /java/
[admin@admin java]$ ll
total 143376
-rw-rw-r--. 1 admin admin 146815279 Feb 15 10:20 jdk-8u321-linux-x64.tar.gz
[admin@admin java]$ tar -zxvf jdk-8u321-linux-x64.tar.gz
- c. 解压缩完成后，会生成对应的【jdk1.8.0_321】目录，里面存放的是相关文件。假设这里我们将jdk安装在usr/java目录，那么我们需要将解压后的【jdk1.8.0_321】里面的所有数据移动到usr/java目录：
mkdir /usr/java
chmod 777 /usr/java
mv jdk1.8.0_321/ /usr/java/
- d. 修改环境变量
[admin@admin java]$ vim /etc/profile
用vim编辑器来编辑profile文件，在文件末尾添加以下内容（按“i”进入编辑）：
export JAVA_HOME=/usr/java/jdk1.8.0_321
export JRE_HOME=${JAVA_HOME}/jre
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib:$CLASSPATH
export JAVA_PATH=${JAVA_HOME}/bin:${JRE_HOME}/bin
export PATH=$PATH:${JAVA_PATH}
配置完使用:wq保存成后，我们通过命令source /etc/profile让profile文件立即生效：
[admin@admin java]$ source /etc/profile
- e. 测试是否安装成功
[admin@admin java]$ java
// 不会出现command not found错误
[admin@admin java]$ javac
// 不会出现command not found错误
[admin@admin java]$ java -version
// 能正常输出JDK对应版本号
二、安装RocketMQ
1、下载RocketMQ，这里我们以目前最新版本4.9.2为例，官网下载地址为：Apache Download Mirrors。这里我们直接下载编译好的二进制安装包，所以可以省去自己手动编译的过程，即【mvn -Prelease-all -DskipTests clean install -U】。
2、将下载好的rocketmq-all-4.9.2-bin-release.zip上传到Linux中。
3、解压rocketmq-all-4.9.2-bin-release.zip文件
[admin@admin rocketmq]$ unzip rocketmq-all-4.9.2-bin-release.zip
4、解压缩完成后，会生成【rocketmq-4.9.2】目录。进入【rocketmq-4.9.2】目录，然后我们修改broker.conf配置文件，追加下面两行配置：
[admin@admin rocketmq]$ cd rocketmq-4.9.2/
[admin@admin rocketmq-4.9.2]$ ll
total 144
drwxr-xr-x. 2 admin admin 126 Oct 22 13:56 benchmark
drwxr-xr-x. 3 admin admin 4096 Feb 15 13:57 bin
drwxr-xr-x. 6 admin admin 228 Feb 15 13:44 conf
-rw-rw-r--. 1 admin admin 19018 Feb 15 13:36 hs_err_pid2828.log
-rw-rw-r--. 1 admin admin 18969 Feb 15 13:36 hs_err_pid2854.log
-rw-rw-r--. 1 admin admin 18969 Feb 15 13:39 hs_err_pid3015.log
-rw-rw-r--. 1 admin admin 19018 Feb 15 13:41 hs_err_pid3060.log
-rw-rw-r--. 1 admin admin 19039 Feb 15 13:52 hs_err_pid3458.log
drwxr-xr-x. 2 admin admin 4096 Oct 22 13:56 lib
-rw-r--r--. 1 admin admin 17327 Oct 22 13:41 LICENSE
-rw-------. 1 admin admin 2956 Feb 15 14:00 nohup.out
-rw-r--r--. 1 admin admin 1338 Oct 22 13:41 NOTICE
-rw-r--r--. 1 admin admin 5342 Oct 22 13:41 README.md
[admin@admin rocketmq-4.9.2]$ cd conf
[admin@admin conf]$ ll
total 40
drwxr-xr-x. 2 admin admin 118 Oct 22 13:41 2m-2s-async
drwxr-xr-x. 2 admin admin 118 Oct 22 13:41 2m-2s-sync
drwxr-xr-x. 2 admin admin 91 Oct 22 13:41 2m-noslave
-rw-r--r--. 1 admin admin 999 Feb 15 13:44 broker.conf
drwxr-xr-x. 2 admin admin 72 Oct 22 13:41 dledger
-rw-r--r--. 1 admin admin 14978 Oct 22 13:41 logback_broker.xml
-rw-r--r--. 1 admin admin 3836 Oct 22 13:41 logback_namesrv.xml
-rw-r--r--. 1 admin admin 3761 Oct 22 13:41 logback_tools.xml
-rw-------. 1 admin admin 44 Feb 15 13:44 nohup.out
-rw-r--r--. 1 admin admin 1305 Oct 22 13:41 plain_acl.yml
-rw-r--r--. 1 admin admin 834 Oct 22 13:41 tools.yml
[admin@admin conf]$ vim broker.conf
// 10.0.90.59是笔者Linux的IP，读者朋友需要自行修改成自己的IP
namesrvAddr=10.0.90.59:9876
brokerIP1=10.0.90.59
如下图：
5、修改启动参数
这一步非必须，由于笔者使用的虚拟机，内存不太够，如果读者朋友觉得内存够的话，可以不修改。不过如果内存不够的话，启动broker也会报内存不足的错误。
我们需要两个启动脚本：runserver.sh 和 runbroker.sh
[admin@admin bin]$ vim /rocketmq/rocketmq-4.9.2/bin/runserver.sh
如下图，调整JAVA_OPT的内存大小：
[admin@admin bin]$ vim /rocketmq/rocketmq-4.9.2/bin/runbroker.sh
如下图，调整JAVA_OPT的内存大小：
三、启动RocketMQ
启动RocketMQ包括启动NameServer和Broker，先启动NameServer：
[admin@admin /]$ cd /rocketmq/rocketmq-4.9.2/
[admin@admin rocketmq-4.9.2]$ nohup sh bin/mqnamesrv -n 10.0.90.59:9876 &
[1] 4796
[admin@admin rocketmq-4.9.2]$ nohup: ignoring input and appending output to ‘nohup.out’
查看NameServer是否启动成功：
[admin@admin rocketmq-4.9.2]$ tail -f ~/logs/rocketmqlogs/namesrv.log
2022-02-15 14:47:00 INFO main - tls.client.keyPassword = null
2022-02-15 14:47:00 INFO main - tls.client.certPath = null
2022-02-15 14:47:00 INFO main - tls.client.authServer = false
2022-02-15 14:47:00 INFO main - tls.client.trustCertPath = null
2022-02-15 14:47:00 INFO main - Using JDK SSL provider
2022-02-15 14:47:02 INFO main - SSLContext created for server
2022-02-15 14:47:02 INFO main - Try to start service thread:FileWatchService started:false lastThread:null
2022-02-15 14:47:02 INFO NettyEventExecutor - NettyEventExecutor service started
2022-02-15 14:47:02 INFO main - The Name Server boot success. serializeType=JSON
2022-02-15 14:47:02 INFO FileWatchService - FileWatchService service started
[admin@admin rocketmq-4.9.2]$ jps
4817 NamesrvStartup
4853 Jps
可以看到，The Name Server boot success...，说明 Name Server启动成功，并且通过jps也能查到这个NamesrvStartup进程。
然后再启动Broker：
[admin@admin /]$ cd /rocketmq/rocketmq-4.9.2/
[admin@admin rocketmq-4.9.2]$ nohup sh bin/mqbroker -n 10.0.90.59:9876 -c conf/broker.conf autoCreateTopicEnable=true &
[1] 4902
[admin@admin rocketmq-4.9.2]$ nohup: ignoring input and appending output to ‘nohup.out’
查看Broker是否启动成功：
[admin@admin rocketmq-4.9.2]$ tail -f ~/logs/rocketmqlogs/broker.log
2022-02-15 14:51:17 INFO main - Try to start service thread:FileWatchService started:false lastThread:null
2022-02-15 14:51:17 INFO FileWatchService - FileWatchService service started
2022-02-15 14:51:17 INFO main - Try to start service thread:PullRequestHoldService started:false lastThread:null
2022-02-15 14:51:17 INFO PullRequestHoldService - PullRequestHoldService service started
2022-02-15 14:51:17 INFO main - Try to start service thread:TransactionalMessageCheckService started:false lastThread:null
2022-02-15 14:51:17 INFO brokerOutApi_thread_1 - register broker[0]to name server 10.0.90.59:9876 OK
2022-02-15 14:51:17 INFO main - The broker[admin.com, 10.0.90.59:10911] boot success. serializeType=JSON and name server is 10.0.90.59:9876
2022-02-15 14:51:26 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2022-02-15 14:51:26 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 191890 bytes
2022-02-15 14:51:27 INFO brokerOutApi_thread_2 - register broker[0]to name server 10.0.90.59:9876 OK
可以看到，The broker[admin.com, 10.0.90.59:10911] boot success，Broker也启动成功。通过jps也能查询到对应的进程：
[admin@admin rocketmq-4.9.2]$ jps
4817 NamesrvStartup
4993 Jps
4910 BrokerStartup
至此，RocketMQ就启动成功了，下面我们简单测试一下消息的发送以及消息的消费。
四、测试消息发送和消费
- 1、发送消息
[admin@admin rocketmq-4.9.2]$ export NAMESRV_ADDR=10.0.90.59:9876
[admin@admin rocketmq-4.9.2]$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
可以看到，消息发送成功。
- 2、消费消息
[admin@admin rocketmq-4.9.2]$ export NAMESRV_ADDR=10.0.90.59:9876
[admin@admin rocketmq-4.9.2]$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
可以看到，客户端成功接收到消息，进行消费。
五、关闭RocketMQ
关闭RocketMQ的时候，需要先先关闭Broker，然后再关闭Name Server。
- 1、关闭Broker
[admin@admin rocketmq-4.9.2]$ sh bin/mqshutdown broker
The mqbroker(4910) is running...
Send shutdown request to mqbroker(4910) OK
- 2、关闭Name Server
[admin@admin rocketmq-4.9.2]$ sh bin/mqshutdown namesrv
The mqnamesrv(4817) is running...
Send shutdown request to mqnamesrv(4817) OK
[1]+ Exit 143 nohup sh bin/mqbroker -n 10.0.90.59:9876 autoCreateTopicEnable=true
六、可视化管理页面安装
1、下载可视化管理页面插件，并上传到服务器中，然后解压缩
下载地址：https://github.com/rocketmq/rocketmq-externals
[admin@admin rocketmq]$ unzip rocketmq-externals-master.zip
解压缩完成后，会生成一个【rocketmq-externals-master】目录。
2、修改配置文件
[admin@admin rocketmq-externals-master]$ cd /rocketmq/rocketmq-externals-master/rocketmq-console/
[admin@admin rocketmq-console]$ ll
total 52
drwxrwxr-x. 3 admin admin 19 Mar 23 2018 doc
-rw-rw-r--. 1 admin admin 29843 Mar 23 2018 LICENSE
-rw-rw-r--. 1 admin admin 176 Mar 23 2018 NOTICE
-rw-rw-r--. 1 admin admin 11424 Mar 23 2018 pom.xml
-rw-rw-r--. 1 admin admin 2169 Mar 23 2018 README.md
drwxrwxr-x. 4 admin admin 30 Mar 23 2018 src
drwxrwxr-x. 3 admin admin 74 Mar 23 2018 style
[admin@admin rocketmq-console]$ vim src/main/resources/application.properties
主要是修改端口号和配置RocketMQ NameServer的地址：
3、手动打包生成可运行的Jar文件
进入rocketmq-console，跳过测试并打包：
[admin@admin rocketmq-console]$ pwd
/rocketmq/rocketmq-externals-master/rocketmq-console
[admin@admin rocketmq-console]$ mvn clean package -Dmaven.test.skip=true
打包完成后，在target目录下回生成一个可执行的Jar文件，如下图：
4、启动可视化页面
[admin@admin target]$ java -jar rocketmq-console-ng-1.0.0.jar
查看启动日志：
5、访问可视化页面
启动成功后，浏览器访问：http://10.0.90.59:1111/#/
可以看到，RocketMQ可视化管理页面就搭建成功了。至此，RocketMQ单机版的安装就安装成功了，接下来就可以愉快地学习RocketMQ啦。
七、遇到的问题
1、防火墙问题
读者朋友可以开放RocketMQ对应的端口监听，当然也可以直接关闭Centos的防火墙。
2、内存不足问题
修改bin目录下的runserver.sh和runbroker.sh两个文件中的JAVA_OPT启动参数的内存配置，调小一些即可。
3、启动Broker失败
检查broker.conf配置文件是否配置了NameServer的地址等，或者查看具体的日志看下什么原因。