阿里云官方文檔地址:
[https://help.aliyun.com/product/29530.html?spm=a2c4g.11186623.6.540.18dc4fedo9nsoQ](https://help.aliyun.com/product/29530.html?spm=a2c4g.11186623.6.540.18dc4fedo9nsoQ)
Demo地址:
[https://github.com/AliwareMQ/mq-demo](https://github.com/AliwareMQ/mq-demo)
1.**下載好Demo后,導入 java-tcp-demo項目**
**在 IntelliJ IDEA 界面,選擇 Open,選擇 java-tcp-demo文件夾。**

**若出現打開方式,選擇open as project,直到導入完成。 Demo 工程需要加載依賴的 JAR 包,因此導入過程需要等待 2-3 分鐘。**
2.**創建資源**
需要先到控制臺創建所需資源,包括消息隊列 RocketMQ 的實例、Topic、Group ID (GID),以及鑒權需要的 AccessKey(AK)。
更多詳細信息與操作指導:
[https://help.aliyun.com/document\_detail/34411.html?spm=a2c4g.11186623.2.17.6bdac931bF6gLn](https://help.aliyun.com/document_detail/34411.html?spm=a2c4g.11186623.2.17.6bdac931bF6gLn)
3.**完善配置MqConfig文件,**
按以下說明配置 MqConfig 類。
lpublic static final String TOPIC = “剛才創建的 Topic”;
lpublic static final String GROUP\_ID = “剛才創建的 Group ID”;
lpublic static final String ACCESS\_KEY = “您的阿里云賬號的 AccessKeyId”;
lpublic static final String SECRET\_KEY = “您的阿里云賬號的 AccessKeySecret”;
lpublic static final String NAMESRV\_ADDR = “您的消息隊列 RocketMQ 實例的 TCP 接入點,可在控制臺的實例管理的獲取接入點信息區域獲取 TCP 協議接入點“;
4.**選擇要測試的消息類型進行測試**;
運行 SimleMQProducer類發送消息。(發送普通消息)
登錄消息隊列 RocketMQ 控制臺,在左側導航欄選擇消息查詢 > 按 Topic 查詢,選擇 Topic 名稱進行查詢。可以看見消息已經發送至 Topic。
運行 SimpleMQConsumer 類接收消息。可以看到消息被接收打印的日志。因為有初始化,所以需等待幾秒,在生產環境中不會經常初始化。