本文为您介绍RocketMQ 5.x系列C# SDK的消息收发示例代码。
消息类型 | 发送消息示例代码 | 订阅消息示例代码 |
参数说明
参数 | 示例值 | 描述 |
Endpoint | rmq-cn-xxx.{regionId}.rmq.aliyuncs.com:8080 | 云消息队列 RocketMQ 版实例的接入点。获取方式，请参见获取实例接入点。
|
InstanceId | rmq-cn-xxx | 云消息队列 RocketMQ 版实例ID。 |
topic | normal_test | 云消息队列 RocketMQ 版的Topic，用于指定生产者将消息发送到哪个Topic，或者指定消费者要消费哪个Topic的消息。 Topic需要提前在云消息队列 RocketMQ 版实例下创建。具体操作，请参见创建Topic。 |
consumerGroup | GID_test | 云消息队列 RocketMQ 版的ConsumerGroup，用于指定消费者使用哪个消费者分组消费消息。 Group需要提前在云消息队列 RocketMQ 版实例下创建。具体操作，请参见创建ConsumerGroup。 |
AccessKey | 1XVg0hzgKm****** | 云消息队列 RocketMQ 版实例的用户名。公网访问时，必须填写实例的用户名；VPC访问时，若Serverless实例未开启内网免身份识别功能，则也必须填写实例的用户名。 获取方式，请参见获取实例用户名密码。 |
SecretKey | ijSt8rEc45****** | 云消息队列 RocketMQ 版实例的用户密码。公网访问时，必须填写实例的用户密码；VPC访问时，若Serverless实例未开启内网免身份识别功能，则也必须填写实例的用户密码。 获取方式，请参见获取实例用户名密码。 |
Serverless版实例公网访问说明
使用公网访问接入云消息队列 RocketMQ 版Serverless实例时，需要在消息收发代码中补充如下内容：
其中，InstanceId需要替换为您实际使用的实例ID。
var clientConfig = new ClientConfig.Builder()
.SetEndpoints(endpoints)
.SetNamespace("InstanceId")
.SetCredentialsProvider(credentialsProvider)
.Build();