在Spark Streaming中为MQTT创建自定义接收器

问题描述

我需要使用通过MQTT broker从IoT设备获得的数据上的火花进行分析。我的Spark作业与MQTT代理之间的连接是可以在其中订阅特定主题的。我已经在spark中使用MQTTUtils库连接到代理，但是我对该库的内部工作方式有疑问。我注意到的是，“ MQTTutils.createStream”连接到主题的MQTT代理。在这种情况下，如果我必须在MQTT代理中订阅100个主题，则它可能会建立与代理的100个连接。在实际情况下，这是不希望的。请让我知道它是否不能按照我的方式工作。

因此，我决定为MQTT代理创建自定义接收器，以便可以在MQTT客户端中管理连接。我已经阅读了有关如何实现自定义接收器的文档，但是我没有以正确的方式成功实现它。

如果有人亲自操作了这样的自定义接收器，请帮助我使其生效。

感谢您的支持，因为这对我的解决方案至关重要

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）