Antes de usar um SDK de cliente TCP para enviar e receber mensagens, crie os recursos necessários no console do ApsaraMQ for RocketMQ. Ao usar o SDK, configure os parâmetros com base nas informações dos recursos.
Antes de começar
Activate AsparaMQ for RocketMQ and grant permissions to a RAM user
Informações básicas
O ApsaraMQ for RocketMQ oferece SDKs para várias linguagens de programação que permitem enviar e receber mensagens pelos protocolos TCP e HTTP. Recomendamos criar grupos distintos para cada protocolo. Para obter detalhes sobre as restrições de uso de grupos por protocolo, consulte Gerencie groups.
Restrições de acesso à rede
Antes de usar o ApsaraMQ for RocketMQ, observe as seguintes restrições de acesso à rede:
Produtores ou consumidores de um grupo só acessam um tópico se o grupo estiver criado na mesma instância e região do tópico. Por exemplo, se você criar um tópico na Instância A na região China (Hangzhou), apenas produtores ou consumidores de um grupo criado na Instância A na região China (Hangzhou) poderão acessá-lo.
Endpoints públicos e privados para clientes TCP e HTTP estão disponíveis em todas as regiões. Em ambientes de produção, recomendamos acessar o ApsaraMQ for RocketMQ por meio de virtual private clouds (VPCs). Se precisar acessar o ApsaraMQ for RocketMQ entre regiões, a partir de data centers on-premises ou pela internet quando a Cloud Enterprise Network (CEN) não estiver disponível, use endpoints públicos. O uso de endpoints públicos gera cobrança de tráfego de saída para a internet. Para mais informações, consulte Billing of Internet traffic.
O ApsaraMQ for RocketMQ fornece endpoints HTTP e TCP. Cada tipo de endpoint aceita apenas clientes do mesmo protocolo. Portanto, ao usar um SDK de cliente TCP, especifique somente um endpoint TCP no código.
Criar uma instância
No ApsaraMQ for RocketMQ, a instância é uma máquina virtual que armazena informações sobre tópicos e grupos. Para criar uma instância do ApsaraMQ for RocketMQ, siga estas etapas:
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, como 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. Em seguida, clique em OK.
Criar um tópico
No ApsaraMQ for RocketMQ, o tópico é um identificador de primeiro nível usado para classificar mensagens. Por exemplo, você pode criar um tópico chamado Topic_Trade para identificar mensagens transacionais. Assim, produtores publicam mensagens no Topic_Trade e consumidores se inscrevem nesse tópico para processá-las. Os tópicos devem atender aos seguintes requisitos:
Um tópico não pode ser usado em diferentes instâncias. Por exemplo, o Tópico A criado na Instância A não estará disponível na Instância B.
Cada nome de tópico deve ser único na instância.
Recomendamos criar tópicos separados para diferentes tipos de mensagem. Por exemplo, crie o Tópico A para mensagens normais, o Tópico B para mensagens transacionais e o Tópico C para mensagens agendadas e atrasadas.
No painel de navegação à esquerda da página Detalhes da Instância, clique em Topics.
Na página Topics, clique em Create Topic.
-
No painel Create Topic, configure os parâmetros Name e Description, defina o parâmetro Message Type como Normal Message e clique em OK.
NotaEste exemplo usa mensagens normais. O tópico criado seguindo as etapas desta seção não serve para enviar ou receber outros tipos de mensagem, pois cada tópico aceita apenas um tipo específico. Para mais informações sobre tipos de mensagem, consulte Message types.
Criar um grupo
No ApsaraMQ for RocketMQ, o grupo identifica produtores ou consumidores do mesmo tipo. Os grupos devem obedecer aos seguintes requisitos:
Há um limite de 1.000 grupos por instância. Reutilize ou exclua grupos inativos para permanecer dentro desse limite. Para aumentar essa cota, entre em contato com o suporte técnico do ApsaraMQ for RocketMQ.
Um grupo não pode ser usado em múltiplas instâncias.
-
O ApsaraMQ for RocketMQ suporta os protocolos HTTP e TCP para consumo de mensagens. Grupos diferentes podem adotar protocolos distintos, mas todos os consumidores dentro do mesmo grupo devem usar o mesmo protocolo.
A mistura de protocolos em um único grupo pode causar falhas de consumo, duplicação ou perda de mensagens.
Alterações de protocolo em um grupo levam aproximadamente de 1 a 2 horas para entrar em vigor.
Se os consumidores de um grupo usarem um protocolo diferente daquele exibido no console do ApsaraMQ for RocketMQ, os dados apresentados estarão incorretos e problemas como perda de mensagens ou mensagens não consumidas poderão ocorrer. Garanta que o protocolo declarado para o grupo no console corresponda ao protocolo efetivamente usado pelos consumidores. Se precisar corrigir o tipo de protocolo declarado no console, contate o suporte técnico do ApsaraMQ for RocketMQ.
Um Group ID é obrigatório para cada consumidor e opcional para produtores.
No painel de navegação à esquerda da página Detalhes da Instância, clique em Groups.
Na página Groups, escolha .
No painel Create Group for TCP Protocol, configure os parâmetros Group ID e Description. Em seguida, clique em OK.
Obter um endpoint
Após criar os recursos no console do ApsaraMQ for RocketMQ, obtenha o endpoint necessário para acessar a instância. Antes de enviar e receber mensagens, especifique o endpoint nos clientes produtor e consumidor para permitir o acesso à instância na região indicada.
No painel de navegação à esquerda da página Detalhes da Instância, clique em Instance Details.
Na seção TCP Endpoint da página Instance Details, passe o ponteiro do mouse sobre o endpoint e clique nele para copiá-lo.
Antes de usar os endpoints, atente-se aos pontos abaixo:
Cada tipo de endpoint aceita apenas clientes do protocolo correspondente. Por exemplo, para enviar e receber mensagens com um SDK de cliente TCP, use o endpoint TCP da sua instância do ApsaraMQ for RocketMQ para acessar o broker do ApsaraMQ for RocketMQ.
Todas as regiões oferecem endpoints públicos e privados para clientes TCP e HTTP. Em ambientes de produção, acesse o ApsaraMQ for RocketMQ preferencialmente via virtual private clouds (VPCs). Use endpoints públicos para acessar instâncias do ApsaraMQ for RocketMQ apenas quando precisar de conexões entre regiões, a partir de data centers on-premises ou pela internet sem disponibilidade da Cloud Enterprise Network (CEN). O tráfego de saída para a internet via endpoints públicos é cobrado. Consulte Billing of Internet traffic para mais detalhes.
Após concluir essas operações, execute o código de exemplo e use o ApsaraMQ for RocketMQ para enviar e receber mensagens.
Próximos passos
Call TCP client SDKs to send and subscribe to normal messages