diff --git a/src/main/java/com/xujie/sys/modules/reader/config/TCPClient.java b/src/main/java/com/xujie/sys/modules/reader/config/TCPClient.java index e02dfd5d..bf0384b7 100644 --- a/src/main/java/com/xujie/sys/modules/reader/config/TCPClient.java +++ b/src/main/java/com/xujie/sys/modules/reader/config/TCPClient.java @@ -79,8 +79,12 @@ public class TCPClient { log.error("连接设备失败,IP:{},Port:{}",config.getIp(),config.getPort(),e); }finally { try { - Objects.requireNonNull(in).close(); - Objects.requireNonNull(socket).close(); + if (in!= null){ + in.close(); + } + if (socket!= null && !socket.isClosed()){ + socket.close(); + } } catch (IOException e) { log.error("关闭输入流失败", e); }