ApsaraMQ for RocketMQ:Criar recursos

Pré-requisitos

Antes de começar, verifique se você já:

• Ativou o ApsaraMQ for RocketMQ e concedeu permissões a um usuário RAM

Restrições de acesso à rede

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

Seleção de endpoint:

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

• Acesso entre regiões, data centers on-premises ou acesso via 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 Taxa de tráfego de Internet.

Etapa 1: Criar uma instância

Uma instância é uma máquina virtual que hospeda o serviço ApsaraMQ for RocketMQ. Ela armazena seus tópicos e group ids.

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 parâmetros abaixo e clique em OK.

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

   

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

Etapa 2: Criar um tópico

Um tópico é uma categoria de mensagem de primeiro nível. Produtores enviam mensagens para um tópico e consumidores se inscrevem nesse tópico para recebê-las. Por exemplo, você pode criar um tópico chamado Topic_Trade para mensagens transacionais.

Regras de tópico:

Exemplos de tipos de mensagem:

Para obter detalhes sobre os tipos de mensagem, consulte Tipos de mensagem.

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 exclusivo para o tópico nesta instância. Exemplo: Topic_Order
   Message Type	Selecione Normal Message. Este exemplo utiliza mensagens normais.
   Description	Breve descrição da finalidade 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 com o Status definido como Enabled.

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

Etapa 3: Criar um group id

Um group id identifica um conjunto de produtores ou consumidores relacionados.

Regras de grupo:

Alterar o protocolo usado pelos consumidores em um grupo leva aproximadamente de 1 a 2 horas. Caso os consumidores utilizem um protocolo diferente daquele 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 para atualizar 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 parâmetros a seguir e clique em OK.

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

Resultado: O novo group id aparece na lista de grupos.

Etapa 4: Obter o endpoint HTTP

Após criar 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 aba Endpoints.

3. Na seção HTTP Endpoint, passe o mouse sobre o endpoint e clique para copiá-lo.

   

O endpoint HTTP e o endpoint tcp da mesma instância não são intercambiáveis. Ao utilizar um SDK cliente HTTP, use obrigatoriamente o endpoint HTTP. Esse endpoint é específico da região. Especifique tanto o endpoint quanto o id da instância no seu código antes de enviar ou receber mensagens.

Resultado: O endpoint HTTP é 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:

• Usar SDKs cliente HTTP para enviar e assinar mensagens normais