深入浅出 消息队列—— 消息过滤原理

深入浅出消息队列----【消息过滤原理】

• 过滤放在 Broker 还是 Consumer？

• Tag 和 SQL

• • Tag 标签过滤
  • SQL 属性过滤

• Tag 过滤原理解析

• SQL 属性过滤原理解析

本文属于个人学习笔记。
归纳整理了原文章中的关键知识点。
记录了个人见解。
文章来源：[编程导航-鱼皮【yes哥深入浅出消息队列专栏

过滤放在 Broker 还是 Consumer？

若将消息过滤功能部署于消费者端，则该消费者将接收所有类型的消息；其中具备消费需求的消息则会被主动接收；而不具备消费需求的消息则会予以忽略。这样一来是否会给消费者带来额外负担？

因此，过滤要放在 Broker 里。

也就是说，在消费者主动获取消息的过程中Broker会将仅传递符合消费者需求的消息，并自动地剔除不必要的信息。

Tag 和 SQL

那 RocketMQ 支持怎样的过滤方式呢？

官方提供了两种方式，分别是：

1. Tag 标签过滤
2. SQL 属性过滤

Tag 标签过滤

这个是生产上最常用消息的过滤方式。

操作相当简便，在生产阶段发送消息时，系统会自动给每条消息附加一个Tag标签（每条消息仅允许设置一个Tag标签）。

    message.s