From 6b6f2b23bae66cac92f9133dc4a9bc5dd79a90c8 Mon Sep 17 00:00:00 2001 From: linwl <304115325@qq.com> Date: Sat, 16 Jan 2021 09:51:39 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=AF=BB=E5=8F=96=E7=9A=84?= =?UTF-8?q?=E7=BB=93=E6=9E=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../dipperposition/common/SocketClient.java | 21 +++++++++++-------- 1 file changed, 12 insertions(+), 9 deletions(-) diff --git a/src/main/java/com/telpo/dipperposition/common/SocketClient.java b/src/main/java/com/telpo/dipperposition/common/SocketClient.java index 2021dcc..d34fe80 100644 --- a/src/main/java/com/telpo/dipperposition/common/SocketClient.java +++ b/src/main/java/com/telpo/dipperposition/common/SocketClient.java @@ -54,22 +54,25 @@ public class SocketClient { InputStream is=socket.getInputStream(); BufferedReader br=new BufferedReader(new InputStreamReader(is, StandardCharsets.UTF_8)); - String ackResult=""; - String ackHexOut = HexConvert.convertStringToHex(ackAckCheckRef); - while(!((reply=br.readLine())==null)){ - log.debug("接收服务器的信息:"+reply); - if (ackHexOut.equals(reply)) { - reply=br.readLine(); - ackResult = HexConvert.convertHexToString(reply); - break; - } + StringBuffer ackResultBuf= new StringBuffer(); + //String ackHexOut = HexConvert.convertStringToHex(ackAckCheckRef); + reply=br.readLine(); + while(reply!=null){ + //log.debug("接收服务器的信息:"+reply); + //if (ackHexOut.equals(reply)) { + ackResultBuf.append(reply); + reply=br.readLine(); + // break; + //} } + String ackResult = HexConvert.convertHexToString(ackResultBuf.toString()); //4.关闭资源 br.close(); is.close(); pw.close(); os.close(); log.debug(ackResult); + log.debug("接收服务器的信息:"+ackResult); return ackResult; } catch (IOException e) { log.error("Socket sendCmd Error:" + e.getMessage());