RocketMQ——安装RocketMQ详解编程语言

本文在Linux环境下安装RocketMQ
RocketMQ 4.x以上版本安装需要JDK1.8 +， Maven

首先在官网下载RocketMQ的源码包，如果没有安装Maven，首先使用wget https://mirrors.tuna.tsinghua.edu.cn/apache/maven/maven-3/3.6.3/binaries/apache-maven-3.6.3-bin.tar.gz下载maven，如果没有wget命令，先使用yum -y install wget安装wget命令，安装完maven后，修改conf文件夹下的settings.xml。由于原始mirror速度过慢，在mirror配置项中删除原始mirror，加入阿里云的镜像

	 <mirror> 
        <id>aliyun-maven</id> 
        <mirrorOf>*</mirrorOf> 
        <name>aliyun maven</name> 
        <url>http://maven.aliyun.com/nexus/content/groups/public</url> 
     </mirror> 

效果如下

修改/etc/profile，将maven加入环境变量并source生效

使用unzip解压刚才的Rocket源码包unzip rocketmq-all-4.6.1-source-release.zip，没有unzip命令使用yum -y install unzip下载该命令

进入到RocketMQ主目录，使用mvn -Prelease-all -DskipTests clean install -U编译，编译完成之后，最终我们需要的文件夹是/opt/rocketmq-source/distribution/target/rocketmq-4.6.1目录下的rocketmq-4.6.1，读者可以将其移动到自己想要的位置进行使用。同样我们可以配置其环境变量，以便使用bin下的命令

使用mqnamesrv启用NameServer，使用mqbroker启动broker。现在可以启动nameserver了，但是在启动mqbroker会无法分配内存的错。实际上这两个命令会分别调用runserver和runbroker两个命令。

我们使用vi进入到runserver观察，发现JVM参数在内存配置时设置了4g，这可能不满足我们虚拟机配置，但是集群会使用虚拟内存。进入runbroker则会发现配置了8g，我们将配置稍微改小一点-Xms512m -Xmx215m -Xmn128m.

这时我们使用启动mqbroker -n localhost:9876启动broker就成功了，后面的ip地址表示当前的broker要连接到哪个nameserver上

RocketMQ还有一个图形界面方便我们观察当前MQ信息下载地址
下载解压后进入rocketmq-console文件夹，使用mvn clean package -Dmaven.test.skip=true进行编译，编译成功后会得到rocketmq-console-ng-1.0.1.jarjar包，将它移动到你想使用它的地方，使用java -jar rocketmq-console-ng-1.0.1.jar --rocketmq.config.namesrvAddr=127.0.0.1:9876启动，在网页访问8080端口就可以看见了，后面的ip地址是要连接的nameserver的地址

关闭RocketMQ的命令分别是mqshutdown namesrv和mqshutdown broker