亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

Nodejs MQTT:取消訂閱不是一個函數

Nodejs MQTT:取消訂閱不是一個函數

心有法竹 2023-03-18 16:31:55
我很好地實施了 MQTT,但我遇到了方法問題unsubscribe。mqttCon.publish() , mqttCon.subscribe(), mqttCon.on()...除此以外,所有其他功能 ( ) 都運行良好。我已經檢查了拼寫,甚至完成了ctrl +click它,它把我帶到了庫實現,這意味著它是正確的方法并且引用得很好,但我一直收到下面的錯誤。我該如何解決?這是一行: mqttCon.unsubscribe(topic)TypeError: mqttCon.unsubscribe is not a function    at noopHandler (/home/dev/project-dir/src/mqtt/processMessage.js:5:13)    at module.exports (/home/dev/project-dir/src/mqtt/processMessage.js:10:20)    at MqttClient.client.on (/home/dev/project-dir/src/mqtt/mqttCon.js:16:13)    at MqttClient.emit (events.js:189:13)    at MqttClient._handlePublish (/home/dev/project-dir/node_modules/mqtt/lib/client.js:1271:12)    at MqttClient._handlePacket (/home/dev/project-dir/node_modules/mqtt/lib/client.js:410:12)    at work (/home/dev/project-dir/node_modules/mqtt/lib/client.js:321:12)    at Writable.writable._write (/home/dev/project-dir/node_modules/mqtt/lib/client.js:335:5)    at doWrite (/home/dev/project-dir/node_modules/mqtt/node_modules/readable-stream/lib/_stream_writable.js:428:64)    at writeOrBuffer (/home/dev/project-dir/node_modules/mqtt/node_modules/readable-stream/lib/_stream_writable.js:417:5)注意:我使用的是 ES6(Emacscript 6+) javascript 而不是Typescript。節點12.18.1和 npm6.14.6這是我的連接代碼mqttCon.js:const mqtt = require('mqtt')const processMessage = require('./processMessage')const logger = require('../logConf')const options = {    host: '',    port: '',    username:'',    password: '',    protocol: ''};const client = mqtt.connect(options)client.on("connect", function () {    console.log("MQTT connected  with status: " + client.connected);    if (client.connected) {        client.on('message', (topic, message) => {            processMessage(topic, String(message))        })    }})
查看完整描述

1 回答

?
慕蓋茨4494581

TA貢獻1850條經驗 獲得超11個贊

你的 mqttCon.js 文件沒有client.prototype.unsubscribe = function() {},所以錯誤是正確的。您正在定義client為一個模塊,但您確實需要mqtt.unsubscribe()在某個地方調用。因此,您需要unsubscribe()向常量添加一個函數client(在這種情況下實際上應該是一個函數var),或者mqtt.unsubscribe()在您的 processMessage.js 文件中需要 mqtt 模塊后調用該函數....我認為這與您正在嘗試的相反無論如何要做。


更新:以上影響了我的想法,問題是我正在導入processMessage.js哪個mqttCon.js又導入了哪個。循環導入,意思是mqttCon(mqttClient) was always not yet initialized inside processMessage.js. 解決方案是當客戶端已經初始化并導出為如下模塊時,我processMessage.js在塊內導入:client.on('connect'....)...



client.on("connect", () => {

? ? console.log("MQTT connected? with status: " + client.connected);

? ? if (client.connected) {

? ? ? ? client.on('message', (topic, message) => {

? ? ? ? ? ? require('./processMessage')(topic, String(message))

? ? ? ? })

? ? }

})


查看完整回答
反對 回復 2023-03-18
  • 1 回答
  • 0 關注
  • 330 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號