| | |
| | | |
| | | import cn.hutool.json.JSONArray; |
| | | import cn.hutool.json.JSONObject; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | |
| | | import com.google.common.primitives.Bytes; |
| | | import org.apache.commons.io.FileUtils; |
| | | |
| | |
| | | import java.util.ArrayList; |
| | | import java.util.Arrays; |
| | | import java.util.List; |
| | | |
| | | @Slf4j |
| | | public class PlcServoManualone extends Thread { |
| | | |
| | | // 用于存储应用程序的配置信息 |
| | |
| | | ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("ServoManualone"); |
| | | if (sendwServer != null) { |
| | | for (WebSocketServer webserver : sendwServer) { |
| | | webserver.sendMessage(jsonObject.toString()); |
| | | |
| | | if (webserver != null) { |
| | | |
| | | if (webserver != null&&webserver.session.isOpen()) { |
| | | webserver.sendMessage(jsonObject.toString()); |
| | | List<String> messages = webserver.getMessages(); |
| | | |
| | | if (!messages.isEmpty()) { |
| | |
| | | // 清空消息列表 |
| | | webserver.clearMessages(); |
| | | } |
| | | }else{ |
| | | log.info("ServoManualone is closed"); |
| | | } |
| | | } |
| | | } |