我是emqtt的新手。我正在尝试使用emq_auth_http,但它不起作用。
我有这3个请求来控制一些数据,并发送回状态为200的数据。
app.post('/mqtt/auth', function(req, res) {
console.log('This is body ', req.body);
res.status(200).send(req.body);
});
app.post('/mqtt/superuser', function(req, res) {
console.log('This is body in supe
我在paho-mqtt上测试了示例程序,我知道loop_forever()函数可以处理重新连接。但是我的问题是,尽管loop_forever()可以重新连接,但它不能重新订阅。服务器突然崩溃应该是个问题,在这种情况下,客户端还在监听,但当服务器重启时,客户端可以重新连接,但不能再订阅消息。我想也许我应该重写loop_forever()函数,但我不确定我是否正确,以及如何做到这一点。
import sys
try:
import paho.mqtt.client as mqtt
except ImportError:
# This part is only required to
我有一个哈普纳服务器,在IoT应用程序上。Happner服务器在端口55000上运行,我希望它将数据发送到同一台计算机上运行的MQTT客户机/代理。我们的想法是将Happner与MQTT客户端集成。我试着在网上四处看看,我发现这个叫做的模块,我认为它不完全符合我的需要,因为我在测试了下面的代码后没有得到这个消息。请建议我如何让这两个人(Happner和MQTT)进行交流。我想我只需要在运行MQTT的端口上发送包,然后它就会接收它。另外,请建议发送这样的数据包是可靠的吗?
var dgram = require('dgram');
var client = dgram.creat