whyclxw
2025-05-28 e16302f9d475c7cc4dd18c5abf1a23cb5502e362
src/main/java/com/whyc/webSocket/InterfaceDevAlarmSocket.java
@@ -42,6 +42,7 @@
    public synchronized void onMessage(Session session, String message){
        InterfaceParam param = ActionUtil.getGson().fromJson(message, InterfaceParam.class);
        thread = new Thread("Thread_interfaceDevAlarm") {
            @Override
            public void run() {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
@@ -50,7 +51,7 @@
                        if (session.isOpen()) {
                            //推送信息
                            synchronized (session) {
                                session.getBasicRemote().sendObject(service.getDevAlarm(param.getDeviceIds()));
                                session.getBasicRemote().sendObject(service.getDevAlarm(param.getDeviceIds(), param.getInterfaceNumber()));
                            }
                            threadFlagMap.put(thread.getId(),false);
                        }