Este tópico descreve a política padrão de retry de consumo no lado do servidor para o ApsaraMQ for RabbitMQ. O conteúdo explica o tratamento das mensagens após uma falha de consumo para ajudar na escolha da política de processamento mais adequada.
Fluxo de retry do consumidor
O mecanismo de retry do consumidor aumenta a confiabilidade do sistema e a consistência dos dados ao reenviar ou processar mensagens automaticamente quando ocorrem falhas temporárias.
Ready: mensagens em fila aguardando consumo.
Unack: mensagens recuperadas pelo consumidor, mas ainda não confirmadas. Isso indica que a mensagem foi recebida, mas o processamento não foi concluído.
Propriedades da política de retry
A política de retry do consumidor consiste em duas propriedades principais: timeout de consumo e número máximo de tentativas de entrega.
Timeout de consumo
O timeout de consumo define o tempo máximo permitido para o consumidor processar uma mensagem. Se o processamento não for concluído dentro desse período, a mensagem retorna ao estado Ready e outro consumidor pode recuperá-la. Definir um timeout de consumo adequado traz os seguintes benefícios:
Evita suspensões prolongadas: um timeout bem configurado impede que o consumidor fique bloqueado por muito tempo durante o processamento. Isso previne o acúmulo de mensagens e melhora o desempenho geral do sistema.
Garante processamento confiável: se um consumidor não conseguir processar uma mensagem em tempo hábil, o ApsaraMQ for RabbitMQ a reentrega para outros consumidores, assegurando seu tratamento rápido.
Número máximo de tentativas de entrega
Esse parâmetro limita quantas vezes o sistema tenta entregar uma mensagem ao consumidor. Configurar um valor apropriado oferece as seguintes vantagens:
Previne retries infinitos: estabelecer um limite máximo evita a reentrega indefinida de mensagens, poupando recursos do sistema.
Permite failover: ao atingir o limite de tentativas, o sistema encaminha a mensagem para uma fila de dead-letter. Assim, os desenvolvedores podem analisar e tratar a mensagem posteriormente.
A propriedade x-delivery-limit de uma fila especifica o número máximo de reentregas. O número máximo de tentativas de entrega corresponde a x-delivery-limit + 1.
Descrição dos parâmetros da política de retry da instância
|
Tipo de instância |
Instâncias Serverless |
Instâncias por assinatura |
||
|
Compartilhada |
Dedicada |
Enterprise Edition |
Platinum Edition |
|
|
Reservada + Elástica / Pagamento conforme o uso acumulado |
Reservada + Elástica |
|||
|
Timeout de consumo |
Máximo: 3 horas Padrão: 5 minutos |
Máximo: 12 horas Padrão: 30 minutos |
Máximo: 3 horas Padrão: 5 minutos |
Máximo: 12 horas Padrão: 30 minutos |
|
Número máximo de tentativas de entrega |
Máximo: 16 Padrão: 16 |
Máximo: 16 Padrão: 16 |
Máximo: 16 Padrão: 16 |
Máximo: 64 Padrão: 16 |
Modifique a política de retry do consumidor
Faça login no console do ApsaraMQ for RabbitMQ.
-
Na página Overview, na seção Resource Distribution, selecione uma região e clique em na instância desejada.
-
Política de retry da instância
Na página Instance Details, clique em na aba Retry Policy e, em seguida, clique em em Edit.
No painel Modify Retry Policy, defina os valores de Maximum Number of Deliveries e Consumption Timeout Period conforme os intervalos descritos acima.
-
Política de retry da fila
No painel de navegação à esquerda, clique em em Queue List e selecione a fila desejada.
Na página Queue Details, clique em na aba Retry Policy e, em seguida, clique em em Edit.
-
No painel Modify Retry Policy, configure os valores de Inherit Instance Configurations, Maximum Number of Deliveries e Consumption Timeout Period com base nos intervalos mencionados anteriormente.
Se a fila herdar a configuração da instância, sua política de retry seguirá a definição no nível da instância. Qualquer alteração na configuração da instância atualiza automaticamente a política da fila.
Caso a fila não herde a configuração da instância, ela terá uma política de retry independente que substituirá a configuração do nível da instância.
-
Clique em em OK.