C# rocketmq 消息过滤功能怎样

在RocketMQ中，消息过滤功能可以通过Tag和SQL92表达式来实现。

1. Tag过滤：在生产者发送消息的时候，可以为消息设置一个Tag，消费者在订阅消息的时候可以指定Tag来过滤消息。只有设置了相同Tag的消息才会被消费者接收。

示例代码：

Message message = new Message("TopicTest", "TagA", Encoding.UTF8.GetBytes("Hello RocketMQ"));

2. SQL92表达式过滤：RocketMQ支持通过SQL92表达式来过滤消息，只有满足表达式条件的消息才会被消费者接收。

示例代码：

IMessageSelector selector = MessageSelector.BySql("a > 5");
consumer.Subscribe("TopicTest", selector);

需要注意的是，SQL92表达式过滤功能需要在RocketMQ服务器端开启，具体配置方法可参考RocketMQ官方文档。