我正在编写一个非常基本的Node应用程序,它有三个组件: index.js、mqtt.js、slack.js。mqtt和slack模块都使用module.exports公开了它们的一些方法。但是,我只能向一个方向公开文件。代码示例:
index.js:
var slack = require('./slack');
var mqtt = require('./mqtt');
var client;
mqtt.connectMQTT(client);
slack.startServer();
slack.js:
var mqtt = require('
我安装了'node.js‘,然后从’‘命令行执行'npm install ’来安装'mqtt.js‘。现在要测试'mqtt客户端‘,我正在尝试执行:var mqtt = require('mqtt');,这会导致错误地说:
"Error: Cannot find module 'mqtt'
at Function.Module._resolveFilename (module.js:338:15)
at Function.Module._load (module.js:280:25)
at Modul
var pahoMqtt = require("paho-mqtt");
let client = new Paho.MQTT.Client("serverIp", port, "/ws", "clientId" + Math.round((new Date()).getTime() / 1000));
当我在节点服务器上运行它时,我得到了以下错误
stack:
[ 'ReferenceError: window is not defined',
' at LibraryFactor
我已经很好地实现了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-
我有一个Nest应用程序,我在那里使用、和 (实际上是从为Nest 8修复它的中使用的)。
现在,问题在于同时使用MikroORM和nest-mqtt:当它们都被导入到一个模块(MikroOrmModule.forRoot()和MqttModule.forRoot())中时,它会引发以下错误:
TypeError: Cannot set property length of #<Map> which has only a getter
at _clone (/home/ts/mikro-orm-nest-mqtt/node_modules/clone/clone.js:16
我正在处理一个我在互联网上发现的项目的例子,我试图知道如何从一个onclick调用一个简单的button方法。我所尝试的是宣布它为:
<button id="bt_connect" src="./js/example.js" onclick="mqtt_sub();">MQTT CONNECTION</button>
调用我在function中定义的./js/example.js
function mqtt_sub() {
var mqtt = require('mqtt');
var c
在我当前的项目中,我正在通过TemperatureSensor通过Node.js读取数据,并通过web-socket在浏览器上推送数据。Node.js代码如下所示:
var http = require('http');
var fs = require('fs');
var port = 8686;
var path = require('path');
var mqtt = require('mqtt');
var sock;
var tempValue,humidityValue,sensorMeasurement;
var
我已经创建了一个简单的node js代理和发布器,并且工作正常,请看一下下面的代码。
broker
--------------
//MQTT broker
var mosca = require('mosca')
var settings = {port:3000}
var broker= new mosca.Server(settings)
broker.on('ready',()=>{
console.log("Broker is ready")
})
出版商是
//mqtt publisher
var mqtt=req
我对mqtt和node.js完全陌生,我想定期从mqtt服务器获取数据并填充到我的html5页面中。
以下是我尝试连接但不确定是否正确的示例代码
var mqtt = require('mqtt');
// connect to the message server
var client = mqtt.connect('mqtt://test.mosquitto.org');
// publish 'Hello mqtt' to 'test'
client.publish('test', 'Hello
是否可以使用websockets和?我有下面的代码,但是没有任何工作。首先,我使用来自泛美卫生组织的mqttw31.js,在我的主机文件中,我定义了所有的连接细节。
src="js/mqttws31.js" type="text/javascript">
src="js/host.js" type="text/javascript">
var mqtt;
var recon
我尝试了以下库:
react-native-native-mqtt
react-native-mqtt
react_native_mqtt
sp-react-native-mqtt
他们中的大多数都给了我同样的错误:
null is not an object (evaluating 'Mqtt.createClient')
- node_modules/regenerator-runtime/runtime.js:63:36 in tryCatch
- node_modules/regenerator-runtime/runtime.js:293:29 in invoke
-
目标是使用mqtt协议发送数据。Java (tempSensor)使用mqtt协议和使用mqtt订阅的node.js生成诱惑值。node.js和java项目在发布/订阅时使用相同的密钥。我能够使用java项目发布数据,也可以在node.js中订阅数据。但是数据不是可读的格式。怎么做?所以数据是可读的格式。TempStruct的结构如下:
public class TempStruct implements Serializable {
private static final long serialVersionUID = 1L;
private double tempValue;
pub
我遵循了介绍的教程,但我无法将客户端连接到服务器。我总是收到以下错误消息(完整的堆栈跟踪):
Error: Connection refused: Bad username or password
at MqttClient._handleConnack (${project_dir}/node_modules/mqtt/lib/client.js:760:24)
at MqttClient._handlePacket (${project_dir}/node_modules/mqtt/lib/client.js:300:12)
at process (${project_dir}/node_
我使用socket.io、node.js和node.js MQTT客户端从HTMLS页面连接到运行在am上的代理。我可以成功地连接到代理并订阅我需要的主题,但是即使有几个主题排队,我也无法从这些主题中获得任何消息。
这是我的代码:
subscribe.js
var sys = require('sys');
var net = require('net');
var mqtt = require('mqtt');
var io = require('socket.io').listen(5000);
io.set('o
我已经创建了一个简单的代理: var mosca = require("mosca");
var settings = {
port: 1883,
};
var server = new mosca.Server(settings);
server.on("ready", function () {
console.log("ready");
}); 当我运行这个文件时,我得到了这个错误: /home//Documents/mqtt/node_modules/jsonschema/lib/validator.js:107
t