这个想法是要有一个适配器，并且在它的运输器内连接多个传感器。 将数据从所有当前连接的传感器转发到同一流。

请注意，在最终情况下，我没有任何MQTT服务器，但是在本教程的上下文中，我正在尝试实现等效于能够连接到可配置数量的MQTT服务器，能够更新ip地址的功能。 输入适配器已经在运行时的服务器数量和服务器数量。

您真的会在运行多个MQTT服务器吗？ 还是新传感器将通过现有服务器发布其读数？

我可以想象一个场景，您需要多个MQTT服务器来实现可伸缩性。 在这种情况下，您很可能希望启动一个附加的输入适配器，以将输入吞吐量扩展到流分析项目。

在典型配置中，您将具有某种消息代理，专门用于管理添加和删除大号传感器的管理。 MQTT恰好是用于这种情况的常见消息传递系统之一。

另一种方法是使用我们的Web服务接口，例如Web套接字。 在该体系结构中，流Web服务（" SWS"）侦听传入的连接请求，并且传感器软件将通过通过Web套接字连接推送更新来将其发布到项目中。 流服务器不必知道要发布多少个传感器，或者何时添加或删除单个传感器。

回到关于动态更改自定义适配器的运行时参数的特定问题，您必须停止并重新启动适配器才能使更改生效。 或者，您可以开始第二次。 适配器的第三，第四，...实例。 使用这种方法，您的代码将监视新的连接定义，并在找到其他连接定义时启动新的适配器实例。 删除连接仍然需要您关闭正在运行的适配器以停止连接到已删除的连接，然后使用剩余的连接启动新的适配器实例。

对我来说，这确实是很多工作，我真的建议您看看可用的消息传递协议和代理。 消息传递系统的基本范例是，双方仅需要知道如何连接到代理，并且可以实例化新的连接，而无需在代理级别进行特定于连接的配置。