wuyouming666
2024-05-29 75375a0f68c8b91799482dc1cd2ec7d7f211167f
springboot-vue3/src/main/java/com/example/springboot/component/PlcInteractionState.java
@@ -2,12 +2,13 @@
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
@Slf4j
public class PlcInteractionState extends Thread {
    private Configuration config;
@@ -89,7 +90,12 @@
                ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("InteractionState");
                if (sendwServer != null) {
                    for (WebSocketServer webserver : sendwServer) {
                        webserver.sendMessage(jsonObject.toString());
                        if(webserver!=null&&webserver.session.isOpen()){
                            webserver.sendMessage(jsonObject.toString());
                        }else{
                            log.info("InteractionState is closed");
                        }
                    }
                }