源码分析RocketMQ消息过滤机制上篇-----消息消费服务端过滤与TAG模式过滤实现

一、消息消费过滤机制 1.1 根据 tagcode 过滤 1.2 高级过滤 上述资源来源于 RocketMQ 官方文档。java 经过官方文档,咱们基本能够知道,消息的过滤机制与服务端息息相关,更细一点的讲,与拉取消息实现过程脱离不了关系,事实上也的确如此,MessageFilter 的使用者也就是 DefaultMessageStore#getMessage 方法,为了弄清楚消息过滤机制,咱们先
相关文章
相关标签/搜索