RocketMQ源码分析之过滤器ExpressionMessageFilter( 四 )

五、总结

  1. ConsumerFilterManager管理topic对应的各个消费组的过滤数据,提供了注册数据过滤对象,取消注册过滤数据对象等;
  2. ExpressionMessageFilter调用ConsumerFilterManager的BloomFilter组件中的isHit进行过滤;




推荐阅读