From 768308ab47041062d9e97745099784acf297286b Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期三, 08 十一月 2023 17:45:37 +0800
Subject: [PATCH] 提交粮情测试协议和流程
---
src/main/java/com/fzzy/mqtt/MqttConsumerCallBack.java | 29 +++++++++++++++++++++++------
1 files changed, 23 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/fzzy/mqtt/MqttConsumerCallBack.java b/src/main/java/com/fzzy/mqtt/MqttConsumerCallBack.java
index cbf2aca..127cfe8 100644
--- a/src/main/java/com/fzzy/mqtt/MqttConsumerCallBack.java
+++ b/src/main/java/com/fzzy/mqtt/MqttConsumerCallBack.java
@@ -1,17 +1,27 @@
package com.fzzy.mqtt;
+import com.fzzy.gateway.hx2023.service.OnReceiveMqttService;
+import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+@Slf4j
+@Component
public class MqttConsumerCallBack implements MqttCallback {
+
+
+ @Autowired
+ private OnReceiveMqttService onReceiveMqttService;
/**
* 瀹㈡埛绔柇寮�杩炴帴鐨勫洖璋�
*/
@Override
public void connectionLost(Throwable throwable) {
- System.out.println("涓庢湇鍔″櫒鏂紑杩炴帴锛屽彲閲嶈繛");
+ log.info("涓庢湇鍔″櫒鏂紑杩炴帴锛屽彲閲嶈繛");
}
/**
@@ -20,10 +30,17 @@
@Override
public void messageArrived(String topic, MqttMessage message) throws Exception {
- System.out.println(String.format("鎺ユ敹娑堟伅涓婚 : %s", topic));
- System.out.println(String.format("鎺ユ敹娑堟伅Qos : %d", message.getQos()));
- System.out.println(String.format("鎺ユ敹娑堟伅鍐呭 : %s", new String(message.getPayload())));
- System.out.println(String.format("鎺ユ敹娑堟伅retained : %b", message.isRetained()));
+
+ String messageStr = new String(message.getPayload());
+
+
+ log.info(String.format("鎺ユ敹娑堟伅涓婚 : %s", topic));
+ log.info(String.format("鎺ユ敹娑堟伅Qos : %d", message.getQos()));
+ log.info(String.format("鎺ユ敹娑堟伅鍐呭 : %s", messageStr));
+
+ log.info(String.format("鎺ユ敹娑堟伅retained : %b", message.isRetained()));
+
+ onReceiveMqttService.onReceiveMessage(messageStr);
}
/**
@@ -31,6 +48,6 @@
*/
@Override
public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
- System.out.println(String.format("鎺ユ敹娑堟伅鎴愬姛"));
+ log.info(String.format("鎺ユ敹娑堟伅鎴愬姛"));
}
}
--
Gitblit v1.9.3