ApsaraMQ for RocketMQ:Crie recursos

Pré-requisitos

Antes de começar, certifique-se de ter:

• Activated ApsaraMQ for RocketMQ and granted permissions to a RAM user

Restrições de acesso à rede

Analise estas restrições antes de crie os recursos:

Seleção de endpoint:

• Ambientes de produção: Use um endpoint privado baseado em VPC.

• Acesso entre regiões, data centers locais ou acesso à Internet (quando o CEN não estiver disponível): Use um endpoint público. Há cobrança de taxas de tráfego de saída. Para mais detalhes, consulte Internet traffic fee.

Etapa 1: Crie uma instância

Uma instância é uma máquina virtual que hospeda o service do ApsaraMQ for RocketMQ e armazena seus tópicos e ID de grupo.

1. Faça login no console do ApsaraMQ for RocketMQ.

2. No painel de navegação à esquerda, clique em Instances.

3. Na barra de navegação superior, selecione uma região. Exemplo: China (Hangzhou).

4. Na página Instances, clique em Create Instance.

5. No painel Create Message Queue for Apache RocketMQ Instance, configure os seguintes parâmetros e clique em OK.

   Parâmetro	Descrição
   Instance Type	Selecione Standard Edition Instance ou Enterprise Platinum Edition. Para obter detalhes sobre o faturamento, consulte Billing overview.
   Name	Nome descritivo para a instância. Exemplo: rocketmq-order-prod
   Description	Breve descrição do propósito da instância. Exemplo: Order processing messages

   

Resultado: A nova instância aparecerá na página Instances.

Etapa 2: Crie um tópico

Um tópico é uma categoria de mensagem de primeiro nível. Os produtores enviam mensagens para um tópico, e os consumidores o assinam para recebê-las. Por exemplo, crie um tópico chamado Topic_Trade para mensagens transacionais.

Regras de tópicos:

Exemplos de tipos de mensagem:

Para obter detalhes sobre os tipos de mensagem, consulte Message types.

Create the topic:

1. Na página de detalhes da instância, clique em Topics no painel de navegação à esquerda.

2. Na página Topics, clique em Create Topic.

3. No painel Create Topic, configure os seguintes parâmetros e clique em OK.

   Parâmetro	Descrição
   Name	Nome de tópico exclusivo nesta instância. Exemplo: Topic_Order
   Message Type	Selecione Normal Message. Este exemplo usa mensagens normais.
   Description	Breve descrição do propósito do tópico. Exemplo: Order-related messages

Este exemplo usa apenas mensagens normais. Para enviar ou receber mensagens transacionais, agendadas ou atrasadas, crie um tópico separado com o tipo de mensagem correspondente.

Resultado: O novo tópico aparece na lista de tópicos e defina o Status como Enabled.

Se o Status exibir Creating , atualize a página até que mude para Enabled .

Etapa 3: Crie um ID de grupo

Um ID de grupo identifica um conjunto de produtores ou consumidores relacionados.

Regras de grupo:

Alterar o protocolo usado pelos consumidores em um grupo leva de 1 a 2 horas. Se os consumidores usarem um protocolo diferente do exibido no console, os dados do console podem ficar imprecisos, mas o envio de mensagens não será afetado. Entre em contato com o suporte técnico e atualize o protocolo exibido.

Create the group:

1. Na página de detalhes da instância, clique em Groups no painel de navegação à esquerda.

2. Na página Groups, escolha HTTP > Create Group.

3. No painel Create Group for HTTP Protocol, configure os seguintes parâmetros e clique em OK.

   Parâmetro	Descrição
   Group ID	Identificador de grupo exclusivo. Exemplo: GID_Order_HTTP
   Description	Breve descrição do propósito do grupo. Exemplo: HTTP consumers for order messages

Resultado: O novo ID de grupo aparece na lista de grupos.

Etapa 4: Obter o endpoint HTTP

Após crie todos os recursos, obtenha o endpoint HTTP para conectar sua aplicação ao broker do ApsaraMQ for RocketMQ.

1. Na página de detalhes da instância, clique em Instance Details no painel de navegação à esquerda.

2. Na página Instance Details, clique na guia Endpoints.

3. Na seção HTTP Endpoint, passe o mouse sobre o endpoint e clique em copiar.

   

Os endpoints HTTP e TCP da mesma instância não são intercambiáveis. Se você usar um SDK de cliente HTTP, deverá usar o endpoint HTTP. O endpoint HTTP é específico da região, então especifique o endpoint e o ID da instância no seu código antes de enviar ou receber mensagens.

Resultado: O endpoint HTTP será copiado para a área de transferência. Salve-o para usar na configuração do seu SDK.

Próximos passos

Com todos os recursos criados, comece a enviar e receber mensagens:

• Use SDK de cliente HTTP para enviar e assinar mensagens normais