本文详解如何在 azure 平台上构建可扩展、低延迟的设备到设备（d2d）通信，重点对比 iot hub 与 event grid mqtt broker 的适用场景，并提供边缘 mqtt 方案作为补充选项。
本文详解如何在 azure 平台上构建可扩展、低延迟的设备到设备（d2d）通信，重点对比 iot hub 与 event grid mqtt broker 的适用场景，并提供边缘 mqtt 方案作为补充选项。
在 Azure IoT 生态中，实现设备 A 与设备 B 的直接通信（如 ESP8266 → ESP8266 或 Python 模块 → 嵌入式终端），不能依赖传统“设备直连”——Azure 不允许设备间建立点对点 TCP/UDP 连接。所有通信必须经由云服务中继或边缘代理。以下是三种主流、生产就绪的架构路径，按推荐优先级排序：
✅ 首选：Azure Event Grid MQTT Broker（推荐用于新架构）
自 2023 年起，Azure Event Grid 支持原生 MQTT 协议，提供标准的发布/订阅模型，无需自建服务即可实现轻量级 D2D：
- 设备 A 使用 mosquitto_pub 或 SDK 连接到 Event Grid MQTT 端点（<namespace>.eventgrid.azure.net:8883），发布至主题如 devices/A/sensor；
- 设备 B 订阅相同主题（如 devices/+/sensor 或 devices/B/sensor），实时接收消息；
- 全托管、自动扩缩、支持 QoS 1、TLS 1.2 加密，且与 IoT Hub 完全解耦。
# 示例：设备 A 发布（使用 mosquitto）
mosquitto_pub -h "myeg.mqtt.eventgrid.azure.net" \
-p 8883 -u "myeg" -P "your-sas-token" \
-t "devices/A/telemetry" -m '{"temp":25.3,"ts":1717023456}' \
--cafile ./cert.pem --tls-version tlsv1.2⚠️ 注意：Event Grid MQTT 当前为预览功能，需在 Azure 门户启用并申请配额；SAS token 需通过 Azure CLI 或 REST API 动态生成（不建议硬编码）。
⚙️ 兼容方案：IoT Hub + Azure Functions（适用于已上线系统）
若你已基于 IoT Hub 实现设备接入（如 ESP8266 成功上报 telemetry），无需推翻重来，可通过路由+函数实现 D2D：
- 在 IoT Hub 中配置消息路由：将 Device A 的 telemetry 路由至 Service Bus Queue 或 Event Grid Topic（避免直接路由至 Functions，降低冷启动延迟）；
- Azure Function（C# / Python）监听队列，解析 payload，调用 IoT Hub 的 Cloud-to-Device (C2D) 消息 API 向 Device B 发送消息；
- Device B 通过 ReceiveAsync()（C SDK）或 iothub_client_sample_mqtt 示例中的 C2D 回调机制接收。
# Azure Function (Python) 示例片段
import azure.iot.hub
from azure.iot.hub.models import Message
def main(queueItem: str):
# 解析 Device A 数据，构造发往 Device B 的指令
msg = Message(b'{"cmd":"led_on","id":"A2B"}')
msg.content_type = "application/json"
msg.content_encoding = "utf-8"
# 使用 IoT Hub 连接字符串发送 C2D
iothub = azure.iot.hub.IoTHubRegistryManager("HostName=xxx.azure-devices.net;SharedAccessKeyName=service;SharedAccessKey=xxx")
iothub.send_c2d_message("DeviceB", msg)✅ 优势：复用现有 IoT Hub 设备身份、证书和安全策略；
❌ 局限：端到端延迟约 300–800ms，不适用于亚秒级协同控制。
? 边缘增强：IoT Operations MQTT Broker（适合本地闭环场景）
当设备位于同一局域网、要求超低延迟或离线可用时，可在本地服务器或网关部署 Azure IoT Operations 内置 MQTT Broker：
- 支持标准 MQTT v3.1.1/v5.0，兼容 ESP-IDF、Paho、AWS IoT SDK；
- 设备 A/B 直连 mqtt://edge-gateway.local:1883，发布/订阅任意主题；
- 通过 IoT Operations 管理集群、TLS 证书、ACL 权限，并可选上行同步关键事件至云端。
? 提示：该方案将通信逻辑下沉至边缘，大幅降低云依赖与带宽消耗，是工业现场、智能楼宇等场景的理想选择。
总结选型建议
| 场景 | 推荐方案 | 关键理由 |
|---|---|---|
| 新建项目，需快速验证 D2D | Event Grid MQTT | 零运维、开箱即用、Pub/Sub 天然匹配 |
| 已用 IoT Hub，仅需增补 D2D 功能 | IoT Hub + Functions + C2D | 无架构改造，复用设备注册与安全体系 |
| 本地网络、高实时性、弱网/离线需求 | IoT Operations MQTT Broker | 微秒级延迟、完全自主可控 |
无论选择哪条路径，请始终遵循最小权限原则：为每个设备分配独立 SAS token 或 X.509 证书，禁用匿名访问，并在 IoT Hub/Event Grid 中启用诊断日志以审计消息流。
