linux下安装rocketmq

这里以在ubuntu18.04上安装为例，来说明安装单个实例rocketmq的过程和验证情况。

安装

下载

下载地址如下，选择想要下载的版本即可：
http://rocketmq.apache.org/release_notes/

解压

在自己的环境安装目录下解压

1	$ unzip rocketmq-all-4.5.2-bin-release.zip

启动服务

启动`namesrv`

namesrv的默认启动申请的jvm内存是信息如下：

1	JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

可以根据实际环境进行调整，如果是在自己的开发本启动，不进行调整的话内存自然不够用。修改jvm配置

1	vim bin/runserver.sh

启动namesrv服务：

1
2
3

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

启动`broker`

broker的默认启动申请的jvm内存为8g，信息如下：

1	JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"

同样需要根据实际环境进行调整，修改jvm配置：

1	vim bin/runbroker.sh

启动broker服务，并且指定namesrv服务：

1
2
3

$ nohup ./bin/mqbroker -n localhost:9876 &
$ tail -f ~/logs/rocketmqlogs/broker.log
The broker[cc-ubuntu, 192.168.1.4:10911] boot success.

启动成功后，便可以在日志文件中看到broker初始化配置信息的过程日志，同时还向namesrv中进行注册。

验证服务

服务启动成功验证

在启动的时候已用查看日志的方式进行了验证，但由于是java服务，除了可以通过启动日志来看服务是否启动成功外，亦可以查看java进程的方式来判断，如下所示：

1
2
3

$ jps -l
14257 org.apache.rocketmq.namesrv.NamesrvStartup
14548 org.apache.rocketmq.broker.BrokerStartup

服务可用验证

设置临时的namesrv环境变量：

1	export NAMESRV_ADDR=localhost:9876

利用官方提供的工具发送消息和消费消息来验证，可以看到正常的完成消息发送和消息消费。

$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
SendResult [sendStatus=SEND_OK, msgId= ...

$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
ConsumeMessageThread_%d Receive New Messages: [MessageExt...

web控制台安装

下载rocketmq-externals:
https://github.com/apache/rocketmq-externals/

然后进行解压，并且编译打包：

$ unzip rocketmq-externals-master.zip
$ cd rocketmq-externals-master/rocketmq-console/
$ mvn clean package -Dmaven.skip.test=true
>>>
[INFO] BUILD SUCCESS

拷贝jar包到合适的路径，启动程序（指定namesrv地址和服务端口）：

1	nohup java -jar rocketmq-console-ng-1.0.1.jar --server.port=19876 --rocketmq.config.namesrvAddr=localhost:9876 &

访问http://localhost:19876/#/即可看到控制台界面：

rocketmq-console

关闭服务

关闭broker

1
2
3

$ ./bin/mqshutdown broker
The mqbroker(3082) is running...
Send shutdown request to mqbroker(3082) OK

关闭namesrv

1
2
3

$ ./bin/mqshutdown namesrv
The mqnamesrv(3019) is running...
Send shutdown request to mqnamesrv(3019) OK

安装

下载

解压