rocketmq的消息过滤-sql方式


通常我们会使用Tag过滤

特殊情况下我们也可以使用userproperties+TAGS过滤 , sql92定义

这两种都是在服务器端完成过滤, 对于超大数据量的场景(1小时4000W+)不要在客流端过滤

大集群中broker服务器达到千台级别,小应用consumer只有几台服务器

sql过滤的几点说明:

  • 兼容tag过滤, tag名称变成TAGS
  • consumer没有判断 IS NOT NULL, broker会自己判断,如果为null, 不会投递
  • 版本不能太低

https://rocketmq.apache.org/docs/filter-by-sql92-example/
https://www.kunzhao.org/blog/2018/04/02/rocketmq-message-filter-flow/


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM