Sample code for sending and receiving messages by using Apache RocketMQ 5.x SDK for C# - ApsaraMQ for RocketMQ: Central de Documentação do Alibaba Cloud

Pré-requisitos

Antes de começar, verifique se você tem:

Uma instância do ApsaraMQ for RocketMQ com o endpoint obtido. Para mais informações, consulte Obter o endpoint de uma instância.
Um tópico e um grupo de consumidores criados na instância.
Um ambiente de desenvolvimento C# configurado. Para mais informações, consulte Preparação do ambiente.
(Condicional) O nome de usuário e a senha da instância obtidos, caso o acesso à instância ocorra pela Internet ou se a instância for serverless com a autenticação livre em VPCs desativada.

Visão geral dos códigos de exemplo

Tipo de mensagem	Exemplo de produtor	Exemplo de consumidor
Mensagens normais	ProducerNormalMessageExample.cs	SimpleConsumerExample.cs
Mensagens ordenadas	ProducerFifoMessageExample.cs	SimpleConsumerExample.cs
Mensagens agendadas e atrasadas	ProducerDelayMessageExample.cs	SimpleConsumerExample.cs
Mensagens transacionais	ProducerTransactionMessageExample.cs	SimpleConsumerExample.cs

Parâmetros

Substitua os espaços reservados abaixo em todos os códigos de exemplo pelos seus valores reais:

Parâmetro	Exemplo	Descrição
`Endpoint`	`rmq-cn-xxx.{regionId}.rmq.aliyuncs.com:8080`	Endpoint da instância. Use o endpoint público para acesso via Internet ou o endpoint de VPC para acesso via VPC. Para mais informações, consulte Obter o endpoint de uma instância.
`InstanceId`	`rmq-cn-xxx`	ID da instância do ApsaraMQ for RocketMQ.
`topic`	`normal_test`	Tópico de destino para envio ou origem para consumo de mensagens. Crie o tópico na instância previamente. Para mais informações, consulte Criar um tópico.
`consumerGroup`	`GID_test`	Grupo de consumidores para processar as mensagens. Crie o grupo de consumidores na instância previamente. Para mais informações, consulte Criar um grupo de consumidores.
`AccessKey`	`1XVg0hzgKm******`	Nome de usuário da instância. Obrigatório para acesso via Internet. Para acesso via VPC, é necessário apenas quando a instância é serverless e a autenticação livre em VPCs está desativada. Para mais informações, consulte Obter o nome de usuário e a senha de uma instância.
`SecretKey`	`ijSt8rEc45******`	Senha da instância. Necessária nas mesmas condições do `AccessKey`. Para mais informações, consulte Obter o nome de usuário e a senha de uma instância.

Acesso a instâncias serverless pela Internet

Para acessar uma instância serverless do ApsaraMQ for RocketMQ pela Internet, adicione SetNamespace à configuração do cliente e defina-o com o ID da sua instância:

Nota

Substitua InstanceId pelo ID real da sua instância.

var clientConfig = new ClientConfig.Builder()
    .SetEndpoints(endpoints)
    .SetNamespace("<your-instance-id>")   // Replace with your actual instance ID, for example, rmq-cn-xxx.
    .SetCredentialsProvider(credentialsProvider)
    .Build();