このトピックでは、C# 用 Apache RocketMQ 5.x SDK を使用してメッセージを送受信するためのサンプルコードについて説明します。
メッセージタイプ | メッセージ送信のサンプルコード | メッセージ受信のサンプルコード |
パラメータ
パラメータ | 例 | 説明 |
Endpoint | rmq-cn-xxx.{regionId}.rmq.aliyuncs.com:8080 | RocketMQ for ApsaraMQ インスタンスのエンドポイント。エンドポイントの取得方法については、「インスタンスのエンドポイントを取得する」をご参照ください。
|
InstanceId | rmq-cn-xxx | RocketMQ for ApsaraMQ インスタンスの ID。 |
topic | normal_test | RocketMQ for ApsaraMQ インスタンスでメッセージを送信または消費する Topic。 RocketMQ for ApsaraMQ インスタンスで事前に Topic を作成する必要があります。詳細については、「Topic を作成する」をご参照ください。 |
consumerGroup | GID_test | RocketMQ for ApsaraMQ インスタンスでコンシューマーがメッセージを消費するために使用するコンシューマーグループ。 RocketMQ for ApsaraMQ インスタンスで事前にコンシューマーグループを作成する必要があります。詳細については、「コンシューマーグループを作成する」をご参照ください。 |
AccessKey | 1XVg0hzgKm****** | RocketMQ for ApsaraMQ インスタンスのユーザー名。インターネット経由でインスタンスにアクセスする場合は、ユーザー名を指定する必要があります。 VPC 内でインスタンスにアクセスする場合は、インスタンスがサーバーレスインスタンスであり、インスタンスで VPC 内の認証不要機能が無効になっている場合にのみ、ユーザー名を指定する必要があります。 ユーザー名の取得方法については、「インスタンスのユーザー名とパスワードを取得する」をご参照ください。 |
SecretKey | ijSt8rEc45****** | RocketMQ for ApsaraMQ インスタンスのパスワード。インターネット経由でインスタンスにアクセスする場合は、パスワードを指定する必要があります。 VPC 内でインスタンスにアクセスする場合は、インスタンスがサーバーレスインスタンスであり、インスタンスで VPC 内の認証不要機能が無効になっている場合にのみ、パスワードを指定する必要があります。 パスワードの取得方法については、「インスタンスのユーザー名とパスワードを取得する」をご参照ください。 |
インターネット経由でサーバーレスインスタンスにアクセスするための説明インターネット経由でサーバーレス インスタンスにアクセスするため
インターネット経由でサーバーレス RocketMQ for ApsaraMQ インスタンスにアクセスしてメッセージを送受信する場合は、メッセージングコードに次の情報を追加する必要があります。
InstanceId を RocketMQ for ApsaraMQ インスタンスの ID に置き換えます。
var clientConfig = new ClientConfig.Builder()
.SetEndpoints(endpoints)
.SetNamespace("InstanceId")
.SetCredentialsProvider(credentialsProvider)
.Build();