「RocketMQ专题」关于消息过滤Tag你不知道的事儿

「RocketMQ专题」关于消息过滤Tag你不知道的事儿

建议使用Tag做消息区分要指定消息模型为广播！！！ 

        我们都知道Tag是用来区分同一topic下不同业务的消息，我为什么要建议使用Tag要指定消息模型为广播呢。

举说明

 此时。系统A和系统B都会收到消息吗？

如果系统A不与系统B在同一消费者组下，正常消费，没有问题，如果在同一消费组下，就会收不到消息了。只要制定不同消费者组即可。为什么呢？

见官网解释：

因为消息的过滤是在消费端进行的，根据消息的tag选择时都消费。

同一topic指定不同的消费者组即可。那么我为什么建议制定模型为广播呢？

 随着你们公司的不断壮大。同一套系统部署在不同城市，如下图

同一topic下的同一消费组要根据配置文件中的tag进行消息过滤。动态制定tag。如果不指定消息模型为广播。那么就会像一开始一样，接收不到消息了。因为消息过滤是发生在消费端。

 官网对rocketmq设计的讲解rocketmq/design.md at master · apache/rocketmq · GitHubMirror of Apache RocketMQ. Contribute to apache/rocketmq development by creating an account on GitHub.https://github.com/apache/rocketmq/blob/master/docs/cn/design.md