2.安裝

2.1.源碼安裝

2.1.1.安裝maven
上傳解壓
Mkdir /home/maven
Cd /home/maven
Rz D:\javasoftware\maven\apache-maven-3.5.2-bin.tar.gz
Tar -zxf apache-maven-3.5.2-bin.tar.gz

配置環境變量
Vim /etc/profile，添加
export PATH=/home/maven/apache-maven-3.5.2/bin:$PATH

:wq，保存
Source /etc/profile，重啟

測試
Mvn -v

2.1.2.安裝rocketmq
下載源碼包rocketmq-all-4.2.0-source-release.zip
上傳到服務器

安裝。Unzip rocketmq-all-4.2.0-source-release.zip

cd rocketmq-all-4.2.0/

mvn -Prelease-all -DskipTests clean install -U， 安裝
這一步要下載很多jar包，安裝十幾個模塊，裝了半個小時，太費時間了。

Distribution模塊多了target目錄，
[root@localhost rocketmq-all-4.2.0]# cd distribution/
[root@localhost distribution]# ll
total 56
drwxr-xr-x. 2 root root 4096 Dec 13 22:12 benchmark
drwxr-xr-x. 2 root root 4096 Dec 13 22:12 bin
drwxr-xr-x. 5 root root 4096 Dec 13 22:12 conf
-rw-r–r--. 1 root root 17336 Dec 13 22:12 LICENSE-BIN
-rw-r–r--. 1 root root 1337 Dec 13 22:12 NOTICE-BIN
-rw-r–r--. 1 root root 4885 Dec 13 22:12 pom.xml
-rw-r–r--. 1 root root 2133 Dec 13 22:12 release-client.xml
-rw-r–r--. 1 root root 2990 Dec 13 22:12 release.xml
drwxr-xr-x. 6 root root 4096 Apr 25 17:38 target
[root@localhost distribution]# cd target/
[root@localhost target]# ll
total 17768
drwxr-xr-x. 6 root root 4096 Apr 25 17:38 apache-rocketmq
-rw-r–r--. 1 root root 9058025 Apr 25 17:38 apache-rocketmq.tar.gz
-rw-r–r--. 1 root root 9098504 Apr 25 17:38 apache-rocketmq.zip
drwxr-xr-x. 2 root root 4096 Apr 25 17:36 archive-tmp
-rw-r–r--. 1 root root 87 Apr 25 17:38 checkstyle-cachefile
-rw-r–r--. 1 root root 6066 Apr 25 17:38 checkstyle-checker.xml
-rw-r–r--. 1 root root 83 Apr 25 17:38 checkstyle-result.xml
drwxr-xr-x. 2 root root 4096 Apr 25 17:36 effective-pom
drwxr-xr-x. 3 root root 4096 Apr 25 17:36 maven-shared-archive-resources
[root@localhost target]# cd apache-rocketmq
[root@localhost apache-rocketmq]# ll
total 44
drwxr-xr-x. 2 root root 4096 Apr 25 17:38 benchmark
drwxr-xr-x. 2 root root 4096 Apr 25 17:38 bin
drwxr-xr-x. 5 root root 4096 Dec 13 22:12 conf
drwxr-xr-x. 2 root root 4096 Apr 25 17:38 lib
-rw-r–r--. 1 root root 17336 Dec 13 22:12 LICENSE
-rw-r–r--. 1 root root 1337 Dec 13 22:12 NOTICE
-rw-r–r--. 1 root root 2426 Dec 13 22:12 README.md
cd distribution/target/apache-rocketmq/bin

2.2.二進制解壓包安裝

Rz rocketmq-all-4.2.0-bin-release.zip
unzip rocketmq-all-4.2.0-bin-release.zip -d rocketmq-all-4.2.0-bin-release
Unzip默認把里面內容解壓到當前文件夾，-d，解壓到指定文件夾。
cd rocketmq-all-4.2.0-bin-release/bin

2.3.啟動

2.3.1.啟動name server

默認內存太大了
cat mqnamesrv

rocketmq 安裝、內部調用runserver.sh

cat runserver.sh

修改成

nohup sh mqnamesrv &，不好，按下enter才會輸入下一個命令。
nohup sh mqnamesrv > /dev/null 2>&1 &，這個好，可以直接輸入其他命令。
在當前目錄，多出來nohup.out文件，
在~/logs/rocketmqlogs/多出來namesrv.log文件，

tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success…

Jps，發現進程NamesrvStartup
[root@localhost bin]# jps
2285 NamesrvStartup
2302 Jps

2.3.2.啟動broker

rocketmq配置、nohup sh mqbroker -n localhost:9876 &

Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000005c0000000, 8589934592, 0) failed; error='Cannot allocate memory' (errno=12)
#
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 8589934592 bytes for committing reserved memory.
# An error report file with more information is saved as:
# /home/rocketmq/rocketmq-all-4.2.0/distribution/target/apache-rocketmq/bin/hs_err_pid4813.log

內存需要8G，沒搞錯吧。

分析原因：
Cat mqbroker

內部調用runbroker.sh，

Cat runbroker.sh

初始內存8G，

Rocketmq？修改成
-Xms256m -Xmx256m -Xmn128m"

再次啟動就成功了，
[root@localhost bin]# nohup sh mqbroker -n localhost:9876 &
[2] 2313
nohup: ignoring input and appending output to `nohup.out’

Jps，發現進程BrokerStartup
[root@localhost bin]# jps
2320 BrokerStartup
2377 Jps
2285 NamesrvStartup

tail -f ~/logs/rocketmqlogs/broker.log
The broker[%s, 172.30.30.233:10911] boot success…

2.3.3.收發消息

在首發消息之前，需要設置name server的值，
export命令用于將shell變量輸出為環境變量，或者將shell函數輸出為環境變量。

export NAMESRV_ADDR=localhost:9876

rocketmq配置詳解？./tools.sh org.apache.rocketmq.example.quickstart.Producer
SendResult [sendStatus=SEND_OK, msgId=AC112A010963330BEDB48860DA700000, offsetMsgId=AC112A0100002A9F00000000000230F0, messageQueue=MessageQueue [topic=TopicTest, brokerName=localhost, queueId=0], queueOffset=199]
死循環發送消息，ctrl+c終止。

./tools.sh org.apache.rocketmq.example.quickstart.Consumer
ConsumeMessageThread_16 Receive New Messages: [MessageExt [queueId=2, storeSize=180, queueOffset=185, sysFlag=0, bornTimestamp=1524724087840, bornHost=/192.168.5.128:35493, storeTimestamp=1524724087849, storeHost=/172.17.42.1:10911, msgId=AC112A0100002A9F0000000000020828, commitLogOffset=133160, bodyCRC=1996742104, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message [topic=TopicTest, flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=200, CONSUME_START_TIME=1524800117986, UNIQ_KEY=AC112A010E09330BEDB483D9C8200065, WAIT=true, TAGS=TagA}, body=18]]]
死循環發送消息，ctrl+c終止。

2.3.4.關閉

先關閉broker，后關閉namesrv。
[root@localhost bin]# sh mqshutdown broker
The mqbroker(2364) is running…
Send shutdown request to mqbroker(2364) OK

[root@localhost bin]# sh mqshutdown namesrv
The mqnamesrv(2247) is running…
Send shutdown request to mqnamesrv(2247) OK
[2]+ Exit 143 nohup sh mqbroker -n localhost:9876
[root@localhost bin]#