將外部MQTT發佈者與NODE-RED連接

在我當前的項目中，我嘗試將外部溫度傳感器連接到NODE-RED。將外部MQTT發佈者與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); 
    } 
}

論節點-RED的另一側，我已經創建MQTT節點，具有訂閱「tempMesurement」。 MQTT節點的在NODE-RED的配置如下：