`//constMQTT_URL="ws://192.168.50.221:8083/mqtt";//常量MQTT_PORT=8083;constMQTT_TIMEOUT=4000;//constMQTT_TOPIC="设备/字段/更新/CR-7iA/WS01_PL04_01/INP_CURRENT";尝试{if(item.url?.length){leturl=newURL(item.url);让端口=url.端口；if(port?.length){letc=mqtt.connect(`${item.url}`,{port:`${port}`,connectTimeout:MQTT_TIMEOUT,keepalive:5,clientId:"mqtt_t_sub"+newDate（）。的价值（）}）;c.on("connect",e=>{console.info("=========SUBSCRIBERCONNECTED");c.subscribe(`${item.topicUrl}`,{},(err,granted)=>{//console.info(err,granted);if(granted){c.on("message",(topic,payload,packet)=>{//console.info(">>"+payload.toString());让stringData=payload.toString(),objData;if(stringData.includes('{')||stringData.includes('[')){objData=JSON.parse(stringData);}elseif(payload.buffer){objData=newInt32Array(newUint8Array(payload).buffer);}//console.info(">>JSON.parse(stringData)",objData);_this.callbackFun(item,objData);});}});});c.on("断开连接",e=>{console.info("=========已断开连接",e);})c.on("error",e=>{console.info("=========SUBSCRIBERERROR...",e);})}}}catch(e){console.log(e);}`先上代码MQTT(websocket)类入门教程【http://blog.itpub.net/6995813...】
