| | |
|---|
| | | |
|---|
| | | import cn.hutool.json.JSONArray; |
|---|
| | | import cn.hutool.json.JSONObject; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | |
|---|
| | | import java.io.BufferedReader; |
|---|
| | | import java.io.FileInputStream; |
|---|
| | |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Arrays; |
|---|
| | | |
|---|
| | | @Slf4j |
|---|
| | | public class Plcstate extends Thread { |
|---|
| | | String name = ""; |
|---|
| | | Integer count = 0; |
|---|
| | |
|---|
| | | ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("State"); |
|---|
| | | if (sendwServer != null) { |
|---|
| | | for (WebSocketServer webserver : sendwServer) { |
|---|
| | | webserver.sendMessage(jsonObject.toString()); |
|---|
| | | if (webserver != null && webserver.session.isOpen()) { |
|---|
| | | webserver.sendMessage(jsonObject.toString()); |
|---|
| | | }else{ |
|---|
| | | log.info("State连接已关闭"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
