RocketMQ如何实现消息过滤?

提问者:帅平 问题分类:面试刷题
RocketMQ如何实现消息过滤?
2 个回答
有个笨蛋住进我心
有个笨蛋住进我心
有两种方案:
一种是在 Broker 端按照 Consumer 的去重逻辑进行过滤,这样做的好处是避免了无用的消息传输到 Consumer 端,缺点是加重了 Broker 的负担,实现起来相对复杂。
另一种是在 Consumer 端过滤,比如按照消息设置的 tag 去重,这样的好处是实现起来简单,缺点是有大量无用的消息到达了 Consumer 端只能丢弃不处理。
一般采用Cosumer端过滤,如果希望提高吞吐量,可以采用Broker过滤
发布于:4周前 (08-21) IP属地:四川省
我来回答