From aba53745b27e7efe5f43f86ef4aa1e95611cd804 Mon Sep 17 00:00:00 2001
From: JLChen <551775569@qq.com>
Date: 星期一, 06 十二月 2021 17:33:59 +0800
Subject: [PATCH] 2021-12-06 1.修复有时解密失败问题。
---
HDLSDK/hdl-socket/src/main/java/com/hdl/sdk/socket/client/TcpClient.java | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/HDLSDK/hdl-socket/src/main/java/com/hdl/sdk/socket/client/TcpClient.java b/HDLSDK/hdl-socket/src/main/java/com/hdl/sdk/socket/client/TcpClient.java
index 51a03d8..3cd750c 100644
--- a/HDLSDK/hdl-socket/src/main/java/com/hdl/sdk/socket/client/TcpClient.java
+++ b/HDLSDK/hdl-socket/src/main/java/com/hdl/sdk/socket/client/TcpClient.java
@@ -14,6 +14,7 @@
import java.io.OutputStream;
import java.net.InetSocketAddress;
import java.net.Socket;
+import java.util.Arrays;
import java.util.List;
@@ -89,10 +90,12 @@
if (stream != null && getOptions() != null) {
readBuffer = new byte[1024];
- while ((getInputStream().read(readBuffer)) != -1) {
+ int len;
+ while ((len = getInputStream().read(readBuffer)) != -1) {
IHandleMessage handleMessage = getOptions().getHandleMessage();
- if (handleMessage != null) {
- handleMessage.read(readBuffer);
+ if (handleMessage != null && len > 0) {
+ handleMessage.read(Arrays.copyOfRange(readBuffer, 0, len));
+// handleMessage.read(readBuffer);
}
}
}
--
Gitblit v1.8.0