Mac安裝RocketMQ4.9.2&RocketMQ-console

安裝rocketmq

依賴JDK，版本要求

1、下載

下載地址：

https://rocketmq.apache.org/dowloading/releases/

點擊下載

下載成功

解壓

unzip rocketmq-all-4.9.1-bin-release.zip

2、修改配置文件

vim rocketmq-all-4.9.1-bin-release/conf/broker.conf
# 添加如下配置
brokerIP1 = 127.0.0.1
brokerIP2 = 127.0.0.1
namesrvAddr = 127.0.0.1:9876

結果如下

3、修改腳本

bin/runbroker.sh

bin/runserver.sh

bin/tools.sh

4、啟動

cd rocketmq-4.9.2/bin/

啟動NameServer

nohup sh mqnamesrv &> /dev/null &
# 查看日志
tail -f ~/logs/rocketmqlogs/namesrv.log

結果如下

啟動Broker

nohup sh mqbroker -n localhost:9876 &> /dev/null &
# 查看日志
tail -f ~/logs/rocketmqlogs/broker.log

結果如下

查看啟動情況

5、測試

設置環境變量

# 設置環境變量 

export NAMESRV_ADDR=localhost:9876

使用安裝包的Demo測試發送消息

sh tools.sh org.apache.rocketmq.example.quickstart.Producer

結果如下

使用安裝包的Demo測試消費消息

sh tools.sh org.apache.rocketmq.example.quickstart.Consumer

結果如下

PS：使用SpringBoot整合RocketMQ的時候引入的客戶端依賴版本要和服務端保持一致

<dependency>
      <groupId>org.apache.rocketmq</groupId>
      <artifactId>rocketmq-spring-boot-starter</artifactId>
      <version>2.2.1</version>
</dependency>

其對應的RocketMQ-client的版本為：

安裝rocketmq-console

1、下載

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

點擊下載rocketmq-console

2、解壓

3、用IDEA打開rocketmq-console

PS：也可以直接打成jar包用java -jar運行

然后修改端口和namesrv

然后啟動（運行App），訪問

http://localhost:8911/