From 4f86dc69d3e392679fab9deddf7a6903663dbc71 Mon Sep 17 00:00:00 2001
From: whycxzp <glperry@163.com>
Date: 星期二, 25 三月 2025 21:30:14 +0800
Subject: [PATCH] ws
---
src/main/java/com/whyc/webSocket/PowerAlarmSocket.java | 107 ++++++++++++++++++++++++++
src/main/java/com/whyc/webSocket/BattAlarmSocket.java | 109 +++++++++++++++++++++++++++
2 files changed, 216 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/whyc/webSocket/BattAlarmSocket.java b/src/main/java/com/whyc/webSocket/BattAlarmSocket.java
new file mode 100644
index 0000000..561e2ce
--- /dev/null
+++ b/src/main/java/com/whyc/webSocket/BattAlarmSocket.java
@@ -0,0 +1,109 @@
+package com.whyc.webSocket;
+
+import com.whyc.config.WebSocketConfig;
+import com.whyc.dto.DevA200AlarmDto;
+import com.whyc.dto.PageAlarm;
+import com.whyc.dto.Response;
+import com.whyc.pojo.db_user.UserInf;
+import com.whyc.service.BattAlarmService;
+import com.whyc.service.DevLithiumAlarmDataService;
+import com.whyc.util.ActionUtil;
+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.util.HashMap;
+import java.util.Map;
+
+
+/**
+ * 鐢垫睜鍛婅
+ */
+@Component
+@ServerEndpoint(value = "/battAlarm/getPage",encoders = WebSocketEncoder.class,configurator = WebSocketConfig.class)
+public class BattAlarmSocket {
+ private Session session;
+
+ private Thread thread;
+
+ private static BattAlarmService service;
+
+ private HttpSession httpSession;
+
+ private volatile boolean runFlag = true;
+
+ private volatile Map<String, Thread> threadMap = new HashMap<>();
+
+ private volatile Map<Long,Boolean> threadFlagMap = new HashMap<>();
+
+ @Autowired
+ public void setService(BattAlarmService service) {
+ BattAlarmSocket.service = service;
+ }
+
+ @OnOpen
+ public void onOpen(Session session, EndpointConfig config) {
+ this.session = session;
+ this.httpSession = (HttpSession) config.getUserProperties().get("httpSession");
+ }
+ @OnMessage
+ public void onMessage(Session session, String message) {
+ PageAlarm dto = ActionUtil.getGson("yyyy-MM-dd HH:mm:ss").fromJson(message, PageAlarm.class);
+ thread = new Thread("Thread_BattAlarmSocket") {
+ @Override
+ public void run() {
+ while (runFlag && !isInterrupted()) {
+ Thread thread = currentThread();
+ threadFlagMap.put(thread.getId(), true);
+ try {
+ Response res=service.getPage(dto.getAlmLevel(),dto.getStartTime(),dto.getEndTime(),
+ dto.getPageNum(),dto.getPageSize());
+ if (session.isOpen()) {
+ //鎺ㄩ�佷俊鎭�
+ synchronized (session) {
+ session.getBasicRemote().sendObject(res);
+ }
+ threadFlagMap.put(thread.getId(), false);
+ }
+ sleep(4000);
+ } catch (Exception e) {
+ interrupt();
+ }
+ }
+ }
+ };
+ thread.start();
+ threadFlagMap.put(thread.getId(),true);
+ //鍋滄鑰佺殑socket绾跨▼
+ Thread threadBefore = threadMap.get(session.getId());
+ if(threadBefore !=null && threadBefore.isAlive()){
+ while (threadFlagMap.get(threadBefore.getId())){
+ }
+ threadBefore.interrupt();
+ }
+ //灏嗙嚎绋嬪瓨鍌�,渚夸簬璋冪敤瀹氫綅
+ threadMap.put(session.getId(), this.thread);
+ }
+
+
+ @OnClose
+ public void onClose(CloseReason closeReason){
+ System.err.println("closeReason = " + closeReason);
+ runFlag = false;
+ if (thread != null && thread.isAlive()) {
+ thread.interrupt();
+ }
+ threadMap.remove(session.getId());
+ }
+
+ @OnError
+ public void onError(Throwable error) {
+ error.printStackTrace();
+ if (thread != null && thread.isAlive()) {
+ thread.interrupt();
+ }
+ threadMap.remove(session.getId());
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/whyc/webSocket/PowerAlarmSocket.java b/src/main/java/com/whyc/webSocket/PowerAlarmSocket.java
new file mode 100644
index 0000000..389e98f
--- /dev/null
+++ b/src/main/java/com/whyc/webSocket/PowerAlarmSocket.java
@@ -0,0 +1,107 @@
+package com.whyc.webSocket;
+
+import com.whyc.config.WebSocketConfig;
+import com.whyc.dto.PageAlarm;
+import com.whyc.dto.Response;
+import com.whyc.service.BattAlarmService;
+import com.whyc.service.PowerAlarmService;
+import com.whyc.util.ActionUtil;
+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.util.HashMap;
+import java.util.Map;
+
+
+/**
+ * 鐢垫簮鍛婅
+ */
+@Component
+@ServerEndpoint(value = "/powerAlarm/getPage",encoders = WebSocketEncoder.class,configurator = WebSocketConfig.class)
+public class PowerAlarmSocket {
+ private Session session;
+
+ private Thread thread;
+
+ private static PowerAlarmService service;
+
+ private HttpSession httpSession;
+
+ private volatile boolean runFlag = true;
+
+ private volatile Map<String, Thread> threadMap = new HashMap<>();
+
+ private volatile Map<Long,Boolean> threadFlagMap = new HashMap<>();
+
+ @Autowired
+ public void setService(PowerAlarmService service) {
+ PowerAlarmSocket.service = service;
+ }
+
+ @OnOpen
+ public void onOpen(Session session, EndpointConfig config) {
+ this.session = session;
+ this.httpSession = (HttpSession) config.getUserProperties().get("httpSession");
+ }
+ @OnMessage
+ public void onMessage(Session session, String message) {
+ PageAlarm dto = ActionUtil.getGson("yyyy-MM-dd HH:mm:ss").fromJson(message, PageAlarm.class);
+ thread = new Thread("Thread_BattAlarmSocket") {
+ @Override
+ public void run() {
+ while (runFlag && !isInterrupted()) {
+ Thread thread = currentThread();
+ threadFlagMap.put(thread.getId(), true);
+ try {
+ Response res=service.getPage(dto.getAlmLevel(),dto.getStartTime(),dto.getEndTime(),
+ dto.getPageNum(),dto.getPageSize());
+ if (session.isOpen()) {
+ //鎺ㄩ�佷俊鎭�
+ synchronized (session) {
+ session.getBasicRemote().sendObject(res);
+ }
+ threadFlagMap.put(thread.getId(), false);
+ }
+ sleep(4000);
+ } catch (Exception e) {
+ interrupt();
+ }
+ }
+ }
+ };
+ thread.start();
+ threadFlagMap.put(thread.getId(),true);
+ //鍋滄鑰佺殑socket绾跨▼
+ Thread threadBefore = threadMap.get(session.getId());
+ if(threadBefore !=null && threadBefore.isAlive()){
+ while (threadFlagMap.get(threadBefore.getId())){
+ }
+ threadBefore.interrupt();
+ }
+ //灏嗙嚎绋嬪瓨鍌�,渚夸簬璋冪敤瀹氫綅
+ threadMap.put(session.getId(), this.thread);
+ }
+
+
+ @OnClose
+ public void onClose(CloseReason closeReason){
+ System.err.println("closeReason = " + closeReason);
+ runFlag = false;
+ if (thread != null && thread.isAlive()) {
+ thread.interrupt();
+ }
+ threadMap.remove(session.getId());
+ }
+
+ @OnError
+ public void onError(Throwable error) {
+ error.printStackTrace();
+ if (thread != null && thread.isAlive()) {
+ thread.interrupt();
+ }
+ threadMap.remove(session.getId());
+ }
+}
\ No newline at end of file
--
Gitblit v1.9.1