MQTTs连接失败（SSL握手错误）：求支持证书的React Native MQTT库

问题分析 #

你遇到的mqtts server connection failure MqttException (0) - javax.net.ssl.SSLHandshakeException: connection closed错误，核心原因是sp-react-native-mqtt不支持SSL证书配置，导致客户端无法通过服务器的SSL身份验证，服务器主动关闭连接。下面推荐两款支持证书配置的成熟MQTT库，并给出配置示例。

推荐库及使用示例 #

1. mqtt.js（通用MQTT客户端，完美支持React Native） #

这是目前社区最广泛使用的MQTT客户端库，完全支持SSL/TLS的各类证书配置，包括CA证书、客户端双向认证证书与私钥。

安装

npm install mqtt --save

带证书配置的连接代码

import mqtt from 'mqtt';

// 证书文件可放置在项目根目录或assets文件夹，通过require引入
const caCert = require('./ca.crt');       // 用于验证服务器证书的CA证书
const clientCert = require('./client.crt'); // 双向认证时需提供客户端证书
const clientKey = require('./client.key');   // 双向认证时需提供客户端私钥

const client = mqtt.connect('mqtts://your-host:8883', {
  clientId: 'your-unique-client-id',
  // SSL核心配置
  ca: caCert,
  cert: clientCert, // 仅双向认证场景需要
  key: clientKey,   // 仅双向认证场景需要
  rejectUnauthorized: true, // 自签名证书场景可临时设为false（生产环境不建议）
});

// 连接成功回调
client.on('connect', () => {
  console.log('MQTTs连接成功');
  client.subscribe('your-target-topic', { qos: 0 }, (err) => {
    if (!err) console.log('已订阅目标主题');
  });
});

// 错误监听
client.on('error', (err) => {
  console.error('MQTT连接错误:', err);
});

// 消息接收监听
client.on('message', (topic, message) => {
  console.log(`收到主题[${topic}]的消息: ${message.toString()}`);
});

// 连接断开监听
client.on('close', () => {
  console.log('MQTT连接已断开');
});

2. react-native-paho-mqtt（基于Eclipse Paho的React Native封装） #

适合对MQTT规范兼容性要求较高的场景，同样完整支持SSL证书配置。

安装

npm install react-native-paho-mqtt --save

带证书配置的连接代码

import { Client } from 'react-native-paho-mqtt';

const client = new Client({
  uri: 'mqtts://your-host:8883',
  clientId: 'your-unique-client-id',
  ssl: true,
  // SSL配置项
  sslOptions: {
    ca: require('./ca.crt'),
    cert: require('./client.crt'), // 双向认证时添加
    key: require('./client.key'),   // 双向认证时添加
    rejectUnauthorized: true,
  },
});

// 连接断开监听
client.onConnectionLost((response) => {
  console.error('连接断开:', response.errorMessage);
});

// 消息接收监听
client.onMessageArrived((message) => {
  console.log(`收到消息: ${message.payloadString}`);
});

// 发起连接
client.connect()
  .then(() => {
    console.log('MQTTs连接成功');
    client.subscribe('your-target-topic', { qos: 0 });
  })
  .catch((err) => {
    console.error('连接失败:', err);
  });

证书配置说明 #

• CA证书：用于验证服务器证书合法性。若服务器使用权威CA签发的证书，系统默认信任，无需手动配置；若为自签名证书，必须将CA证书（或服务器证书）配置到客户端。
• 客户端证书/私钥：仅服务器要求双向SSL认证时需要配置，用来向服务器证明客户端身份。
• 证书存放：证书文件（.crt/.pem/.key）可放在项目根目录或assets文件夹，通过require引入即可，注意Android/iOS的文件权限配置。

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