使用MQTTnet与AWS IoT：可连接发布但订阅失败求助

针对你遇到的能连接、发布但订阅就断开的情况，按以下步骤排查：

1. 先获取断开的具体原因 #

首先给MQTT客户端添加断开事件监听，打印详细错误信息，这是定位问题的核心：

mqttClient.DisconnectedAsync += async e =>
{
    Console.WriteLine($"断开原因：{e.Reason}");
    if (e.ClientDisconnectOptions?.ReasonCode != null)
    {
        Console.WriteLine($"MQTT断开代码：{e.ClientDisconnectOptions.ReasonCode}");
    }
    if (e.Exception != null)
    {
        Console.WriteLine($"异常详情：{e.Exception.ToString()}");
    }
};

比如如果是权限问题，通常会返回**1008（政策违规）**的断开代码，或者在原因里提到权限不足。

2. 检查AWS IoT的IAM权限策略 #

能发布但订阅失败，大概率是权限缺失。确保你的IAM策略包含以下动作，且资源覆盖对应的主题和主题过滤器：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "iot:Connect",
                "iot:Publish",
                "iot:Subscribe", // 订阅必须的动作
                "iot:Receive"    // 接收消息必须的动作
            ],
            "Resource": [
                "arn:aws:iot:你的AWS区域:你的AWS账号ID:topic/vin/my-vin",
                "arn:aws:iot:你的AWS区域:你的AWS账号ID:topicfilter/vin/my-vin" // 订阅用的主题过滤器资源
            ]
        }
    ]
}

注意：订阅操作对应的资源是topicfilter前缀，而发布是topic前缀，两者都要包含。

3. 显式指定MQTT协议版本 #

AWS IoT对MQTT 3.1.1支持更稳定，MQTTnet 4.x默认可能使用的版本不匹配，显式指定版本：

var mqttClientOptions = new MqttClientOptionsBuilder()
    .WithWebSocketServer(signedRequestUrl)
    .WithProtocolVersion(MqttProtocolVersion.V311) // 强制使用3.1.1版本
    .Build();

4. 确认客户端ID的合法性 #

AWS IoT要求客户端ID唯一，且不能包含特殊字符（如空格、斜杠等）。如果你的签名URL是基于IAM生成的，客户端ID需要和生成签名时使用的一致，或者确保符合AWS的命名规范。

5. 显式指定订阅的QoS等级 #

AWS IoT支持QoS 0和1，显式指定QoS避免默认值不兼容：

var result = await mqttClient.SubscribeAsync(new MqttTopicFilterBuilder()
    .WithTopic("vin/my-vin")
    .WithQualityOfServiceLevel(MqttQualityOfServiceLevel.AtMostOnce) // 或AtLeastOnce
    .Build());

按以上步骤排查，尤其是第一步的错误日志，能快速定位问题。如果是权限问题，调整IAM策略后即可解决；如果是协议版本或客户端ID问题，对应调整配置即可。

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