|
@@ -147,6 +147,9 @@ const startListening = () => {
|
|
});
|
|
});
|
|
|
|
|
|
mqttClient.on('message', (topic, message) => {
|
|
mqttClient.on('message', (topic, message) => {
|
|
|
|
+ console.log(
|
|
|
|
+ `【接收设备mqtt消息】 topic是 ${topic} , message : ${JSON.parse(message.toString())}`
|
|
|
|
+ );
|
|
if (topic === MQTT_TOPIC) {
|
|
if (topic === MQTT_TOPIC) {
|
|
const parsedMessage: MqttMessage = JSON.parse(message.toString());
|
|
const parsedMessage: MqttMessage = JSON.parse(message.toString());
|
|
handleMqttMessage(parsedMessage);
|
|
handleMqttMessage(parsedMessage);
|