Consulta de mensajes - ApsaraMQ for RocketMQ - Centro de documentación de Alibaba Cloud

ApsaraMQ for RocketMQ ofrece tres métodos para consultar mensajes: por ID de mensaje, por clave de mensaje y por tema. Utilice la función de consulta de mensajes para comprobar que un mensaje se envió correctamente, revisar su contenido y consultar su traza.

Métodos de consulta

De forma predeterminada, los mensajes en ApsaraMQ for RocketMQ se almacenan durante tres días. Por lo tanto, solo puede consultar mensajes de los últimos tres días. Por ejemplo, si la hora actual es 15:09:48 del 10 de junio de 2019, el mensaje más antiguo que puede consultar en un tema se envió a las 15:09:48 del 7 de junio de 2019.

La siguiente tabla describe y compara los tres métodos de consulta.

Método de consulta	Condición de consulta	Tipo de coincidencia	Descripción
Por ID de mensaje	tema + ID de mensaje	coincidencia exacta	Busca un mensaje específico según su tema e ID de mensaje para recuperar sus propiedades.
Por clave de mensaje	tema + clave de mensaje	coincidencia aproximada	Encuentra hasta 64 de los mensajes más recientes que coinciden con un tema y una clave de mensaje especificados. Importante Los productores deben asignar una clave única a cada mensaje. Si más de 64 mensajes comparten la misma clave, es posible que algunos no se devuelvan en los resultados de la consulta.
Por tema	tema + intervalo de tiempo	coincidencia por rango	Recupera todos los mensajes de un tema dentro de un intervalo de tiempo especificado. Este método puede devolver un gran volumen de mensajes, lo que dificulta encontrar uno específico.

Proceso de consulta recomendado

Se recomienda seguir este proceso para consultar mensajes.

消息查询

Procedimiento

Inicie sesión en la consola de ApsaraMQ for RocketMQ. En el panel de navegación izquierdo, haga clic en Instances.
En la barra de navegación superior, seleccione una región, como China (Hangzhou).
En la página Instances, localice la instancia deseada. En la columna Actions, haga clic en More y luego seleccione Message Query en la lista desplegable.
En la página Message Query, seleccione un método de consulta, introduzca la información obligatoria y haga clic en Search.
- Query by Message ID
  
  Para consultar un mensaje específico mediante coincidencia exacta, introduzca su tema e ID de mensaje. Registrar el ID del mensaje tras un envío exitoso simplifica la resolución de problemas.
  
  El siguiente código muestra cómo obtener el ID del mensaje mediante el SDK de Java.
```
   SendResult sendResult = producer.send(msg);
   String msgId = sendResult.getMessageId();
```
  Para otros lenguajes, consulte SDK reference overview.
- Query by Message Key
  
  ApsaraMQ for RocketMQ crea un índice para los mensajes basado en la clave de mensaje que usted establece. Al buscar un mensaje mediante la clave, ApsaraMQ for RocketMQ utiliza el índice para encontrar y devolver los mensajes coincidentes.
  Importante
  - Debe establecer la clave del mensaje al enviarlo para utilizar este método de consulta.
  - Una consulta por clave de mensaje devuelve únicamente los 64 mensajes coincidentes más recientes. Utilice claves únicas y distinguibles según su lógica de negocio.
  El siguiente código muestra cómo establecer una clave de mensaje.
```
        Message msg = new Message("Topic","*","Hello MQ".getBytes());
        /**
         * Set a unique business key for message retrieval. A globally unique key is recommended.
         * This allows you to query the message in the ApsaraMQ for RocketMQ console if you fail to receive it. 
         * If you do not set a key, message sending and receiving are not affected, but key-based queries will not work.
         */
      msg.setKey("TestKey"+System.currentTimeMillis());                                
```
- Query by Topic
  
  Utilice este método cuando desconozca el ID o la clave del mensaje. Especifique un tema y un intervalo de tiempo para recuperar todos los mensajes enviados durante ese periodo.
  Importante
  Al consultar mensajes por tema:
  - Esta búsqueda por rango puede devolver una gran cantidad de mensajes. Reduzca el intervalo de tiempo tanto como sea posible para limitar los resultados.
  - Los resultados se paginan porque la consulta puede devolver un volumen elevado de mensajes.

Resultados de la consulta

Puede consultar los mensajes obtenidos en la página Message Query de la consola. Los resultados incluyen el ID del mensaje, la etiqueta, la clave, la hora de producción y la hora de almacenamiento. También puede query message traces, verificar el consumo o descargar mensajes.

Verificación de consumo

ApsaraMQ for RocketMQ proporciona una función de verificación de consumo. Esta función le permite enviar un mensaje específico a un cliente en línea para probar su lógica de consumo y comprobar los resultados.

Importante

La verificación de consumo es únicamente una herramienta de prueba para la lógica del cliente. No afecta la entrega normal de mensajes ni modifica el estado de consumo del mensaje.

En el cuadro de diálogo de verificación de consumo, seleccione un group ID y un client ID, y luego haga clic en OK. La verificación de consumo puede provocar la reentrega del mensaje.

Referencias

En los resultados de la consulta, puede consultar la traza del mensaje para revisar su estado y resultado de consumo. Para obtener más información, consulte query message traces.