From 428eee9df5f8885ab71d7cd273f5889b8c81e1dc Mon Sep 17 00:00:00 2001 From: zhubaomin <zhubaomin> Date: 星期四, 31 十月 2024 16:49:30 +0800 Subject: [PATCH] 2024-10-31 优化代码 --- pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/forTcp/TcpSessionCache.java | 19 +++++++++++++++++++ 1 files changed, 19 insertions(+), 0 deletions(-) diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/forTcp/TcpSessionCache.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/forTcp/TcpSessionCache.java index 55869f8..fc34bbf 100644 --- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/forTcp/TcpSessionCache.java +++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/forTcp/TcpSessionCache.java @@ -162,6 +162,25 @@ return map ; } } + + + /** + * 寰楀埌閮ㄥ垎鍦ㄧ嚎鎯呭喌 + * @return + */ + public static HashMap<String, Boolean> partOnLine(String[] rtuAddrArrGrp){ + synchronized (sessionTable){ + HashMap<String, Boolean> map = new HashMap<String, Boolean>(); + for(String rtuAddr : rtuAddrArrGrp){ + TcpSession tcpSe = sessionTable.get(rtuAddr) ; + if(tcpSe != null){ + map.put(rtuAddr, tcpSe.ioSession.isConnected()) ; + } + } + return map ; + } + } + /** * 寰楀埌鎵�鏈塕TU杩炴帴鐘舵�佹儏鍐� * @return -- Gitblit v1.8.0