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