最近由於工作需要開始學習訊息中介軟體rocketmq

首先，介紹一下rocketmq的安裝。

1.解壓rocketmq

2.新解壓的rocketmq是沒有執行許可權的，需要修改檔案許可權。

3.修改runbroker.sh和runserver.sh的記憶體設定，因為這兩個檔案啟動時預設記憶體比較大。具體根據電腦配置進行修改。兩個檔案的修改結果相同，結果如下

4.後臺啟動mqnamesrv，其實啟動的是runserver.sh。

啟動命令：nohup ./mqnamesrv &

5.後臺啟動mqbroker，其實啟動的是runbroker.sh。

啟動命令：nohup sh mqbroker -n "rocketmq伺服器ip地址:9876" -c ../conf/2m-noslave/broker-a.properties > broker.out &

6.檢視當前namesvr管理的broker

命令：./mqadmin clusterList -n  rocketmq的IP地址:9876

此時已經完成了rocketmq的安裝和啟動。

Java中rocketmq的呼叫。

1.匯入rocketmq需要的jar包

<!-- https://mvnrepository.com/artifact/com.alibaba.rocketmq/rocketmq-common -->
<dependency>
    <groupId>com.alibaba.rocketmq</groupId>
    <artifactId>rocketmq-common</artifactId>
    <version>3.2.6</version>
</dependency>

2.訊息生產者程式碼

3.訊息消費者，有兩種：pullConsumer 和pushConsumer，這裡用的是pushConsumer

4.此時訊息生產者可以直接產生訊息，訊息消費者可以直接取出訊息進行消費