O ApsaraMQ for RocketMQ exige três recursos para que sua aplicação envie ou receba mensagens por meio de um SDK cliente TCP: uma instância, um tópico e um group ID. Este guia orienta a criação de cada recurso no console e a obtenção do endpoint TCP necessário para a conexão da aplicação. Ao usar o SDK, configure os parâmetros com base nas informações dos recursos criados neste guia.
Pré-requisitos
Protocolos e restrições de rede
O ApsaraMQ for RocketMQ oferece SDKs cliente para diversas linguagens de programação. Esses SDKs se comunicam via TCP ou HTTP. Crie group IDs separados para cada protocolo. Para consultar os limites de grupos específicos por protocolo, veja Gerenciar grupos.
|
Restrição |
Detalhes |
|
Escopo de região e instância |
Um tópico é acessível apenas para produtores e consumidores cujo grupo pertença à mesma instância e região. Por exemplo, um tópico na Instância A em China (Hangzhou) só pode ser acessado por grupos na Instância A em China (Hangzhou). |
|
Correspondência de protocolo do endpoint |
Endpoints TCP e HTTP não são intercambiáveis. Se você utilizar um SDK cliente TCP, especifique um endpoint TCP. |
|
Endpoints públicos versus privados |
Ambos os tipos de endpoint estão disponíveis em todas as regiões. Em ambientes de produção, utilize um endpoint de Virtual Private Cloud (VPC). Use o endpoint público somente quando a VPC ou a Cloud Enterprise Network (CEN) estiverem indisponíveis — como em acessos entre regiões, conexões on-premises ou acesso pela Internet. Endpoints públicos geram cobranças de tráfego de saída. |
Etapa 1: Criar uma instância
Uma instância é uma máquina virtual gerenciada que hospeda tópicos e group IDs para o serviço ApsaraMQ for RocketMQ.
Faça login no console do ApsaraMQ for RocketMQ.
No painel de navegação à esquerda, clique em Instances.
Na barra de navegação superior, selecione uma região. Exemplo: China (Hangzhou).
Na página Instances, clique em Create Instance.
-
No painel Create Message Queue for Apache RocketMQ Instance, configure os parâmetros Instance Type, Name e Description e clique em OK. Para mais informações sobre o faturamento das instâncias Standard Edition e Enterprise Platinum Edition, consulte Visão geral do faturamento.
Verificar
Após a criação, a instância aparece na página Instances. Confirme se a instância está listada antes de prosseguir.
Etapa 2: Criar um tópico
Um tópico categoriza as mensagens conforme a finalidade do negócio. Produtores enviam mensagens para um tópico e consumidores se inscrevem nele. Como cada tópico suporta apenas um tipo de mensagem, crie tópicos distintos para diferentes tipos:
Topic_Order-- mensagens normais (notificações de pedidos)Topic_Payment-- mensagens transacionais (processamento de pagamentos)Topic_Reminder-- mensagens agendadas e atrasadas (lembretes)
Um tópico pertence a uma única instância. O Tópico A na Instância A não está disponível na Instância B. Cada nome de tópico deve ser exclusivo dentro de sua instância.
Na página de detalhes da instância, clique em Topics no painel de navegação à esquerda.
Na página Topics, clique em Create Topic.
-
No painel Create Topic, configure os seguintes parâmetros e clique em OK.
Parâmetro
Descrição
Name
Insira um nome para o tópico. Exemplo:
Topic_Order.Description
Opcional. Insira uma descrição para o tópico.
Message Type
Selecione Normal Message.
Este exemplo utiliza mensagens normais. O tópico criado aqui suporta apenas mensagens normais. Para enviar outros tipos de mensagem (transacionais, agendadas ou atrasadas), crie um tópico separado com o tipo de mensagem correspondente. Para obter detalhes, consulte Tipos de mensagem.
Verificar
O novo tópico aparece na lista de tópicos. Confirme se a coluna Status exibe Enabled.
Se o status mostrar Creating, atualize a página. O tópico estará pronto quando o status mudar para Enabled.
Etapa 3: Criar um group ID
Um group ID identifica um conjunto de produtores ou consumidores do mesmo tipo. Todo consumidor deve especificar um group ID. Produtores não exigem essa configuração.
|
Regra |
Detalhes |
|
Limite de grupos |
Cada instância suporta até 1.000 grupos. Reutilize ou exclua grupos não utilizados para permanecer dentro do limite. Para solicitar um limite maior, entre em contato com o suporte técnico do ApsaraMQ for RocketMQ. |
|
Escopo da instância |
Um grupo pertence a uma única instância. Um grupo na Instância A não pode ser usado na Instância B. |
|
Separação de protocolos |
Crie um grupo separado para cada protocolo (TCP ou HTTP). Misturar protocolos no mesmo grupo de consumidores pode causar falhas no consumo de mensagens, duplicação ou perda. A troca do protocolo usado pelos consumidores em um grupo leva aproximadamente 1 a 2 horas. |
|
Exibição no console |
Se os consumidores usarem um protocolo diferente daquele exibido no console, as métricas podem ficar imprecisas, mas a entrega de mensagens não será afetada. Entre em contato com o suporte técnico para corrigir o protocolo exibido. |
Na página de detalhes da instância, clique em Groups no painel de navegação à esquerda.
Na página Groups, escolha TCP > Create Group.
No painel Create Group for TCP Protocol, configure os parâmetros Group ID e Description e clique em OK.
Verificar
O novo group ID aparece na lista de group IDs.
Etapa 4: Obter o endpoint TCP
Com todos os recursos criados, copie o endpoint TCP. Sua aplicação precisa desse endpoint para conectar produtores e consumidores à instância.
Na página de detalhes da instância, clique em Instance Details no painel de navegação à esquerda.
Na página Instance Details, clique na aba Endpoints.
-
Na seção TCP Endpoint, passe o mouse sobre o endpoint e clique para copiá-lo.
Utilize o tipo de endpoint correto para o seu SDK. Um SDK cliente TCP requer o endpoint TCP; um SDK cliente HTTP requer o endpoint HTTP. Para ambientes de produção, use o endpoint privado (VPC). Use o endpoint público apenas quando a VPC ou a CEN estiverem indisponíveis. Endpoints públicos geram cobranças de tráfego de saída .
Próximos passos
Comece a enviar e receber mensagens: