send 函数

function mqttSend(publishTopic, subscribeTopic, payload, _this) {

let qos = 2;

let { client } = _this;

client.publish(publishTopic, JSON.stringify(payload), qos);

client.subscribe(subscribeTopic);

}
传入参数调用send函数
 

onConnect() {

let _this = this;

let payload = {

//参数放在这里

};

let { publishTopic, subscribeTopic } = _this.MQTToption;

mqttSend(publishTopic, subscribeTopic, payload, _this);

},

//请求路径

 let MQTToption = {

      url: '',

      clientId: this.clientId,

      timeout: 10 * 1000,

      keepAliveInterval: 10,

      cleanSession: false,

      ssl: false,

      diviceID: 'macsn',

      publishTopic: ``,

      subscribeTopic: ``,

    };

    this.MQTToption = MQTToption;

    let { url, clientId, publishTopic, subscribeTopic } = MQTToption;

    let client = new Paho.Client(url, clientId);

    this.client = client;
//接受消息的函数
 

  onMessageArrived(message) {

      debugger

      console.log('------------------onMessageArrived');

      let _this = this;

      let { payloadString } = message;

      let messageReceive = JSON.parse(payloadString);

 
}