From d71e3a495a125811889fdf7c2a2ec0650e28262d Mon Sep 17 00:00:00 2001
From: doum <doum>
Date: 星期四, 25 十二月 2025 17:41:21 +0800
Subject: [PATCH] 最新版本541200007最新版本541200007
---
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttSubServiceImpl.java | 43 +++++++++++++++++++++++++++++++++++++++++++
1 files changed, 43 insertions(+), 0 deletions(-)
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttSubServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttSubServiceImpl.java
new file mode 100644
index 0000000..a3a9859
--- /dev/null
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttSubServiceImpl.java
@@ -0,0 +1,43 @@
+package com.doumee.service.business.impl.mqtt;
+
+import com.alibaba.fastjson.JSONObject;
+import com.doumee.mqtt.config.MqttConfig;
+import com.doumee.mqtt.service.MqttBizService;
+import com.doumee.mqtt.service.MqttToolService;
+import lombok.extern.slf4j.Slf4j;
+import org.eclipse.paho.client.mqttv3.MqttClient;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+/**
+ * 涓庣‖浠跺鎺ユ湇鍔�
+ * @author 姹熻箘韫�
+ * @date 2023/10/09 18:06
+ */
+@Service
+@Slf4j
+public class MqttSubServiceImpl implements MqttBizService {
+ @Autowired
+ private MqttPushCallback callBack ;
+ @Override
+ public MqttClient subscribe(MqttClient client,MqttConfig config,String[] topics){
+ log.error("mqtt璁㈤槄寮�濮�========寮�濮�"+ JSONObject.toJSONString(config));
+ client = MqttToolService.subscribe(client,config, topics,callBack);
+ log.error("mqtt璁㈤槄寮�濮�========缁撴潫"+ JSONObject.toJSONString(config));
+ return client;
+ }
+ @Override
+ public MqttClient unsubscribe(MqttClient client,MqttConfig config,String[] topics){
+ log.error("mqtt璁㈤槄寮�濮�========寮�濮�"+ JSONObject.toJSONString(config));
+ client = MqttToolService.unsubscribe(client,config, topics,callBack);
+ log.error("mqtt璁㈤槄寮�濮�========缁撴潫"+ JSONObject.toJSONString(config));
+ return client;
+ }
+
+ @Override
+ public MqttClient publish(MqttClient client,MqttConfig config, String topic, String param){
+ log.error("mqtt鍙戝竷娑堟伅========寮�濮�"+ JSONObject.toJSONString(config)+"\n"+param);
+ client = MqttToolService.pubMessage(client,config,param,topic,callBack);
+ log.error("mqtt鍙戝竷娑堟伅========缁撴潫"+ JSONObject.toJSONString(config));
+ return client;
+ }
+}
--
Gitblit v1.9.3