添加plc连接不上时报警，主界面后端推送数据超时提示

ZengTao

2024-05-06 b454340c14d789c5fe41350d092ea2f14d6454b3

 springboot-vue3/src/main/java/com/example/springboot/component/PlcManualonePosition.java

@@ -2,13 +2,15 @@

import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import lombok.extern.slf4j.Slf4j;

import org.apache.commons.io.FileUtils;

import java.io.*;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

@Slf4j
public class PlcManualonePosition extends Thread {
    private Configuration config;

@@ -54,11 +56,7 @@
        while (this != null) {
            try {
                Thread.sleep(500);

            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            // this.readValue();
                // this.readValue();
            // String PlcAddress = this.name;
            // Integer Plccount = this.count;

@@ -188,10 +186,11 @@
            ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("ManualonePosition");
            if (sendwServer != null) {
                for (WebSocketServer webserver : sendwServer) {
                    webserver.sendMessage(jsonObject.toString());
                    

//      WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("ManualonePosition");
                    if (webserver != null) {
                    if (webserver != null&&webserver.session.isOpen()) {
                        webserver.sendMessage(jsonObject.toString());
                        List<String> messages = webserver.getMessages();


@@ -242,9 +241,16 @@
                            // 清空消息列表
                            webserver.clearMessages();
                        }
                    }else{
                        log.info("ManualonePosition is closed");
                    }
                }
            }

            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            
        }
    }
}