1.將安裝包上傳到linux系統中
這里我在usr/local目錄下新建了一個目錄叫soft用來存放各種安裝包
Rocketmq也上傳到soft目錄中.
2. 解壓安裝包
[root@superj soft]# unzip rocketmq-all-4.4.0-bin-release.zip
目錄結構:
3.將rmq安裝到指定文件夾
這里我在usr/local目錄中新建一個文件夾 rocketmq
在local目錄下,執行指令: mkdir rocketmq
回到剛剛rocketmq安裝包所在目錄(soft),將安裝包剪切到rocketmq目錄中
4.啟動rocketmq
1)啟動nameserver
1⃣️啟動NameServer
nohup sh bin/mqnamesrv &
2⃣️查看啟動日志
tail -f ~/logs/rocketmqlogs/namesrv.log
輸入命令后,沒反應?
配置下jdk環境變量和rocketmq環境變量
①通過 vim ~/.bash_profile 命令打開 .bash_profile,如果沒有該文件可以通過 touch ~/.bash_profile 命令創建.添加如下配置,其中 jdk 的位置填入第一步中你自己查找出的 jdk 的位置
export JAVA_HOME=/usr/local/ jdk1.8.0_171
使用 source ~/.bash_profile 命令使配置生效
②修改 RocketMQ 的 bin 目錄下的 runserver.sh 和 runbroker.sh,將設置 JAVA_HOME 的第二三行注釋掉,把第一行 JAVA_HOME 設置為jdk 的安裝目錄,如下所示
[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME= /usr/local/jdk1.8.0_171
# [ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java
# [ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!"
RocketMQ默認的虛擬機內存較大,也可能造成啟動失敗,將虛擬內存調小一些
配置mq的環境變量並使其生效
echo "ROCKETMQ_HOME=`pwd`" >> ~/.bash_profile
source ~/.bash_profile
再啟動就成功了,日志如下
通過jps命令可以查看當前有哪些進程
💡Tips:
除了通過命令行查看日志,還可以通過notepad++ 安裝插件也能連接linux服務器哦,連接上之后就能直接在里面查看日志了
配置連接
連接到遠程
2) 啟動Broker
1⃣️啟動Broker
nohup sh bin/mqbroker -n localhost:9876 &
2⃣️查看啟動日志
tail -f ~/logs/rocketmqlogs/broker.log
查看進程,都有,說明啟動成功
5.關閉rocketmq
1⃣️關閉NameServer
sh bin/mqshutdown namesrv
2⃣️關閉Broker
sh bin/mqshutdown broker
6.測試rocketmq
1)首先克隆一個進程,一個窗口用來發消息,一個窗口用來接收消息
這里用的ftp工具,右鍵克隆一個新窗口
將兩個窗口都進入到rocketmq的bin目錄內
2)發送消息
1⃣️設置臨時環境變量
export NAMESRV_ADDR=localhost:9876
2⃣️使用安裝包的Demo發送消息(如果在bin目錄下了,就去掉指令中的bin/)
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
3)接收消息
1⃣️設置環境變量
export NAMESRV_ADDR=localhost:9876
2⃣️接收消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
疑問???
為啥總有一個窗口報錯 說沒配置jdk環境變量呢?
克隆的那一個發消息成功了,只能也用這同一個窗口嘗試接消息,也成功了