RocketMQ消息過濾與查詢

消息過濾   RocketMQ分佈式消息隊列的消息過濾方式有別於其它MQ中間件，是在Consumer端訂閱消息時再做消息過濾的。RocketMQ這麼做是還是在於其Producer端寫入消息和Consomer端訂閱消息採用分離存儲的機制來實現的，Consumer端訂閱消息是需要通過ConsumeQueue這個消息消費的邏輯隊列拿到一個索引，然後再從CommitLog裏面讀取真正的消息實體內容，所以說

>>阅读原文<<