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
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
默認內存太大了
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
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…
在首發消息之前,需要設置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終止。
先關閉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]#
版权声明:本站所有资料均为网友推荐收集整理而来,仅供学习和研究交流使用。
工作时间:8:00-18:00
客服电话
电子邮件
admin@qq.com
扫码二维码
获取最新动态