如何实现TDMQ中的Pulsar 广播

如何实现TDMQ中的Pulsar 广播，很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。
Pulsar订阅模型分类
Pulsar 支持的几种模式如下，依次是独占模式/高可用模式/分享模式/基于键值的分享模式。

Pulsar 广播模式
Pulsar 的订阅模式和很多 MQ 不太一样。比如 RabbitMQ/Kafka 等，一般消费端（Consumer）是直接去对接 Topic 的，然后 Consumer 自己又有个组的概念在配置中心去设置 offset，以此来决定是一起分享 Topic 的数据，还是每开发云主机域名个人都接收同样的数据。在 Pulsar 的消费订阅模型里，添加了一个 Subscription 的逻辑，Subscription 的 Type 决定了消费是独享还是分享。
于是广播模式可以用不同 Subscription 独享的模式来实现，具体架构可以参照下图：

代码实现
1. Full-mesh 的形创建 Java 项目（比如：Springboot – 这个应该是相对简单的 IDE 集成开发组件）
画重点
介绍链接：https://cloud.tencent.com/document/product/1179/44914

2. 创建一个 Component 用来全局使用 Producer 和 Consumers

这里创建了1个 Producer 和3个拥有 exclusive subscription 的 consumers（广播模式 – 我们期待他们3个每次都收到一样的信息）

3. 最外层的测试代码和简单的 Message 模型

跑起来测试一下，果然3个一起接收一样的消息
看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注开发云行业资讯频道，感谢您对开发云的支持。

相关推荐: 如何部署kubernates dashboard

如何部署kubernates dashboard，相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。直接部署官方默认的dashboard:官方默认的replica是1，可以下载官方的yaml文件，按需修…