Linux下安装RocketMQ-蒲公英云

RocketMQ安装前准备:

建议使用64位操作系统，Linux / Unix / Mac;本人使用的是CentOS7，你当然也可以使用小红帽或者UBuntu。
64位JDK 1.8+;RocketMQ4.3.x之后都是使用jdk1.8+，所以你得保证你得安装环境必须装有jdk1.8+
Maven 3.2.x；Maven工具其实不一定需要使用的，但是也建议大家在安装环境下配置好Maven3.3.9+
4g+内存用于Broker服务器, RocketMQ定位是分布式消息中间件，属重量级应用，所以它是比较吃内存的。但是如果你只是想在本地尝试一下搭建流程，或者你是想在自己的虚拟机上搭建一个对性能没什么要求的测试服务器，那么你可以只为这个虚拟机分配1.5g + 的内存。当然，低内存就代表着低性能，而且RocketMQ在低内存下运行是相对容易出错的，具体的内存分配，看你个人情况而定。
本次安装的是单机版本

安装环境配置:

[注]:这里需要注意一下，在配置jdk1.8和maven的过程中，都需要在 /etc/profile 目录下配置他们的环境变量，并将java_home和maven_home都配置到 PATH 变量上，千万不要配置两个PATCH，否则可能会出现预料之外的情况，具体配置可以参考本人的PATCH变量: export PATH=$PATH:${JAVA_PATH}:$MAVEN_HOME/bin

以后如果有更多的环境变量配置，就在PATCH变量值的后面加上 :${XXX_HOME}/bin 即可。注意，Linux下的环境变量之间用冒号隔开

一、下载RocketMQ到安装环境下:

好了，终于开始正式安装RocketMQ了。

首先我们需要下载RocketMQ的安装包：RocketMQ4.3.1 然后将安装包上传到Linux服务器。

当然，你也可以直接用wget命令在Linux系统上直接下载安装包:

wget http://mirrors.hust.edu.cn/apache/rocketmq/4.3.1/rocketmq-all-4.3.1-bin-release.zip

如果你还没有安装wget，可以使用下面命令完成安装

yum -y install wget

#

二、完成RocketMQ的安装和配置

2.1 将安装文件解压到安装目录下,这里将它安装到usr/local下

unzip rocketmq-all-4.3.1-bin-release.zip -d /usr/local

如果没有unzip命令，可以使用yum命令安装: yum install unzip

解压完之后，可以看到usr/local目录下多了个文件夹 -> rocketmq-all-4.3.1-bin-release，由于文件名太长，决定使用 ln命令给这个目录映射一个简短的新名字:

ln -s rocketmq-all-4.3.1-bin-release rocketmq

这样以后配置文件目录时只需要配置rocketmq即可替代rocketmq-all-4.3.1-bin-release

2.2 创建文件存储目录

mkdir /usr/local/rocketmq/store
mkdir /usr/local/rocketmq/store/commitlog
mkdir /usr/local/rocketmq/store/consumequeue
mkdir /usr/local/rocketmq/store/index

2.3 修改配置文件

vim /usr/local/rocketmq/conf/2m-noslave/broker-a.properties

可以看到界面如下:

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pqcTg1MjUzMzQ0NQ_size_16_color_FFFFFF_t_70

这里建议将默认配置删除。

我这里贴出一份本人的配置文件[配置参考网络]

## 配置broker的配置文件##
## 集群名称
brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样 
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址，如果mq部署在局域网上，则用局域网ip，如果是在阿里云上，配置成阿里云外网ip
namesrvAddr=192.168.1.10:9876
## broker ip地址
brokerIP1=192.168.1.10
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口
listenPort=10911
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120 
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824 
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
##设置的磁盘最大利用率。默认是75
diskMaxUsedSpaceRatio=75
#存储路径
storePathRootDir=/usr/local/rocketmq/store
#commitLog 存储路径
storePathCommitLog=/usr/local/rocketmq/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue
#消息索引存储路径
storePathIndex=/usr/local/rocketmq/store/index
#checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/store/index/checkpoint
#abort 文件存储路径
abortFile=/usr/local/rocketmq/store/index/abort
#限制的消息大小 建议 65536
maxMessageSize=10240
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVE
brokerRole=ASYNC_MASTER
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
#发消息线程池数量 128
#sendMessageThreadPoolNums=64
#拉消息线程池数量 128
#pullMessageThreadPoolNums=64

2.4 修改日志配置:

mkdir -p /usr/local/rocketmq/logs
cd /usr/local/rocketmq/conf && sed -i 's#${user.home}#/usr/local/rocketmq#g' *.xml

第二个命令可分为两部分: 首先cd /usr/local/rocketmq/conf 自是进入rocketmq的config目录下，然后sed -i ‘s#${user.home}#/usr/local/rocketmq#g’ *.xml 是为了将conf目录下所有的xml文件中的 ${user.home}内容修改为 /usr/local/rocketmq

命令修改前的配置如下:

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pqcTg1MjUzMzQ0NQ_size_16_color_FFFFFF_t_70 1

可以看到RocketMQ的日志文件默认是打印到user.home目录下。

我们执行sed 命令后，改变日志的输出路径:

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pqcTg1MjUzMzQ0NQ_size_16_color_FFFFFF_t_70 2

这样日志就会打印到RocketMQ安装目录下。其实也可以不改，这个要看个人的习惯,不改的话默认打印到user.home下，比如你说root用户，日志就会在/root/logs下。

2.5 修改启动命令

到了这一步其实已经可以启动了，但是如果你的安装环境内存不够的话，必须要修改了启动参数才能正常运行.

2.5.1 修改broker启动参数*

vim /usr/local/rocketmq/bin/runbroker.sh

修改java-configuration :

JAVA_OPT=”${JAVA_OPT} -server -Xms256m -Xmx512m -Xmn256” 修改堆内存的配置

25.2 修改server的启动参数

vim /usr/local/rocketmq/bin/runserver.sh

JAVA_OPT=”${JAVA_OPT} -server -Xms256m -Xmx512m -Xmn256m -XX:MetaspaceSize=64m -XX:MaxMetaspaceSize=128m”

上述配置的参数值仅仅是为了降低内存占用而设，其值没有其他参考价值

三、正式启动RocketMQ

3.1 进入RocketMQ的bin目录下

cd /usr/local/rocketmq/bin

3.2 启动nameserver

nohup sh mqnamesrv &

至于为什么要用nohup和&, nohup 命令用途是:不挂断地运行命令，& 放在命令后面表示设置此进程为后台进程。

这里可以用jps查看nameserver的启动情况，如果出现如下的界面，说明已经启动成功

注：在启动nameserver的过程中，有时会让当前命令行界面丢失，无法输入指令。如图:

这时候只能新开一个窗口来执行后面的操作

3.3 启动broker

nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-noslave/broker-a.properties >/dev/null 2>&1 &

使用jsp命令查看程序运行情况:

可以看到，broker已经启动起来了

3.4 查看RocketMQ的broker日志和namesrv日志:

tail -f -n 500 /usr/local/rocketmq/logs/rocketmqlogs/broker.log
tail -f -n 500 /usr/local/rocketmq/logs/rocketmqlogs/namesrv.log

3.5关闭nameserver和broker命令

关闭nameserver服务

sh mqshutdown namesrv

关闭broker服务

sh mqshutdown broker

四、使用Tomcat部署RocketMQ的控制台

4.1 首先下载RocketMQ的控制台扩展

下载地址//github.com/apache/rocketmq-externals/tree/rocketmq-console-1.0.0

这里需要注意的是，我们这里下载的是rocketmq-externals项目的1.0.0分支，这个分支亲测可以正常运行，但是rocketmq-externals项目的master分支项目你想要运行起来还是比较麻烦的，博主就搞了很久，比如在对master分支下的项目下载到本地后，找到rocketmq-console项目，执行mvn package的时候就报jar报miss异常，没办法只能将4.3.1版本的jar包导入，却发现和mater分支下的代码不兼容，项目直接报错，启动不起来。额…最后balabalabal一顿操作，还是没有解决问题，实在是惭愧…

4.2 配置console项目的application.properties文件

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pqcTg1MjUzMzQ0NQ_size_16_color_FFFFFF_t_70 3