RocketMQ_高级特性之消息过滤_2-【官方】百战程序员_IT在线教育培训机构

RocketMQ分布式消息队列的消息过滤方式有别于其它MQ中间件，是在Consumer端订阅消息时再做消息过滤的。RocketMQ这么做是在于其Producer端写入消息和Consumer端订阅消息采用分离存储的机制来实现的，Consumer端订阅消息是需要通过ConsumeQueue这个消息消费的逻辑队列拿到一个索引，然后再从CommitLog里面读取真正的消息实体内容，所以说到底也是还绕不开其存储结构。其ConsumeQueue的存储结构如下，可以看到其中有8个字节存储的Message Tag的哈希值，基于Tag的消息过滤正是基于这个字段值的。

主要支持如下2种的过滤方式 (1) Tag过滤方式：Consumer端在订阅消息时除了指定Topic还可以指定TAG，如果一个消息有多个TAG，可以用||分隔。其中，Consumer端会将这个订阅请求构建成一个 SubscriptionData，发送一个Pull消息的请求给Broker端。Broker端从RocketMQ的文件存储层—Store读取数据之前，会用这些数据先构建一个MessageFilter，然后传给Store。Store从 ConsumeQueue读取到一条记录后，会用它记录的消息tag hash值去做过滤，由于在服务端只是根据hashcode进行判断，无法精确对tag原始字符串进行过滤，故在消息消费端拉取到消息后，还需要对消息的原始tag字符串进行比对，如果不同，则丢弃该消息，不进行消息消费。

以某电商平台为例，订单消息和支付消息属于不同业务类型的消息，分别创建Topic_Order和Topic_Pay，其中订单消息根据商品品类以不同的Tag再进行细分，列如电器类、男装类、女装类、化妆品类等被各个不同的系统所接收。通过合理的使用Topic和Tag，可以让业务结构清晰，更可以提高效率，这就涉及到消息过滤。

RocketMQ支持的消息过滤方式如下：

过滤方式	说明	场景
Tag过滤（默认过滤方式）	发送者：设置消息Tag。订阅者：订阅消息Tag。订阅的Tag和发送者设置的消息Tag一致，则消息被投递给消费端进行消费。	简单过滤场景。一条消息支持设置一个Tag，仅需要对Topic中的消息进行一级分类并过滤时可以使用此方式。
SQL属性过滤	发送者：设置消息的自定义属性。订阅者：订阅时自定义SQL过滤表达式，根据自定义属性过滤消息。满足过滤表达式的消息被投递给消费端进行消费。	复杂过滤场景。一条消息支持设置多个自定义属性，可根据SQL语法自定义组合多种类型的表达式对消息进行多级分类并实现多维度的过滤。

实时效果反馈

1.使用sql过滤的优点不包括哪个

A 支持复杂场景过滤

B 支持自定义属性过滤

C 支持多种协议

答案

1=>C

RocketMQ_高级特性之消息过滤_1 RocketMQ_高级特性之消息过滤_3

北京市昌平区回龙观镇南店村综合商业楼2楼226室