微信小程序是腾讯于 2017 年 1 月 9 日推出的一种不需要下载安装即可在微信平台上使用的应用程序，用户扫一扫或者搜一下即可打开应用。也体现了「用完即走」的理念，用户不用关心是否安装太多应用的问题。应用将无处不在，随时可用，但又无需安装卸载。对于开发者而言，小程序开发门槛相对较低，难度不及 APP，能够满足简单的基础应用，对于用户来说，能够节约使用时间成本和手机内存空间，对于开发者来说也能节约开发和推广成本。

在物联网场景中，实现小程序与物联网设备间的通讯，就可以通过小程序对设备进行指令下发，在手机上轻松进行设备状态监控及数据查看。因此，很多物联网项目需要使用微信小程序连接基于 MQTT 的物联网平台。

本文将主要介绍如何在微信小程序中使用 MQTT，实现小程序客户端与 MQTT 服务器的连接、订阅、收发消息、取消订阅等功能。

❏ 前期准备

注册微信小程序帐号，并下载微信开发者工具 (https://developers.weixin.qq.com/miniprogram/dev/devtools/download.html)。由于微信小程序安全要求比较高，在与后台服务器之间的通讯必须使用 https 或 wss 协议，因此要在微信小程序后台设置域名服务器。

微信小程序仅支持通过 WebSocket 进行即时通信，EMQ X 的 MQTT Over WebSocket 能够完全兼容使用在微信小程序上。但由于微信小程序的规范限制，EMQ X 使用微信小程序接入时需要注意以下几点：

broker.emqx.iowss://broker.emqx.io

添加完成后，在微信小程序开发时才允许我们于该域名地址下的服务器进行通信与交互。

❏ 新建项目

准备完成前期网络通讯相关工作后，我们打开已经下载好了的微信开发者工具，打开后在页面点击新建一个小程序项目，如下图所示：

点击确认后，微信开发者工具就自动初始化好了项目，我们就可以开始开发了。

❏ 安装 MQTT 客户端库

因为小程序是通过 JavaScript 开发的，因此可以使用 MQTT.js 作为 MQTT 客户端库。

从小程序基础库版本 2.2.1 (https://developers.weixin.qq.com/miniprogram/dev/framework/compatibility.html) 或以上、及开发者工具 (https://developers.weixin.qq.com/miniprogram/dev/devtools/download.html) 1.02.1808300 或以上开始，小程序支持使用 npm 安装第三方包。如感兴趣的读者可自行查看小程序 npm 支持的 (https://developers.weixin.qq.com/miniprogram/dev/devtools/npm.html) 官方文档来操作使用，本文为简化操作过程，将不使用 npm 的方式安装。我们将在 utils 文件夹下新建一个 mqtt.js 文件，我们直接获取在 MQTT.js CDN 上的打包构建后的源码复制 mqtt.js 文件中。

MQTT.js CDN 地址：https://unpkg.com/mqtt@4.0.1/dist/mqtt.min.js 可通过浏览器打开查看。

完成后我们，在 index.js 主页面中直接 import 即可：

import mqtt from '../../utils/mqtt'

EMQ X Cloud 是全托管的云原生 MQTT 消息服务，用户通过可靠、实时的物联网数据移动、处理和集成，可以轻松连接海量物联网设备，同时无需进行基础设施管理维护，对于开发者来说十分方便。

因此本文将使用 EMQ X Cloud 提供的免费公共 MQTT 服务器 (https://www.emqx.com/zh/mqtt/public-mqtt5-broker) 作为本次测试的 MQTT 服务器地址，服务器接入信息如下：

• Broker: broker.emqx.io

• TCP Port: 1883

• SSL/TLS Port: 8883

更多详情请访问 EMQ X Cloud 官网 (https://www.emqx.com/zh/cloud)，或查看 EMQ X Cloud 文档(https://docs.emqx.cn/cloud/latest/)。

❏ 连接代码

微信小程序使用 WebSocket 的方式连接到 MQTT 服务器，但连接的 URL 地址中请使用 wxs 协议名称，连接及初始化数据的关键代码：

Page({
  data: {
    client: null,
    host: 'broker.emqx.io:8084',
    topic: 'testtopic/miniprogram',
    msg: 'Hello! I am from WeChat miniprogram',
    mqttOptions: {
      protocolVersion: 4, //MQTT连接协议版本
      clientId: 'emqx_cloud_miniprogram',
      clean: true,
      password: '',
      username: '',
      reconnectPeriod: 1000, // 1000毫秒，两次重新连接之间的间隔
      connectTimeout: 30 * 1000, // 1000毫秒，两次重新连接之间的间隔
      resubscribe: true // 如果连接断开并重新连接，则会再次自动订阅已订阅的主题（默认true）
    },
  },
  connect() {
    this.data.client = mqtt.connect(`wxs://${this.data.host}/mqtt`, this.data.mqttOptions)
    this.data.client.on('connect', () => {
      wx.showToast({
        title: '连接成功'
      })
    })
  },

})

❏ 订阅主题

subscribe() {
  this.data.client.subscribe(this.data.topic)
  wx.showToast({
    title: '主题订阅成功'
  })
},

❏ 取消订阅

unsubscribe() {
  this.data.client.unsubscribe(this.data.topic)
  wx.showToast({
    title: '取消订阅成功'
  })
},

❏ 消息发布

publish() {
  this.data.client.publish(this.data.topic, this.data.msg)
},

❏ 断开连接

disconnect() {
  this.data.client.end()
  wx.showToast({
    title: '断开连接成功'
  })
},

我们在小程序中简单编写了如下应用界面，该应用具备：创建连接、订阅主题、收发消息、取消订阅、断开连接等功能。

完整的项目示例代码：https://github.com/emqx/MQTT-Client-Examples/tree/master/mqtt-client-wechat-miniprogram

使用 MQTT 5.0 客户端工具 - MQTT X (https://mqttx.app/zh) 作为另一个客户端进行消息收发测试。

可以看到 MQTT X 可以正常接收来到来自小程序发送过来的消息，同样，使用 MQTT X 向该主题发送一条消息时，也可以看到小程序能正常接收到该消息。