連接實例
更新時間 2023-07-03 20:54:20
最近更新時間: 2023-07-03 20:54:20
分享文章
場景說明
RocketMQ提供了兩種連接:
- 生產者連接:生產者通過調用RocketMQ提供的API,與RocketMQ代理(Broker)建立連接。生產者連接主要用于發送消息到RocketMQ。
- 消費者連接:消費者通過調用RocketMQ提供的API,與RocketMQ代理(Broker)建立連接。消費者連接主要用于從RocketMQ訂閱消息并進行消費。
RocketMQ采用基于TCP/IP的通信協議,使用長連接方式進行連接。在建立連接之前,需要配置正確的RocketMQ服務端地址和端口,并使用相應的身份驗證信息(如AccessKey和SecretKey)進行認證。
建立連接后,RocketMQ客戶端可以通過連接發送消息到RocketMQ集群,并從集群中接收消息進行消費。連接的建立和維護是RocketMQ消息傳遞的基礎,確保了消息的可靠傳遞和高效處理。
操作步驟
首先需要在RocketMQ控制臺實例詳情記錄下集群的接入點信息,目前支持namesrv的內網訪問,將該地址作為客戶端程序namesrv地址的參數,具體生產消費消息的客戶端示例代碼請參考快速入門-生產消費驗證。
1、 天翼云官網點擊控制中心,選擇產品分布式消息服務RocketMQ。
2、 登錄分布式消息服務RocketMQ控制臺,點擊右上角地域選擇對應資源池。
進入實例列表,點擊【管理】按鈕進入管理菜單。
3、 進入實例列表,點擊【管理】按鈕進入管理菜單。
4、 進入主題管理菜單,點擊【撥測】按鈕,進行生產消費的撥測驗證,驗證開通的消息實例和主題。
5、 用戶應用按照規范接入RocketMQ,發送、消費消息。