From 96f7af2f3bf9a36dd48e0e6bf4f8a8ca1e31ed7d Mon Sep 17 00:00:00 2001
From: vince <757871790@qq.com>
Date: 星期三, 08 十一月 2023 17:49:56 +0800
Subject: [PATCH] Merge remote-tracking branch 'orgin/igds-api-gateway' into igds-api-gateway
---
src/main/java/com/fzzy/mqtt/MqttConsumerCallBack.java | 53 +++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 53 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/fzzy/mqtt/MqttConsumerCallBack.java b/src/main/java/com/fzzy/mqtt/MqttConsumerCallBack.java
new file mode 100644
index 0000000..127cfe8
--- /dev/null
+++ b/src/main/java/com/fzzy/mqtt/MqttConsumerCallBack.java
@@ -0,0 +1,53 @@
+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) {
+ log.info("涓庢湇鍔″櫒鏂紑杩炴帴锛屽彲閲嶈繛");
+ }
+
+ /**
+ * 娑堟伅鍒拌揪鐨勫洖璋�
+ */
+ @Override
+ public void messageArrived(String topic, MqttMessage message) throws Exception {
+
+
+ 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);
+ }
+
+ /**
+ * 娑堟伅鍙戝竷鎴愬姛鐨勫洖璋�
+ */
+ @Override
+ public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
+ log.info(String.format("鎺ユ敹娑堟伅鎴愬姛"));
+ }
+}
--
Gitblit v1.9.3