在 Apache RocketMQ 中，消息过滤功能是通过哪些机制实现的？请说明其工作原理。

回答思路

1. 【回答框架 1】RocketMQ 消息过滤主要基于消息属性和 Tag 实现，分为 Tag 过滤和 SQL 属性过滤两种方式。Tag 过滤是 Broker 端在消息投递时根据消费者订阅的 Tag 表达式进行匹配，只将符合 Tag 的消息发送给消费者。
2. 【回答框架 2】SQL 属性过滤通过 SQL92 语法对消息的自定义属性进行条件判断，Broker 端会解析 SQL 表达式并过滤消息，支持更复杂的过滤逻辑，但会增加 Broker 的计算开销。
3. 【回答框架 3】两种过滤方式都在 Broker 端完成，消费者端无需额外处理，但 Tag 过滤性能更高，SQL 过滤更灵活。实际应用中应根据过滤复杂度选择合适的机制。
4. 【回答框架 4】RocketMQ 的过滤机制还支持基于类过滤器的扩展，但默认实现以 Tag 和 SQL 属性为主，理解其原理有助于优化消息消费性能。
5. 【关键点 1】Tag 过滤基于消息 Tag 与订阅 Tag 的精确匹配，实现简单高效。
6. 【关键点 2】SQL 属性过滤支持 SQL92 语法，可对消息属性进行复杂条件判断。
7. 【关键点 3】过滤在 Broker 端执行，减少无效消息传输，但 SQL 过滤会增加 Broker 负载。
8. 【关键点 4】选择过滤方式需权衡性能与灵活性，Tag 过滤适合简单场景，SQL 过滤适合复杂场景。
9. 【易错点 1】不要混淆 Tag 过滤与 SQL 过滤的适用场景，SQL 过滤虽灵活但性能开销更大。
10. 【易错点 2】避免在过滤条件中使用过多复杂 SQL 表达式，可能导致 Broker 性能下降。
11. 【易错点 3】注意 Tag 过滤是精确匹配，不支持模糊匹配，需合理设计 Tag 命名规范。