Este glosario define los conceptos fundamentales de ApsaraMQ for RocketMQ. Los términos se agrupan por función: cómo se estructuran los mensajes, cómo se producen y consumen, y cómo se gestionan y monitorean.
Mensajes
Topic
Un topic es el clasificador principal de los mensajes. Los productores envían mensajes a un topic y los consumidores se suscriben a él para recibirlos. Cada topic contiene una o más colas de mensajes (particiones).
Para obtener orientación sobre cómo estructurar topics, consulte Best practices of topics and tags.
Tag
Un tag es un clasificador secundario que categoriza los mensajes dentro de un topic. Mientras que el topic define la categoría general del mensaje, los tags permiten a los consumidores filtrar subconjuntos específicos de mensajes dentro de ese topic.
Para obtener orientación sobre el uso de tags con topics, consulte Best practices of topics and tags.
Mensaje
Un mensaje es la unidad básica de transferencia de datos en ApsaraMQ for RocketMQ. Cada mensaje pertenece a un topic y, opcionalmente, puede incluir un tag.
ID de mensaje
Es un identificador único global que ApsaraMQ for RocketMQ asigna automáticamente a cada mensaje. Utilice los ID de mensaje para rastrear y consultar mensajes individuales.
Clave de mensaje
Es un identificador a nivel de negocio que establece el productor para asociar un mensaje con una lógica de negocio específica. A diferencia del ID de mensaje (generado por el sistema), la clave de mensaje la define la aplicación y ayuda a localizar mensajes relacionados con una operación de negocio concreta.
Cola de mensajes
También conocida como partición de topic. Una cola de mensajes es una partición física dentro de un topic. Cada topic contiene una o más colas, las cuales se asignan automáticamente al crear el topic. El número de colas de un topic no se puede modificar después de su creación.
Productores
Productor
Es una entidad (también llamada publicador de mensajes) que crea y envía mensajes a ApsaraMQ for RocketMQ.
Instancia de productor
Es un proceso cliente de productor. Distintas instancias de productor pueden ejecutarse en procesos separados o en máquinas diferentes. Las instancias de productor son seguras para hilos; una sola instancia puede ejecutar varios hilos dentro del mismo proceso.
Consumidores
Consumidor
Es una entidad (también llamada suscriptor de mensajes) que recibe y procesa mensajes de ApsaraMQ for RocketMQ. ApsaraMQ for RocketMQ admite dos tipos de consumidores:
|
Tipo de consumidor |
Comportamiento |
|
Push consumer |
El broker envía los mensajes al consumidor. |
|
Pull consumer |
El consumidor extrae activamente los mensajes del broker. Solo el SDK TCP para Java admite este tipo de consumidor. |
Los pull consumers requieren una instancia Enterprise Platinum Edition. Para más detalles, consulte Methods and parameters y Subscribe to messages.
Instancia de consumidor
Es un proceso cliente de consumidor. Distintas instancias de consumidor pueden ejecutarse en procesos separados o en máquinas diferentes. Cada instancia de consumidor utiliza un pool de hilos para procesar mensajes.
Offset de consumidor
El offset de consumidor registra hasta qué punto ha leído un pull consumer dentro de una partición. Los pull consumers consumen los mensajes de una partición de forma secuencial. Cada partición tiene los siguientes marcadores de offset:
MaxOffset: Número total de mensajes en la partición.
MinOffset: Punto de inicio de la partición.
ConsumerOffset: Cantidad de mensajes ya consumidos.
La cantidad de mensajes no consumidos (acumulados) es igual a MaxOffset menos ConsumerOffset.
Grupo
Es una colección lógica de productores o consumidores. Todos los clientes de un grupo producen o consumen el mismo tipo de mensajes y siguen la misma lógica de publicación/suscripción.
ID de grupo
Es un identificador único para un grupo.
Modos de consumo
ApsaraMQ for RocketMQ admite dos modos de consumo. La diferencia radica en si cada mensaje se entrega a un solo consumidor o a todos los consumidores de un grupo.
|
Modo |
Comportamiento de entrega |
Ejemplo (9 mensajes, 3 consumidores) |
|
Consumo por clúster |
Los mensajes se distribuyen uniformemente entre los consumidores del grupo. Cada mensaje se entrega a un solo consumidor. |
Cada consumidor procesa 3 mensajes. |
|
Consumo por difusión |
Cada consumidor del grupo recibe todos los mensajes. |
Cada consumidor procesa los 9 mensajes. |
Para más detalles, consulte Clustering consumption and broadcasting consumption.
Tipos de mensajes
Mensaje programado
Es un mensaje que se entrega a los consumidores en un momento específico. El broker retiene el mensaje hasta que llega la hora de entrega programada.
Para más detalles, consulte Scheduled messages and delayed messages.
Mensaje diferido
Es un mensaje que se entrega a los consumidores después de un periodo de retraso especificado. A diferencia de un mensaje programado (que se entrega a una hora fija), un mensaje diferido se entrega tras un intervalo de tiempo relativo contado desde su envío.
Para más detalles, consulte Scheduled messages and delayed messages.
Mensaje transaccional
Es un mensaje que participa en una transacción distribuida. ApsaraMQ for RocketMQ proporciona un mecanismo de transacción distribuida similar a X/Open XA (eXtended Architecture) para garantizar la consistencia eventual en las transacciones distribuidas.
Para más detalles, consulte Transactional messages.
Mensaje ordenado
Es un mensaje que se publica y consume en estricto orden FIFO (primero en entrar, primero en salir).
Para más detalles, consulte Ordered messages.
Mensaje ordenado por partición
Es un mensaje cuyo orden se mantiene dentro de una partición específica, no en todo el topic. ApsaraMQ for RocketMQ utiliza una clave de sharding para asignar mensajes a las particiones. Los mensajes que comparten la misma clave de sharding se publican y consumen en estricto orden FIFO dentro de su partición.
Una clave de sharding no se puede utilizar como clave de mensaje.
Para más detalles, consulte Ordered messages.
Operaciones y monitoreo
Acumulación de mensajes
La acumulación de mensajes ocurre cuando los consumidores no pueden seguir el ritmo al que los productores envían mensajes. Los mensajes no consumidos se acumulan en el broker.
Mensajes acumulados = Mensajes en tránsito + Mensajes listos
Mensajes en tránsito: Mensajes que los consumidores están procesando actualmente, pero que aún no han sido confirmados.
Mensajes listos: Mensajes disponibles para consumo, pero que aún no se han entregado.
Filtrado de mensajes
Es un mecanismo del lado del broker que permite a los consumidores recibir solo los mensajes que coinciden con tags específicos. Dado que el filtrado se ejecuta en el broker, los mensajes irrelevantes nunca se entregan al consumidor.
Para más detalles, consulte Message filtering.
Rastreo de mensajes
Es un registro completo del ciclo de vida de un mensaje, desde el momento en que un productor lo publica hasta que un consumidor lo procesa. Cada rastreo incluye marcas de tiempo y ubicaciones a lo largo de toda la ruta: productor, broker y consumidor. Utilice los rastreos de mensajes para diagnosticar problemas de entrega y verificar el flujo de mensajes.
Para más detalles, consulte Query message traces.
Restablecimiento de offset de consumidor
Restablece el progreso de consumo de un grupo de consumidores a un punto específico en el tiempo. Después del restablecimiento, los consumidores vuelven a leer todos los mensajes enviados después de la marca de tiempo especificada. El rango de restablecimiento está limitado a la ventana de almacenamiento persistente, que de forma predeterminada es de tres días.
Para más detalles, consulte Reset consumer offsets.
Cola de mensajes muertos
Es una cola dedicada que almacena mensajes que no se pudieron consumir correctamente. Cuando un mensaje falla al consumirse, ApsaraMQ for RocketMQ retries delivery automáticamente. Si el mensaje sigue fallando después del número máximo de reintentos, se convierte en un mensaje muerto y se mueve a la cola de mensajes muertos asociada a ese grupo de consumidores, en lugar de descartarse.
Para más detalles, consulte Dead-letter queues.