在RocketMQ中，消息过滤功能可以通过Tag和SQL92表达式来实现。
示例代码：
Message message = new Message("TopicTest", "TagA", Encoding.UTF8.GetBytes("Hello RocketMQ"));
示例代码：
IMessageSelector selector = MessageSelector.BySql("a > 5");
consumer.Subscribe("TopicTest", selector);
需要注意的是，SQL92表达式过滤功能需要在RocketMQ服务器端开启，具体配置方法可参考RocketMQ官方文档。
