下载mqtt到项目
方式一：
npm 在我的项目出现了奇奇怪怪的问题。所以我选择方式二
方式二：
直接下载mqtt.js
地址：https://cdnjs.com/libraries/mqtt

image.png

image.png

image.png

import { $GLOBAL } from '../../app';
import mqtt from './mqtt';

let client = null;
const initMqtt = function (that) {
  let url = $GLOBAL.MQTT_URL;//url：类似于：'wss://mqtt.....
  let date = new Date().getTime();
  client = mqtt.connect(url, {
    protocol: 'wxs',
    clientId: 'wqs' + date,
    username: $GLOBAL.USERNAME,//账号
    password: $GLOBAL.PASSWORD,//密码
  });
  that.globalData.client = client;//为全局client赋值：在app.js
  client.on('connect', () => {
    console.log('连接成功');
  });
  client.on('message', (topic, payload) => {
    //在这里做处理：收到新消息走这个方法
    console.log('更新', topic + ':' + payload);
  });
  client.on('disconnect', () => {
    console.log('代理断开连接');
  });
  client.on('close', () => {
    console.log('断开连接');
  });
  client.on('offline', () => {
    console.log('脱机');
  });
  client.on('error', () => {
    console.log('无法连接');
    initMqtt();
  });
};
//添加订阅 ${$GLOBAL.MQTT_TOPIC}/user/${userId}订阅的主题地址：问后端，是直接返回还是拼接
const addSubscription = function (userId) {
    client.subscribe(`${$GLOBAL.MQTT_TOPIC}/user/${userId}`, err => {
      if (!err) {
        console.log('订阅成功');
      } else {
        console.log('订阅失败');
      }
    });
  },
  mqttFun = {
    initMqtt,
    addSubscription,
  };

module.exports = mqttFun;

使用：
app.js
1、添加全局client

image.png

2、在onLaunch注册mqtt

   // 全局注册mqtt:并防止重复注册
   if (!this.globalData.client) {
     mqttUtil.initMqtt(this);
   }

在页面你想订阅的地方添加订阅方法

  mqttUtil.addSubscription(info.userId);

//其他的问题
自己测试能不能收到消息

client.publish('订阅的地址', '发送内容')