2021-12-07 1.更新

JLChen

2021-12-07 e9932ca3da0e41e263caf76ce672a33c1bca2f05

 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);

                }

            }

        }