From f44135f835bf62319f9bb8a32e4592a707e5e8c1 Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期日, 27 四月 2025 11:09:55 +0800
Subject: [PATCH] SSO登录逻辑再修改
---
pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/TestController.java | 62 +++++++++++++++++++++++++++++++
1 files changed, 62 insertions(+), 0 deletions(-)
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/TestController.java b/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/TestController.java
new file mode 100644
index 0000000..0a6a028
--- /dev/null
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/TestController.java
@@ -0,0 +1,62 @@
+package com.dy.pipIrrApp.workOrder.mqtt;
+
+import lombok.extern.slf4j.Slf4j;
+import org.eclipse.paho.client.mqttv3.MqttClient;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author ZhuBaoMin
+ * @date 2024-11-16 11:32
+ * @LastEditTime 2024-11-16 11:32
+ * @Description
+ */
+
+@Slf4j
+@RestController
+@RequestMapping(path = "mqtt")
+public class TestController {
+
+ @Value("${mqtt.broker}")
+ private String broker;
+
+ @Value("${mqtt.username}")
+ private String username;
+
+ @Value("${mqtt.password}")
+ private String password;
+
+ @Value("${mqtt.topic}")
+ private String topic;
+
+ @Value("${mqtt.qos}")
+ private Integer qos;
+
+ @GetMapping("/mqtt/{msg}")
+ public String testSendMqttMsg(@PathVariable("msg") String msg){
+ log.info("娑堟伅鍐呭锛歿}.", msg);
+
+ MqttClient mqttClient = MqttClientConnectorPool.connectMQTT(broker, username, password);
+ MqttMsgSender sender = new MqttMsgSender();
+
+ String content = "{" + " \"message\": \"" + msg + "\"," + " \"val\": 100.00" + "}";
+
+ if (null != mqttClient){
+ sender.sendMessage(mqttClient, topic, content, qos);
+ } else {
+ log.info("MqttClient涓虹┖锛屾棤娉曞彂閫侊紒");
+ return "澶辫触锛�";
+ }
+ return "鎴愬姛锛�";
+ }
+
+ @GetMapping("/receive")
+ public String receiveMsg() {
+ MqttMsgSubscriber subscriber = new MqttMsgSubscriber();
+ subscriber.readSubscribeTopicMessage();
+ return "success";
+ }
+}
--
Gitblit v1.8.0