阿里云-消息队列-用户指南.pdf

阿里云消息队列（MQ）是一款高效、稳定、可靠的消息中间件服务，为企业级应用提供高可用、低延迟的消息传输。本用户指南主要涵盖了MQ的主要功能和操作，包括消息删除、消费进度重置、消息查询以及消息过滤等关键概念。 **删除消息** MQ提供了两种删除消息的方式： 1. **删除Topic**：这将彻底删除整个Topic，意味着所有订阅该Topic的消费者将不再接收到任何消息。这种操作通常是当Topic不再需要或者需要清理旧数据时执行。 2. **重置消费进度**：针对消费者，可以重置消费进度到当前时间，从而跳过历史消息，仅消费当前时间之后的新消息。此外，也可以指定一个更早的时间点来重新消费历史消息，这对于处理丢失或未正确处理的消息非常有用。 **消息查询** MQ提供了多种查询消息的方法： 1. **按Message Topic查询**：可以根据Topic遍历查询该Topic下的所有消息，但若Topic消息量大，可能会返回大量记录，适用于日常调试。 2. **按Message Key查询**：如果在发送消息时指定了Key属性，可以通过Key唯一定位到该消息。建议每个消息的Key尽可能唯一，否则查询结果可能会包含多条记录。Key查询最多返回64条记录。 3. **按Message ID查询**：Producer发送消息后会返回Message ID，通过Message ID可以在控制台唯一查询到对应的消息。MessageBody以二进制形式存储，需要下载后使用文本编辑器查看。 **消息投递状态** MQ的消息投递状态包括： - **NOT_ONLINE**：订阅端不在线，消息无法投递。 - **CONSUMED**：消息已被成功投递，无论消费者如何响应（如ReconsumerLater、NULL响应或异常），消息状态均为已消费。 - **CONSUMED_BUT_FILTERED**：消息已投递，但被消费者过滤，例如订阅条件不符。 - **NOT_CONSUME_YET**：消息尚未被投递，可能是堆积未消费，或者消费线程出现问题。 **消息过滤** MQ支持基于Tag的消息过滤，让消费者能够根据消息的Tag在服务端过滤消息。例如，在电商交易场景中，不同类型的交易消息（订单、支付、物流）会被发送到同一个Topic，不同系统订阅不同Tag的消息，如物流系统只订阅“logistics”Tag，而实时计算系统订阅所有Tag。 **发送消息与Tag的使用** 发送消息时，每条消息必须指定一个Tag来标识消息类型。消费者可以有以下几种订阅方式： - **消费方式-1**：订阅Topic下所有类型的消息，使用通配符“*”。 - **消费方式-2**：订阅特定Tag的消息，明确指定Tag名称。 - **消费方式-3**：订阅多个Tag的消息，多个Tag之间用“||”分隔。 - **消费方式-4**（错误示例）：一个消费者不应多次订阅同一Topic的不同Tag，因为后者的订阅会覆盖前者。 通过理解并正确使用这些功能，用户可以有效地管理和处理MQ中的消息流，确保消息的正确传递和消费，从而优化应用程序的性能和稳定性。