O roteamento global de mensagens encaminha mensagens entre filas, ou de uma fila para uma exchange, em diferentes instâncias, vhosts ou regiões. Funciona de forma semelhante ao plugin Shovel de código aberto do RabbitMQ.
Observações de uso
Há taxas extras. Custo total = taxas do ApsaraMQ for RabbitMQ + taxas de encaminhamento do EventBridge + taxas de tráfego da Cloud Enterprise Network (CEN) (apenas para regiões diferentes). ApsaraMQ for RabbitMQ: Billing of subscription instances. EventBridge: Billing. CEN: Billing rules.
Não há suporte para roteamento de mensagens por retransmissão. Para encaminhar mensagens da instância A para a instância C, crie uma rota direta. Não é possível rotear por uma instância B intermediária.
Possível latência durante a sincronização. Grandes volumes de mensagens e largura de banda de rede limitada podem causar latência.
Limites de tamanho de mensagem: O tamanho máximo da mensagem da instância de destino deve ser maior ou igual ao da instância de origem. Mensagens que excedem o limite de destino falham no roteamento e são perdidas.
Pré-requisitos
-
ApsaraMQ for RabbitMQ
As instâncias de origem e de destino, vhosts, exchanges e filas estão criadas e disponíveis.
-
EventBridge
O EventBridge está ativado e as permissões necessárias de usuário RAM foram concedidas. Activate EventBridge and grant permissions to a RAM user.
Crie uma tarefa de roteamento global de mensagens
Acesse o console do ApsaraMQ for RabbitMQ. No painel de navegação à esquerda, clique em Shovel Task.
Na página Shovel Task, clique em Create Task.
-
(Opcional) Na caixa de diálogo Alibaba Cloud Service Authorization - Message Queue RabbitMQ, leia a mensagem e clique em OK.
Ao criar uma tarefa de roteamento global de mensagens pela primeira vez, as seguintes funções vinculadas ao serviço são criadas automaticamente: AliyunServiceRoleForEventBridgeSourceRabbitMQ e AliyunServiceRoleForEventBridgeSendToRabbitMQ. Service-linked roles.
NotaO EventBridge assume a função AliyunServiceRoleForEventBridgeSourceRabbitMQ para receber mensagens enviadas pela instância de origem.
O EventBridge assume a função AliyunServiceRoleForEventBridgeSendToRabbitMQ para encaminhar mensagens para a instância de destino.
-
Na página Create Shovel Task, configure as informações das instâncias de origem e de destino da tarefa de roteamento de mensagens.
Na etapa Basic Information, especifique o nome e a descrição da tarefa e clique em Next.
-
Na etapa Source and Destination, configure as informações das instâncias de origem e de destino da tarefa de roteamento de mensagens e clique em Next.
Parâmetro
Descrição
Exemplo
Source
Service Type
Tipo de instância para a origem da mensagem. Definido automaticamente como Message Queue for RabbitMQ.
Message Queue for RabbitMQ
Region
Região da instância de origem.
China (Shenzhen)
Instance
id da instância de origem.
amqp-cn-i7m2a8bq****
vhost
Vhost na instância de origem.
test-001
Queue
Fila na instância de origem.
test-001-q
Destination
Service Type
Tipo de instância para o destino da mensagem. Definido automaticamente como Message Queue for RabbitMQ.
Message Queue for RabbitMQ
Region
Região da instância de destino.
China (Shenzhen)
Instance
id da instância de destino.
amqp-cn-7pp2a85q****
vhost
Vhost na instância de destino.
test-routing
Destination Type
Tipo de recurso de destino. Valores válidos:
-
Queue: Encaminhar mensagens para filas na instância de destino.
-
Exchange: Encaminhar mensagens para exchanges na instância de destino.
NotaSe o Destination Type estiver definido como Exchange, certifique-se de que a exchange de destino esteja vinculada a uma fila. Caso contrário, as mensagens encaminhadas serão perdidas.
test-routing-ex
Routing Key
Chave de roteamento para o encaminhamento de mensagens. Disponível apenas quando o Destination Type estiver definido como Exchange. Valores válidos:
-
Not Set: Usar a chave de roteamento existente para encaminhar mensagens.
-
Set: Usar uma chave de roteamento personalizada para encaminhar mensagens.
test
-
Na etapa Create and Start, confirme as configurações da tarefa de roteamento de mensagens e clique em Create and Start.
Após a criação, a tarefa aparece na página Shovel Task com Running na coluna Status.
Referências
O roteamento global de mensagens é compatível com o plugin Shovel Plugin de código aberto do RabbitMQ.