在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官方文档。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
推荐阅读:RocketMQ C#的性能优化与调优