我已经创建了一个简单的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客户端Java库,并且我认为我正在以错误的方式重新连接到代理。目前,我有一个处理连接、断开、发布和订阅等MQTT操作的类。
public class MqttConnection {
private static final String BROKER_ADDRESS = Preferences.getProperty("mqtt-address");
private static final String BROKER_PORT = Preferences.getProperty("mqtt-port");
所以我使用ActiveMQ作为MQTT代理,如下所示: TransportConnector mqtt = new TransportConnector();
mqtt.setName(mqttBrokerConfig.getBrokerName());
URI uri = new URI("mqtt://some ip");
mqtt.setUri(uri);
final BrokerService broker = new BrokerService();
broker.setUseJmx(false); // Disable JMX for secure
我想要实现的场景是,首先我的服务将连接到一个mqtt代理,当我从一个will主题收到一条消息时,我想断开它与我的mqtt客户端所连接的代理的连接,并连接到一些其他的broker.is。
var mqtt = require('mqtt')
var client = mqtt.connect('mqtt://192.168.100.3')
client.on('connect', function () {
console.log("connected to broker")
client.subscribe(
当收到带有有效负载"0“的MQTT消息时,我使用mqtt-launcher ()执行命令。
下面是配置
logfile = '/home/user/mqtt-launcher/logfile'
mqtt_broker = 'broker' # default: 'localhost'. If using TLS, this must be set to the domain name signed by$
mqtt_port = 1883 # default: 18
我有问题的节点红色,不能再运行任何流,我不知道该做什么了。
我得到以下错误
Imported unrecognised type: mqtt-env-broker
Flows stopped due to missing node types. Check logs for details.
尝试从调色板中删除此模块,但得到以下错误,我也无法禁用它
Failed to remove: node-red-contrib-mqtt-env
Error: Type in use: mqtt-env-broker
Check the log for more information
我已经安装了节点-
在这里,如果telegraf到influxdb连接是成功的,因为当我重新启动telegraf时,它会创建我在配置文件中提到的db。但是mqtt公开的消息没有被telegraf接收,我甚至试图把它放入文件中,但是它是空的。所以有些地方出了问题。
import paho.mqtt.client as mqtt
from influxdb import InfluxDBClient
import json
influxclient = InfluxDBClient(host='localhost', port=8086)
# This is the Publisher
dict
我使用的是NodeJS的mqtt模块。一切工作正常,比如发布,订阅一个特定的主题,处理连接错误等等。问题是当我试图订阅所有主题时,这通常是作为client.subscribe('#',callback)完成的,它没有订阅任何主题。 相关代码如下: // Connecting to a specific topic
client = mqtt.connect(broker,options)
console.log("MQTT Connected")
client.on('connect',()=>{
client.subscribe