栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

「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

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/707157.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号