如何解决哪些方法可用于扩展订阅客户端?
作为示例,假设有多个MQTT代理(数据源),每个代理都吸收很多消息。在我的应用程序中,我想处理这些消息并能够水平扩展我的应用程序。这些消息均匀地分布在各个主题之间,因此我的应用程序的每个实例都能够处理多个主题的消息。
有效负载中包含的每条消息都不应重复,也不应有唯一的ID。
当然,适当的队列/消息体系结构会更好地适合此用例,但是在MQTT Brokers的另一端,有一个遗留系统无法轻松替换。
到目前为止,我想到的唯一想法是保留一个中央存储,该存储为每个主题分配一个应用程序实例,并且这些实例从该中央存储中获取主题列表。 但是,这会带来一些缺点,因为故障转移和扩展事件变得难以处理,而又不会丢失数据或在下游创建重复项。
有没有更好的方法来扩展订户?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。