1、mq硬件要求

Linux安裝rocketmq_#運維

2、下載mq

  • 鏡像站
  • https://mirrors.aliyun.com/apache/rocketmq/
  • 官網 https://rocketmq.apache.org/download

3、上傳到虛擬機，解壓，重命名

Linux安裝rocketmq_官網_02

4、修改內存

修改runserver內存

Linux安裝rocketmq_apache_03

Linux安裝rocketmq_#運維_04

修改runbroker內存

Linux安裝rocketmq_#服務器_05


Linux安裝rocketmq_#服務器_06

5、啓動mq

官網有啓動命令

  • 官網有啓動命令
### Start the namesrv service
$ nohup sh bin/mqnamesrv &
 
### Verify that the namesrv service is started successfully
$ tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success...
### Start the broker service
$ nohup sh bin/mqbroker -n localhost:9876 &

### Verify that the broker service is started successfully, for example, the broker's ip is 192.168.1.2 and the name is broker-a
$ tail -f ~/logs/rocketmqlogs/broker.log 
The broker[broker-a,192.169.1.2:10911] boot success...

啓動nameserver

  • 執行啓動命令，注意執行命令時的目錄
  • 執行查看日誌命令，看到啓動成功

啓動broker

  • 執行啓動命令
  • 執行查看日誌命令，看到啓動成功

查看進程

Linux安裝rocketmq_#運維_07

nameserver和broker的作用

Linux安裝rocketmq_#服務器_08

Linux安裝rocketmq_#服務器_09

6、測試消息的生產消費

$ 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...

Linux安裝rocketmq_#運維_10


Linux安裝rocketmq_apache_11


Linux安裝rocketmq_#運維_12


Linux安裝rocketmq_官網_13

7、關閉mq

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

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

Linux安裝rocketmq_#運維_14