解密有问题后不往上层发

hxb

2022-02-16 845bb16392e6b47ec31147d0e7c6ddc39537f2e7

 HDLSDK/hdl-socket/src/main/java/com/hdl/sdk/socket/client/TcpClient.java

@@ -3,6 +3,7 @@




import com.hdl.sdk.common.utils.ByteUtils;

import com.hdl.sdk.common.utils.LogUtils;

import com.hdl.sdk.common.utils.ThreadToolUtils;

import com.hdl.sdk.socket.SocketBoot;

import com.hdl.sdk.socket.SocketOptions;

@@ -15,6 +16,7 @@
import java.io.OutputStream;

import java.net.InetSocketAddress;

import java.net.Socket;

import java.net.SocketAddress;

import java.util.ArrayList;

import java.util.List;



@@ -67,12 +69,14 @@


    @Override

    public void connect() throws Exception {



        mSocket = getSocket();

        SocketOptions options = getOptions();

        mSocket.connect(new InetSocketAddress(ip, port));

//        SocketOptions options = getOptions();

        mSocket.connect(new InetSocketAddress(ip, port), 3 * 1000);

        mSocket.setTcpNoDelay(true);

        mSocket.setReuseAddress(true);

        mSocket.setKeepAlive(true);

        mSocket.setSoTimeout(20 * 1000);



        tcpClientList.add(this);

    }

@@ -103,12 +107,17 @@
    public void onHandleResponse() throws Exception {

        final InputStream stream = getInputStream();

        if (stream != null && getOptions() != null) {

            int len=0;

            while ( (len=getInputStream().read(readBuffer)) != -1) {

            while ( true) {

                int len=getInputStream().read(readBuffer);

                if(len<=0){

                    throw  new Exception("接收异常，接收数据长度len="+len);

                }



                IHandleMessage handleMessage = getOptions().getHandleMessage();

                if (handleMessage != null) {

                    byte []bytes = new byte[len];

                    System.arraycopy(readBuffer,0,bytes,0,len);

                    LogUtils.i("收到TCP数据",new String(bytes));

                    //完整的数据才回调

                    handleMessage.read(bytes);

                }

@@ -120,14 +129,10 @@
    public void sendMsg(byte[] msg) throws Exception {

        final OutputStream outputStream = getOutStream();

        if (outputStream != null && getOptions() != null) {

            try {

                IHandleMessage handleMessage = getOptions().getHandleMessage();

                handleMessage.write(handleMessage.write(msg));

                getOutStream().write(msg);



            } finally {

                outputStream.write(msg);

                outputStream.flush();

            }

        }

    }