現在のプロジェクトでは、外部温度センサーを NODE-RED に接続しようとしています。
MQTT を外部センサーに接続しました。このセンサーは、tempMeasurement
トピックを含むデータを公開しています。MQTT パブリッシャーの構成は次のとおりです。
public class MQTTPublisher {
// public static final String BROKER_URL =
// "tcp://broker.mqttdashboard.com:1883";
public static final String BROKER_URL = "tcp://test.mosquitto.org:1883";
private MqttClient client;
public MQTTPublisher() {
try {
client = new MqttClient(BROKER_URL, MqttClient.generateClientId(),
new MemoryPersistence());
client.connect();
} catch (MqttException e) {
e.printStackTrace();
}
}
public void publish(String topicName, int qos, byte[] payload)
throws MqttException {
final MqttTopic topic = client.getTopic(topicName);
final MqttMessage message = new MqttMessage(payload);
topic.publish(message);
System.out.println("Published data. Topic: " + topic.getName()
+ " Message: " + payload);
}
}
Node-RED の反対側では、"tempMesurement" をサブスクライブする MQTT ノードを作成しました。NODE-RED での MQTT ノードの構成は次のとおりです。
私の問題は、上の図に示すように、MQTT サブスクライバー ノードが切断されたメッセージを表示していることです。提案していただけますか - NODE-RED の構成の何が問題になっていますか? この問題を解決するにはどうすればよいですか?