如何通过Azure IoT SDK的DeviceClient实现MQTT LWT遗嘱消息功能？

不需要切换到原生MQTT客户端，完全不需要做大规模重构。
官方Azure IoT SDK在后续迭代中已经原生支持LWT配置，仅需要升级SDK版本、调整DeviceClient初始化阶段的传输配置即可，你之前写的所有设备通信、方法调用、孪生同步等业务逻辑完全可以复用。

具体实现步骤 #

• 首先将你当前使用的Azure IoT Device SDK升级到最新稳定版（.NET SDK从v1.31.0版本开始支持该能力，Java、Python、Node.js SDK的对应正式版本也已同步上线该特性，升级无破坏性变更）
• 初始化DeviceClient时，不再直接用连接字符串重载方法创建实例，改用MqttTransportSettings自定义MQTT传输层参数
• 在MqttTransportSettings中给WillMessage属性赋值，配置遗嘱的主题、消息体、QoS等级、保留标记
• 把配置完成的传输设置传入DeviceClient创建方法，后续所有业务逻辑保持原有写法即可

最小代码示例（.NET/C#） #

// 配置MQTT传输层参数
var mqttTransport = new MqttTransportSettings(TransportType.Mqtt_Tcp_Only);
// 配置LWT遗嘱内容
mqttTransport.WillMessage = new WillMessage
{
    // 主题需符合IoT Hub的MQTT主题规范，示例为默认设备到云消息主题
    Topic = $"devices/{deviceId}/messages/events/",
    Payload = Encoding.UTF8.GetBytes("device abnormal offline"),
    Qos = QualityOfService.AtLeastOnce,
    Retain = false
};

// 组装认证与传输配置
var authProvider = new DeviceAuthenticationWithRegistrySymmetricKey(deviceId, deviceSymmetricKey);
ITransportSettings[] transportSettings = { mqttTransport };

// 创建设备客户端，后续逻辑和原有代码完全一致
var deviceClient = DeviceClient.Create(iotHubHostName, authProvider, transportSettings);
await deviceClient.OpenAsync();

注意事项 #

• 配置的遗嘱主题必须符合Azure IoT Hub的MQTT主题权限规则，否则会出现连接鉴权失败的问题
• LWT仅在设备异常断开（网络中断、设备掉电、未正常执行关闭流程就断开连接）时触发，主动调用CloseAsync/Dispose正常断开连接的场景下，IoT Hub不会投递遗嘱消息
• 遗嘱消息的路由、过滤规则和普通设备到云消息完全一致，可直接复用你现有的IoT Hub消息路由配置，不需要额外调整
• 如果你需要使用MQTT over WebSocket，只需要把传输类型改成Mqtt_WebSocket_Only即可，LWT配置逻辑完全相同

内容的提问来源于stack exchange，提问作者user19255201