RocketMQ 源碼分析 09 消息過濾

1、消息消費過濾機制 1.1 根據 tagcode 過濾 使用messageTag比對， 存儲的Message Tag和訂閱的Message Tag 1.2 高級過濾使用FilterServer 重點看下DefaultMessageStore#getMessage 1.設置拉取偏移量，從 PullRequest 中獲取，初始從消費進度中獲取 2.根據 topic、queueId 獲取消息隊列（Co

>>阅读原文<<