すべてのプロダクト
Search
ドキュメントセンター

ApsaraMQ for RocketMQ:サンプルコード

最終更新日:Mar 27, 2025

このトピックでは、Apache RocketMQ 5.x SDK for C++ を使用してメッセージを送受信するためのサンプルコードについて説明します。

メッセージタイプ

メッセージ送信のサンプルコード

メッセージ受信のサンプルコード

PushConsumer

SimpleConsumer

標準メッセージ

ExamplePushConsumer.cpp

ExampleSimpleConsumer.cpp

順序メッセージ

ExampleProducerWithFifoMessage.cpp

スケジュールメッセージと遅延メッセージ

ExampleProducerWithTimedMessage.cpp

トランザクションメッセージ

ExampleProducerWithTransactionalMessage.cpp

パラメーター

パラメーター

説明

access_point

rmq-cn-xxx.{regionId}.rmq.aliyuncs.com:8080

RocketMQ for ApsaraMQ インスタンスのエンドポイント。エンドポイントの取得方法については、インスタンスのエンドポイントを取得する を参照してください。

  • インターネット経由でインスタンスにアクセスする場合は、パブリックエンドポイントを指定します。

  • VPC 内でインスタンスにアクセスする場合は、VPC エンドポイントを指定します。

topic

normal_test

RocketMQ for ApsaraMQ インスタンスでメッセージを送信する、またはメッセージを消費する Topic。

RocketMQ for ApsaraMQ インスタンスで事前に Topic を作成する必要があります。詳細については、「Topic を作成する」をご参照ください。

group

GID_test

RocketMQ for ApsaraMQ インスタンスでコンシューマーがメッセージを消費するために使用するコンシューマーグループ。

RocketMQ for ApsaraMQ インスタンスで事前にコンシューマーグループを作成する必要があります。詳細については、「コンシューマーグループを作成する」をご参照ください。

access_key

1XVg0hzgKm******

RocketMQ for ApsaraMQ インスタンスのユーザー名。インターネット経由でインスタンスにアクセスする場合は、ユーザー名を指定する必要があります。 VPC 内でインスタンスにアクセスする場合は、インスタンスがサーバーレスインスタンスであり、インスタンスで VPC 内の認証不要機能が無効になっている場合にのみ、ユーザー名を指定する必要があります。

ユーザー名の取得方法については、インスタンスのユーザー名とパスワードを取得する を参照してください。

access_secret

ijSt8rEc45******

RocketMQ for ApsaraMQ インスタンスのパスワード。インターネット経由でインスタンスにアクセスする場合は、パスワードを指定する必要があります。 VPC 内でインスタンスにアクセスする場合は、インスタンスがサーバーレスインスタンスであり、インスタンスで VPC 内の認証不要機能が無効になっている場合にのみ、パスワードを指定する必要があります。

パスワードの取得方法については、インスタンスのユーザー名とパスワードを取得する を参照してください。