消息隊列RocketMQ版是阿里云基于Apache RocketMQ構建的低延遲、高并發、高可用、高可靠的分布式消息中間件。

參數說明

參數 描述 類型 是否必須 默認值
TCP接入點 TCP協議接入點,從消息隊列RocketMQ控制臺的實例詳情頁面獲取。 String
AccessKey 您的AccessKey ID,用于身份認證。 String
AccessKey Secret 您的AccessKey Secret,用于身份認證。 String

訂閱消息

參數 描述 類型 是否必須 默認值
Topic 訂閱消息的主題名。 String
consumerGroup 消費者的Group ID,可在RocketMQ版控制臺創建。 String
subExpression 消息過濾表達式,滿足表達式的消息才會被訂閱。
說明 僅支持或運算,如tag1 || tag2 || tag3,如果設置為空和星號(*),則表示全部訂閱。
String
messageModel 消費模式。
  • CLUSTERING:集群消費模式。
  • BROADCASTING:廣播消費模式。
String CLUSTERING

發送消息

參數 描述 類型 是否必須 默認值
Topic 發送消息的主題名。 String
發送組(ProducerGroup) 發送消息的Group ID。 String
sendTag 可理解為Gmail中的標簽,對消息進行再歸類,方便消費者指定過濾條件在消息隊列RocketMQ的服務器過濾。 String
sendKey 消息的業務標識,由消息生產者設置,唯一標識某個業務邏輯。 String
sendMsgTimeoutMillis 消息發送的超時時間,單位毫秒。 String