uniapp 苹果 mqtt 如何实现连接和通信

在uniapp中开发iOS应用时，如何正确实现MQTT的连接和通信？我尝试了几个MQTT库但在iOS端总是连接失败，不知道是配置问题还是兼容性问题。具体需要关注哪些参数设置？有没有可用的示例代码或推荐的开源库？另外，iOS端是否有特殊的权限或证书要求？希望有经验的朋友能分享一下具体实现步骤和注意事项。

sinazl 1楼作者

在 uniapp 中，使用 MQTT.js 库连接苹果设备。先安装 mqtt 包，然后引入并创建客户端：

import mqtt from 'mqtt'
const client = mqtt.connect('mqtt://服务器地址')
client.on('connect', () => {
  client.subscribe('主题')
})
client.on('message', (topic, message) => {
  console.log(message.toString())
})
// 发送消息
client.publish('主题', '消息内容')

注意 iOS 需配置网络权限。

htzhanglong 2楼

在 UniApp 中实现苹果设备（iOS）的 MQTT 连接和通信，可以通过 mqtt.js 库实现。以下是详细步骤和示例代码：

1. 安装 MQTT 库

在项目根目录执行：

npm install mqtt --save

2. 连接 MQTT 服务器

import mqtt from 'mqtt/dist/mqtt';

// MQTT 连接配置
const options = {
  clean: true,           // 清除会话
  connectTimeout: 4000,  // 超时时间
  clientId: 'uniap_' + Math.random().toString(16).substr(2, 8), // 客户端ID
};

// 连接服务器（以公共测试服务器为例）
const client = mqtt.connect('wss://test.mosquitto.org:8081', options);

client.on('connect', () => {
  console.log('MQTT连接成功');
  // 订阅主题
  client.subscribe('test/topic', (err) => {
    if (!err) {
      console.log('订阅成功');
    }
  });
});

client.on('error', (error) => {
  console.log('MQTT连接失败:', error);
});

3. 消息收发处理

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

// 发送消息
const publishMessage = () => {
  client.publish('test/topic', 'Hello from UniApp!', (err) => {
    if (!err) {
      console.log('消息发送成功');
    }
  });
};

4. 断开连接

const disconnectMQTT = () => {
  client.end(); // 安全断开连接
};

注意事项：

iOS 限制：确保使用 wss://（WebSocket SSL）协议，iOS 对非安全连接限制严格
网络请求配置：在 manifest.json 中配置网络权限：

"app-plus": {
  "modules": {
    "MQTT": {}
  },
  "distribute": {
    "ios": {
      "urlschemewhitelist": ["ws", "wss"]
    }
  }
}

真机测试：iOS 真机需使用 HTTPS/WSS 协议，推荐使用专业 MQTT 服务（如 EMQX、阿里云等）

完整示例组件：

<template>
  <view>
    <button @click="connectMQTT">连接MQTT</button>
    <button @click="sendMessage">发送测试消息</button>
    <button @click="disconnect">断开连接</button>
  </view>
</template>

<script>
import mqtt from 'mqtt/dist/mqtt';
export default {
  data() {
    return {
      client: null
    };
  },
  methods: {
    connectMQTT() {
      this.client = mqtt.connect('wss://test.mosquitto.org:8081');
      // ... 添加事件监听（参考上文）
    },
    sendMessage() {
      if (this.client) {
        this.client.publish('test/topic', 'Hello UniApp!');
      }
    },
    disconnect() {
      if (this.client) {
        this.client.end();
      }
    }
  }
};
</script>