Este glossário define os conceitos fundamentais do ApsaraMQ for RocketMQ. Os termos estão agrupados por função: estruturação de mensagens, produção e consumo, gerenciamento e monitoramento.
Mensagens
Tópico
O tópico é o classificador principal das mensagens. Produtores enviam mensagens para um tópico e consumidores se inscrevem nele para recebê-las. Cada tópico contém uma ou mais filas de mensagens (partições).
Para orientações sobre como estruturar tópicos, consulte Práticas recomendadas de tópicos e tags.
Tag
A tag é um classificador secundário que categoriza as mensagens dentro de um tópico. Enquanto o tópico define a categoria ampla da mensagem, as tags permitem filtrar subconjuntos específicos de mensagens nesse tópico.
Para orientações sobre o uso de tags com tópicos, consulte Práticas recomendadas de tópicos e tags.
Mensagem
A mensagem é a unidade básica de transferência de dados no ApsaraMQ for RocketMQ. Cada mensagem pertence a um tópico e pode conter uma tag opcionalmente.
ID da mensagem
Identificador globalmente único atribuído automaticamente pelo ApsaraMQ for RocketMQ a cada mensagem. Use IDs de mensagens para rastrear e consultar mensagens individuais.
Chave da mensagem
Identificador de nível de negócio definido pelo produtor para associar uma mensagem a uma lógica de negócios específica. Ao contrário do ID da mensagem (gerado pelo sistema), a chave da mensagem é definida pela aplicação e ajuda a localizar mensagens relacionadas a uma operação de negócios específica.
Fila de mensagens
Também conhecida como partição de tópico. A fila de mensagens é uma partição física dentro de um tópico. Cada tópico contém uma ou mais filas, atribuídas automaticamente durante a criação. Não é possível alterar o número de filas de um tópico após a criação.
Produtores
Produtor
Entidade (também chamada de publicador de mensagens) que cria e envia mensagens para o ApsaraMQ for RocketMQ.
Instância do produtor
Processo cliente do produtor. Diferentes instâncias podem executar em processos separados ou em máquinas distintas. As instâncias do produtor são seguras para threads: uma única instância pode executar várias threads no mesmo processo.
Consumidores
Consumidor
Entidade (também chamada de assinante de mensagens) que recebe e processa mensagens do ApsaraMQ for RocketMQ. O ApsaraMQ for RocketMQ oferece suporte a dois tipos de consumidor:
|
Tipo de consumidor |
Comportamento |
|
Push consumer |
O broker envia as mensagens ao consumidor. |
|
Pull consumer |
O consumidor busca ativamente as mensagens no broker. Apenas o SDK TCP para Java oferece suporte a esse tipo de consumidor. |
Pull consumers exigem uma instância Enterprise Platinum Edition. Para obter detalhes, consulte Métodos e parâmetros e Inscrever-se em mensagens.
Instância do consumidor
Processo cliente do consumidor. Diferentes instâncias podem executar em processos separados ou em máquinas distintas. Cada instância usa um pool de threads para processar mensagens.
Offset do consumidor
O offset do consumidor rastreia o progresso de leitura de um Pull consumer em uma partição. Pull consumers consomem mensagens de uma partição sequencialmente. Cada partição possui os seguintes marcadores de offset:
MaxOffset: Número total de mensagens na partição.
MinOffset: Ponto inicial da partição.
ConsumerOffset: Quantidade de mensagens já consumidas.
O número de mensagens não consumidas (acumuladas) corresponde ao MaxOffset menos o ConsumerOffset.
Grupo
Coleção lógica de produtores ou consumidores. Todos os clientes de um grupo produzem ou consomem o mesmo tipo de mensagem e seguem a mesma lógica de publicação/assinatura.
ID do grupo
Identificador único de um grupo.
Modos de consumo
O ApsaraMQ for RocketMQ oferece suporte a dois modos de consumo. A diferença está na entrega de cada mensagem: para apenas um consumidor ou para todos os consumidores de um grupo.
|
Modo |
Comportamento de entrega |
Exemplo (9 mensagens, 3 consumidores) |
|
Consumo por clustering |
As mensagens são distribuídas uniformemente entre os consumidores do grupo. Cada mensagem vai para um único consumidor. |
Cada consumidor processa 3 mensagens. |
|
Consumo por broadcasting |
Todos os consumidores do grupo recebem todas as mensagens. |
Cada consumidor processa todas as 9 mensagens. |
Para obter detalhes, consulte Consumo por clustering e consumo por broadcasting.
Tipos de mensagem
Mensagem agendada
Mensagem entregue aos consumidores em um momento específico. O broker retém a mensagem até o horário de entrega agendado.
Para obter detalhes, consulte Mensagens agendadas e mensagens atrasadas.
Mensagem atrasada
Mensagem entregue aos consumidores após um período de atraso especificado. Ao contrário da mensagem agendada (entregue em horário fixo), a mensagem atrasada é entregue após um intervalo de tempo relativo ao momento do envio.
Para obter detalhes, consulte Mensagens agendadas e mensagens atrasadas.
Mensagem transacional
Mensagem que participa de uma transação distribuída. O ApsaraMQ for RocketMQ fornece um mecanismo de transação distribuída semelhante ao X/Open XA (eXtended Architecture) para garantir consistência eventual nas transações distribuídas.
Para obter detalhes, consulte Mensagens transacionais.
Mensagem ordenada
Mensagem publicada e consumida em ordem estrita FIFO (first-in, first-out).
Para obter detalhes, consulte Mensagens ordenadas.
Mensagem ordenada por partição
Mensagem ordenada dentro de uma partição específica, e não em todo o tópico. O ApsaraMQ for RocketMQ usa uma chave de sharding para atribuir mensagens às partições. Mensagens que compartilham a mesma chave de sharding são publicadas e consumidas em ordem FIFO estrita dentro da partição.
Uma chave de sharding não pode ser usada como chave de mensagem.
Para obter detalhes, consulte Mensagens ordenadas.
Operações e monitoramento
Acúmulo de mensagens
O acúmulo de mensagens ocorre quando os consumidores não conseguem acompanhar a taxa de envio dos produtores. Mensagens não consumidas se acumulam no broker.
Mensagens acumuladas = Mensagens em trânsito + Mensagens prontas
Mensagens em trânsito: Mensagens em processamento pelos consumidores, mas ainda não confirmadas.
Mensagens prontas: Mensagens disponíveis para consumo, mas ainda não entregues.
Filtragem de mensagens
Mecanismo executado no broker que permite aos consumidores receber apenas mensagens correspondentes a tags específicas. Como a filtragem ocorre no broker, mensagens irrelevantes nunca chegam ao consumidor.
Para obter detalhes, consulte Filtragem de mensagens.
Rastreamento de mensagens
Registro completo do ciclo de vida de uma mensagem, desde a publicação pelo produtor até o processamento pelo consumidor. Cada rastreamento inclui timestamps e locais ao longo de toda a rota: produtor, broker e consumidor. Use rastreamentos de mensagens para diagnosticar problemas de entrega e verifique o fluxo das mensagens.
Para obter detalhes, consulte Consultar rastreamentos de mensagens.
Redefinição de offset do consumidor
Redefine o progresso de consumo de um grupo de consumidores para um ponto específico no tempo. Após a redefinição, os consumidores releem todas as mensagens enviadas depois do timestamp especificado. O intervalo de redefinição limita-se à janela de armazenamento persistente, que é de três dias por padrão.
Para obter detalhes, consulte Redefinir offsets de consumidor.
Fila de mensagens mortas
Fila dedicada que armazena mensagens sem consumo bem-sucedido. Quando uma mensagem falha no consumo, o ApsaraMQ for RocketMQ tenta entregar novamente automaticamente. Se a falha persistir após o número máximo de tentativas, ela se torna uma mensagem morta e é movida para a fila de mensagens mortas associada àquele grupo de consumidores, em vez de ser descartada.
Para obter detalhes, consulte Filas de mensagens mortas.