ApsaraMQ for RabbitMQ:Queues

Pré-requisitos

Certifique-se de ter:

• Uma instância do ApsaraMQ for RabbitMQ

• Um vhost na instância onde deseja criar filas

• (Opcional) Para usuários RAM: Conceder permissões (opcional).

Criar uma fila

1. Faça login no console do ApsaraMQ for RabbitMQ. No painel de navegação à esquerda, clique em Instances.

2. Na barra de navegação superior, selecione a região da instância e clique no nome dela.

3. No painel de navegação à esquerda, clique em Queues.

4. Na página Queues, clique em Change ao lado de vhost e selecione o vhost no qual deseja criar a fila. Em seguida, clique em Create Queue.

5. No painel Create Queue, configure os parâmetros a seguir e clique em OK.

   Parâmetro	Descrição
   Queue Name	Nome da fila. Regras de nomenclatura: 1. The queue name supports only letters, digits, hyphens (-), underscores (_), periods (.), pound signs (#), slashes (/), at signs (@), colons (:), commas (,), spaces ( ), and greater-than signs (>). Length: 1–255 characters. 2. After a queue is created, you cannot modify its name. If you want to modify its name, delete the queue and re-create it. amq. é um prefixo reservado e não pode ser utilizado.
   Auto Delete	Exclui a fila após o cancelamento da assinatura pelo último consumidor. Yes: ativado. No: desativado.
   Retry Policy	Parâmetros opcionais de nova tentativa.
   Dead-letter Policy	Parâmetros opcionais de dead-letter. Clique para expandir.

Perguntas frequentes

P: Posso especificar qual cliente consome mensagens?

Não. O ApsaraMQ for RabbitMQ não permite especificar um cliente consumidor específico. A distribuição de mensagens segue os mecanismos padrão do RabbitMQ de round-robin ou despacho baseado em prioridade.

P: Como crio uma fila sequencial (x-single-active-consumer) via código?

O console do ApsaraMQ for RabbitMQ não suporta a configuração do parâmetro x-single-active-consumer. Para criar uma fila sequencial, utilize o SDK. Chame o método channel.queueDeclare e defina "x-single-active-consumer": true no parâmetro arguments.

Exemplo:

Map<String, Object> arguments = new HashMap<>();
arguments.put("x-single-active-consumer", true);
channel.queueDeclare("my-queue", true, false, false, arguments);

P: Por que a criação automática de fila falha (Failed to declare queue)?

O ApsaraMQ for RabbitMQ não suporta a criação automática de filas. Antes de declarar uma fila no código, crie-a manualmente no console ou chame a API.

Quantidade máxima de filas

Se a cota de filas da instância atingir o limite:

• Para instâncias das edições Enterprise, Professional e Platinum Edition, clique em Upgrade para fazer o upgrade.

• Para instâncias (Shared) Pay-by-Messaging-Request, (Shared) Pay-by-Provisioned-Capacity-and-Elastic-Traffic e (Exclusive) Pay-by-Provisioned-Capacity-and-Elastic-Traffic, clique em Change Quota para ajustar o limite de quantidade de filas.

Para consultar os limites de quantidade de diferentes instâncias, veja Queues per instance em Cluster limits no tópico Limites.

Visualize estatísticas da fila

As métricas variam conforme a edição da instância.

1. Na página Queues, localize a fila desejada e clique em Details na coluna Actions.

2. Na página Queue Details, clique na aba Dashboard.

   Edição da instância	Fonte de monitoramento	Referência
   Enterprise Edition, Enterprise Platinum Edition	Managed Service for Prometheus e Managed Service for Grafana	Painel
   Standard Edition, Professional Edition	Cloud Monitor	Monitoramento

Vincular uma exchange a uma fila

1. Na página Queues, localize a fila desejada e clique em Details na coluna Actions.

2. Na página Queue Details, clique na aba Bound as Destination. Em seguida, clique em Add Binding.

3. No painel Add Binding, configure Source Exchange e Routing Key, depois clique em OK.

Enviar mensagens para uma fila

Envie mensagens para uma fila a partir de uma exchange vinculada.

1. Na página Queues, localize a fila desejada e clique em Details na coluna Actions.

2. Na página Queue Details, clique na aba Bound as Destination.

3. Na lista de vínculos, localize o vínculo desejado e clique em Send Message na coluna Actions.

4. No painel Send Message, selecione uma opção mandatory, insira um Message ID e o Message Body, e clique em OK.

Visualize consumer tags

Uma consumer tag identifica exclusivamente um cliente consumidor. O broker gera uma automaticamente caso o cliente não especifique nenhuma. Utilize a tag gerada automaticamente em vez de uma personalizada.

Para visualizar as consumer tags, o cliente consumidor deve estar conectado ao broker. Na página Queues, localize a fila desejada e clique em Consumer Tags na coluna Actions.

Limpar uma fila

Na página Queues, localize a fila desejada e escolha More > Clear Messages na coluna Actions.

Excluir filas

1. Na página Queues, exclua filas usando um dos métodos a seguir:

   • Fila única: Localize a fila e escolha More > Delete na coluna Actions. Alternativamente, clique no nome da fila ou em Details, e então clique em Delete no canto superior direito da página Queue Details.

   • Múltiplas filas: Selecione as filas e clique em Batch Delete abaixo da lista de filas.

2. Confirme a exclusão.