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