在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官方文檔。
