メッセージを送信する操作 - ApsaraMQ for RocketMQ - Alibaba Cloud ドキュメントセンター

この操作を呼び出して、プロデューサーからApache RocketMQブローカーのMessage Queueにメッセージを送信できます。

リクエストの構造

リクエスト行

POST /topics/TopicName/messages?ns=INSTANCE_ID HTTP/1.1

次の表に、リクエストラインのパラメーターを示します。

パラメーター

必須

説明

TopicName

継続する

メッセージを送信する宛先トピックの名前。

継続しない

インスタンスの ID です。このパラメーターは、名前空間を持つ新しいインスタンスに必要です。インスタンスに名前空間があるかどうかは、Message Queue for Apache RocketMQコンソールの [インスタンス] ページで確認できます。インスタンスは、名前空間があるかどうかに基づいて、デフォルトインスタンスと新しいインスタンスに分類されます。

デフォルトインスタンス: デフォルトインスタンスには名前空間がありません。デフォルトインスタンスのすべてのリソースの名前は、グローバルに一意である必要があります。
新しいインスタンス: 新しいインスタンスには名前空間があります。新しいインスタンスのすべてのリソースの名前は、インスタンス内で一意である必要があります。

Message Queue For Apache RocketMQインスタンスの名前空間の詳細については、「インスタンスの使用」をご参照ください。

リクエスト本文 (XML形式)

次の表に、リクエストボディのパラメーターを示します。

パラメーター	必須	説明
MessageTag	継続しない	メッセージのタグ。
MessageBody	継続する	メッセージの内容。
プロパティ	継続しない	メッセージのプロパティ。

次の情報は、メッセージのシリアル化プロパティのキーと値のペアを示しています。

key1:value1 | key2:value2 | key3:value3の形式でキーと値のペアを指定します。

次の表に、キーと値のペアを指定するためのパラメーターを示します。

パラメーター	データ型	説明
キー	String	メッセージのキー。
__STARTDELIVERTIME	Long	スケジュールされたメッセージの絶対スケジュール時間。このパラメーターを、ミリ秒数を表すUNIXタイムスタンプに設定します。
__TransCheckT	Long	トランザクションメッセージの最初のステータスチェックを実行する相対時刻。単位は秒です。有効な値: 10 ~ 300

レスポンス構造

ステータス行
HTTP/1.1 201
レスポンスボディ
次の表に、レスポンス本文のパラメーターを示します。
パラメーター
データ型
説明
MessageId
String
メッセージの ID 。
MessageBodyMD5
String
メッセージ本文のMD5ハッシュ値。

例

リクエストの例

<?xml version="1.0" encoding="UTF-8"?>
<Message xmlns="http://mq.aliyuncs.com/doc/v1/">
<MessageBody>a</MessageBody>
<MessageTag>Tag</MessageTag>
<Properties>KEYS:MessageKey|__STARTDELIVERTIME:1571388173000</Properties>
</Message>

レスポンスの例

<Message xmlns="http://mq.aliyuncs.com/doc/v1/">
<MessageId>1E057D566EAD42A579935B5CD874****</MessageId>
<MessageBodyMD5>0CC175B9C0F1B6A831C399E26977****</MessageBodyMD5>
</Message>

パラメーター	データ型	説明
MessageId	String	メッセージの ID 。
MessageBodyMD5	String	メッセージ本文のMD5ハッシュ値。