RocketMQ 过滤消息分为两种，一种tag过滤，另外一种是复杂的sql过滤。

tag过滤 

首先创建producer然后启动，在这里创建了字符串的数组tags。字符串数组里面放置了多个字符串，然后去发送15条消息。

15条消息随着i的增长，然后取模做了一个哈希，值是0 1 2。要么是taga，要么是tagb，或者tagc。也就是topic TagFilterTest 里面的每条消息都会有一个tag。

15条消息会从taga到c。前面三条是 Tag A B C，到了第四条开始也是从A开始，第五条B，第六条C。

上面就是将15条消息打上tag然后发送过去。

消费者创建了consumer，消费者也去订阅这个主题。consumer会从这个主题上面去进行消费。

和之前消费者不同的地方在于"TagA || TagC"   这里写上了tag过滤的表达式。也就是消费者会去订阅这个主题里面标签为taga和tagc这样的消息，消费者是可以收到的。

这个过滤是在broker端还是消费端？

如果是broker端进行过滤的，那么会将a和c直接发给消费者，tagb是不会发送的。

如果是消费端过滤，那么会将所有的消息发给消费者，消费者收到所有消息的时候，那么会去消费a和c，那么b就不消费了。

消费者这里只消费了10条消息，可以看到消息带着的标签。只有a c是收到的，b是没有收到的。

实际上是broker过滤这些消息，broker将一些消费者需要的消息发送过去。其实也就是broker将消息已经过滤了。

这样来说，消费者的性能是得到了保证，这样就不需要在消费者这端再做一次消息的过滤。而是broker将已经过滤好的消息推送给你，你直接消费就行了。

tag过滤的限制，限制是⼀条消息只能有⼀个 标签，这可能不适⽤于复杂的场景。在这种情况下，您可以使⽤ SQL 表达式来过滤掉消息。

使⽤SQL过滤