SOFAStack 消息隊列提供 Java SDK 實現消息發送與訂閱，您可通過本文了解消息發送和訂閱相關接口的參數說明。
通用參數
參數名 | 參數說明 |
ENDPOINT | 設置 TCP 協議接入點，從消息隊列控制臺的 概覽 > 接入配置 獲取。 |
INSTANCE_ID | 設置實例 ID，從消息隊列控制臺的 概覽 > 接入配置 獲取。 |
ACCESS_KEY | 您在阿里云賬號管理控制臺中創建的 AccessKeyId，用于身份認證。 |
SECRET_KEY | 您在阿里云賬號管理控制臺中創建的 AccessKeySecret，用于身份認證。 |
消息發送接口
消息發送參數
參數名 | 參數說明 |
SEND_MSG_TIMEOUT_MILLIS | 設置消息發送的超時時間，單位：毫秒。默認值為 3000。 |
shardingKey（順序消息） | 順序消息中用來計算不同分區的值。 |
消息發送返回值
同步消息 SendResult
結構體參數名
參數說明
messageId
消息 ID，可以在控制臺根據消息 ID 查詢到消息的具體軌跡信息，如果發送失敗則不會返回消息 ID。
topic
消息主題。
異步消息 SendResult
結構體參數名
參數說明
onSuccess
消息發送成功，則執行 onSuccess 中實現的方法。
onException
消息發送拋出異常，則執行 onException 中實現的方法。
消息訂閱接口
消息訂閱參數
參數名 | 參數說明 |
GROUP_ID | 您在消息隊列控制臺上創建的 Group ID，詳情參見 基礎術語。 |
MESSAGE_MODEL | 設置 Consumer 的消費模式，取值說明如下：
|
CONSUME_THREAD_NUMS | 設置 Consumer 的消費線程數，默認值為 20。 |
MAX_RECONSUME_TIMES | 設置消息消費失敗的最大重試次數，默認值為 16。 |
CONSUME_TIMEOUT | 設置每條消息消費的最大超時時間，超過設置時間則被視為消費失敗，等下次重新投遞再次消費。每個業務需要設置一個合理的值，單位：分鐘。 默認值為 15。 |
SUSPEND_TIME_MILLIS（順序消息） | 只適用于順序消息，設置消息消費失敗的重試間隔時間。 |
MAX_CACHED_MESSAGE_AMOUNT | 客戶端本地的最大緩存消息數據，單位：條。默認值為 1000。 |
MAX_CACHED_MESSAGE_SIZE_IN_MI_B | 客戶端本地的最大緩存消息大小，默認值：512 MB。取值范圍為 16 MB ~ 2 GB。 |
更多信息
消息收發代碼示例