From 167236d51d359745c6abe0b6ed827b2ff7d37a4b Mon Sep 17 00:00:00 2001
From: whycxzp <glperry@163.com>
Date: 星期二, 17 六月 2025 17:39:42 +0800
Subject: [PATCH] 领导层首页-运行监控界面
---
src/main/java/com/whyc/webSocket/MonitorSocket.java | 75 +++++++++++++++++++++++++++++++++++++
1 files changed, 75 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/whyc/webSocket/MonitorSocket.java b/src/main/java/com/whyc/webSocket/MonitorSocket.java
new file mode 100644
index 0000000..474ac35
--- /dev/null
+++ b/src/main/java/com/whyc/webSocket/MonitorSocket.java
@@ -0,0 +1,75 @@
+package com.whyc.webSocket;
+
+import com.whyc.config.WebSocketConfig;
+import com.whyc.dto.Response;
+import com.whyc.pojo.db_user.User;
+import com.whyc.service.LeaderHomeService;
+import com.whyc.service.MonitorService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import javax.servlet.http.HttpSession;
+import javax.websocket.*;
+import javax.websocket.server.ServerEndpoint;
+import java.io.IOException;
+
+/**
+ * 杩愯鐩戞帶鐣岄潰
+ */
+@Component
+@ServerEndpoint(value = "/monitor",encoders = WebSocketEncoder.class,configurator = WebSocketConfig.class)
+public class MonitorSocket {
+
+ private Session session;
+
+ private Thread thread;
+
+ private static MonitorService monitorService;
+
+ @Autowired
+ public void setMonitorService(MonitorService monitorService) {
+ MonitorSocket.monitorService = monitorService;
+ }
+
+ @OnOpen
+ public void onOpen(Session session, EndpointConfig config){
+ this.session = session;
+ HttpSession httpSession = (HttpSession) config.getUserProperties().get("httpSession");
+ User user = (User) httpSession.getAttribute("user");
+ Integer userId = user.getId();
+ Thread thread = new Thread() {
+ @Override
+ public void run() {
+ try {
+ while (!currentThread().isInterrupted()) {
+ Response response = monitorService.getAll(userId);
+ session.getBasicRemote().sendObject(new Response().set(1, response));
+ sleep(4000);
+ }
+ } catch (Exception e) {
+ this.interrupt();
+ }
+ }
+ };
+ thread.start();
+ this.thread = thread;
+ }
+
+ @OnClose
+ public void onClose(CloseReason closeReason) throws IOException {
+ System.err.println("closeReason = " + closeReason);
+ if(session.isOpen()){
+ session.close();
+ }
+ }
+
+ @OnError
+ public void onError(Throwable error) throws IOException {
+ error.printStackTrace();
+ thread.isInterrupted();
+ if(session.isOpen()){
+ session.close();
+ }
+ }
+
+}
--
Gitblit v1.9.1