使用AWS IoT Device SDK v2连接AWS IoT时遇意外断连报错求助

报错原因分析 #

AWS_ERROR_MQTT_UNEXPECTED_HANGUP 是连接建立过程中被AWS IoT服务端主动断开的典型报错，常见诱因包括证书密钥不匹配、认证方式混用、权限不足、客户端ID冲突等。结合你的代码，以下是针对性的排查和修复方案：

修复步骤 #

1. 修正证书与密钥的文件名一致性 #

你的代码中，证书（cert）和私钥（key）的文件名存在差异：

• 证书文件名：96cf4fd7b42e237cf3e6505822cb89a71d2bff29e0149bc68b2536198e5cba6e.certificate.pem.crt
• 私钥文件名：96cf4fd7b42e237cf3e6505822cb89a72d1bff29e0149bc68b2536198e5cba6e.private.pem.key

两者中间的1d和2d不一致，会导致TLS握手失败，直接触发服务端断开连接。必须确保cert和key是同一套生成的文件。

2. 移除混用的认证配置 #

你使用的是mTLS证书认证，但额外添加了with_credentials(aws_region, aws_access_id, aws_secret_key)——这是SigV4签名认证的配置，两种认证方式不能混用。mTLS认证仅需证书、私钥和根CA文件，不需要Access Key和Secret Key。

3. 验证IoT策略权限 #

确保你的证书关联的IoT策略允许连接操作，策略至少包含以下权限（替换为你的AWS账号ID）：

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": "iot:Connect",
      "Resource": "arn:aws:iot:ap-south-1:你的AWS账号ID:client/Nestcms123"
    }
  ]
}

4. 检查客户端ID唯一性 #

如果同一个客户端ID被多个设备同时使用，AWS IoT会断开旧连接。确保Nestcms123未被其他设备占用。

5. 启用调试日志（可选） #

添加日志输出可查看连接过程中的详细错误：

io.enable_logging(io.LogLevel.Debug);

修正后的完整代码 #

import { Injectable } from '@nestjs/common';
import { io, iot, mqtt } from 'aws-iot-device-sdk-v2';
import * as path from 'path';

@Injectable()
export class AppService {
  async build_connection(): Promise<mqtt.MqttClientConnection> {
    const ca_file = path.resolve(__dirname, '../src/certs/AmazonRootCA1.pem');
    // 修正证书与私钥文件名，确保为同一套文件
    const cert = path.resolve(
      __dirname,
      '../src/certs/96cf4fd7b42e237cf3e6505822cb89a71d2bff29e0149bc68b2536198e5cba6e.certificate.pem.crt',
    );
    const key = path.resolve(
      __dirname,
      '../src/certs/96cf4fd7b42e237cf3e6505822cb89a71d2bff29e0149bc68b2536198e5cba6e.private.pem.key',
    );
    const client_id = 'Nestcms123';
    const endpoint = 'a3cz63qenxx11e-ats.iot.ap-south-1.amazonaws.com';

    // 启用调试日志，方便排查问题
    io.enable_logging(io.LogLevel.Debug);
    const client_bootstrap = new io.ClientBootstrap();

    const config_builder = iot.AwsIotMqttConnectionConfigBuilder.new_mtls_builder_from_path(cert, key);
    config_builder.with_certificate_authority_from_path(undefined, ca_file);
    config_builder.with_clean_session(false);
    config_builder.with_client_id(client_id);
    config_builder.with_endpoint(endpoint);

    const config = config_builder.build();
    const client = new mqtt.MqttClient(client_bootstrap);
    const connection = client.new_connection(config);

    connection.on('error', (error) => {
      console.error('连接错误:', error);
    });

    // 发起实际连接请求（原代码仅创建连接对象，未执行连接）
    await connection.connect();
    console.log('AWS IoT连接成功');

    return connection;
  }
}

注意：原代码仅创建了连接对象但未调用connect()方法发起连接，修正后的代码补充了这一步骤。

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