HarmonyOS 鸿蒙Next mqtt连接不上，有偿求最简单成功连接例子

HarmonyOS 鸿蒙Next mqtt连接不上，有偿求最简单成功连接例子

用的最新的套件，真机环境。 url前缀用wss显示连接成功，但订阅主题是没消息，而且是url乱填也是这样子，换成其它前缀都是失败，可远程有偿求救

1.新建项目

2.ohpm i @ohos/mqtt

3.在src/main/ets下新建mqtt目录，新建文件MyMqttClient.ets

import { MqttAsync, MqttClient, MqttQos, MqttSubscribeOptions } from '[@ohos](/user/ohos)/mqtt'

export class MyMqttClient {
  private mqttClient: MqttClient|null=null

  public createMqttClient() {
    let serverUrl: string ="ws://192.168.11:188" 
    let clientId: string = "clientId_panda" //'客户端,唯一就行'
    if(MqttAsync==undefined){
      console.log("1111111");
    }else{
      console.log("222222222");
    }
    // return ;

    this.mqttClient = MqttAsync.createMqtt({
      url: serverUrl,
      clientId: clientId,
      persistenceType: 1
    })
  }

  public async connectMqtt() {
    let result: boolean
    // if(this.mqttClient){
    //   console.log("1111111111111");
    // }else {
    //   console.log("2222222222222");
    // }
    if(this.mqttClient){
      await this.mqttClient.connect({
        userName: 'MQTT用户名',
        password: '连接密码',
        connectTimeout: 30,
        MQTTVersion: 0
      }).then(() => {
        result = true
        console.info('连接成功')
      }).catch(() => {
        result = false
        console.warn('连接失败')
      })
    }

  }

  public async subscribe() {
    let subscribeOption: MqttSubscribeOptions = {
      topic: '你的主题',
      qos: 0
    }
    if(this.mqttClient){
      await this.mqttClient.subscribe(subscribeOption).then((data) => {
        console.info('MQTT subscribe success ====>', JSON.stringify(data))
      }).catch((err: object) => {
        console.error('MQTT subscribe failed, Cause:', JSON.stringify(err))
      })

      this.mqttClient.messageArrived((err, data) => {
        if (err) {
          console.error('MQTT messageArrived failed, Cause:', JSON.stringify(err))
        }else {
          console.error('MQTT messageArrived success, 消息内容:', JSON.stringify(data))
        }
      })
    }

  }

  public pushMessage(pic: string, mes: string, qo: MqttQos) {
    if(this.mqttClient){
      this.mqttClient.publish({
        topic: pic,
        qos: qo,
        payload: mes
      }, (error, data) => {
        if (error) {
          console.error("Push message failed, Cause:", JSON.stringify(error))
        }else {
          console.info("Push message success", JSON.stringify(data))
        }
      })
    }

  }
  public destroy() {
    if(this.mqttClient){
      this.mqttClient.destroy().then((data) => {
        console.debug('Destroy the mqtt client', JSON.stringify(data))
      })
    }


  }
}