如何从多个端点发布到 AWS IoT Core 中的同一主题，而不丢失设备数据？

在 AWS IoT Core 中从多个端点发布到同一主题，而不会丢失设备数据

问题

在 AWS IoT Core 中，通过 MQTT 代理与设备进行通信。平台发布数据时，代理会接收，而来自设备的已发布数据会被中断。本文探讨了这种情况并提供了解决方法。

解决方案：创建主题层次结构

问题的关键在于创建不同的主题层次结构。

1. 创建层次结构： 将设备数据发布到特定主题（如 "device-data"），将平台数据发布到另一个主题（如 "platform-data"）。

2. 配置策略： 为设备创建策略，允许订阅 "device-data"；为平台创建策略，允许发布到 "platform-data"。

3. 发布消息： 从平台发布数据时，将其发布到 "platform-data"；设备将继续发布到 "device-data"，不受干扰。

优势

此解决方案提供了以下优势：

• 隔离： 设备和平台数据隔离到不同主题中，防止干扰。
• 可扩展性： 添加更多平台功能而不会影响设备发布。
• 可维护性： 简化主题管理，故障排除和维护更加容易。

实现

MQTT 客户端：

// 配置设备的 MQTT 客户端
MqttClient client = new MqttClient(brokerUrl, clientId, new MemoryPersistence());
client.connect(mqttOptions);
// 订阅 "device-data" 主题
client.subscribe("device-data");

平台 API：

// 配置平台 API 的 MQTT 客户端
MqttClient client = new MqttClient(brokerUrl, clientId, new MemoryPersistence());
client.connect(mqttOptions);
// 发布到 "platform-data" 主题
client.publish("platform-data", dataPayload.toString());

结论

通过创建主题层次结构和适当的策略配置，可以从多个端点发布到 AWS IoT Core 中的同一个主题，而不会导致设备已发布数据的中断。这确保了可靠的数据发布，并维护了设备和平台功能之间的隔离。

常见问题解答

1. 这种解决方案对我的应用程序性能有影响吗？

使用不同的主题层次结构通常不会对应用程序性能产生重大影响。然而，为了优化性能，建议使用 QoS 级别 1 或 2，并在必要时调整 MQTT 客户端的重试和超时设置。

2. 我可以使用不同的代理来实现这个解决方案吗？

是的，这个解决方案可以与任何支持 MQTT 协议的代理一起使用。然而，请确保代理配置为接受来自设备和平台的连接，并根据不同的主题层次结构授权订阅和发布。

3. 是否有替代的解决方案来解决这个问题？

另一种方法是使用 MQTT 野卡订阅。但是，这种方法可能会导致设备接收来自平台的不需要的消息。相比之下，使用主题层次结构提供了更好的隔离和控制。

4. 我可以使用 AWS IoT Greengrass 来实现此解决方案吗？

是的，AWS IoT Greengrass 可以与 MQTT 代理一起用于此解决方案。通过将 Greengrass 组配置为订阅不同的主题，您可以实现设备和平台数据的隔离。

5. 此解决方案是否适用于 AWS IoT 规则引擎？

是的，可以通过创建基于不同主题的规则来使用 AWS IoT 规则引擎。这允许您处理来自设备和平台的特定数据，并执行相应的操作。