华尔思线上版本库

hxb

2022-03-27 cc6023291bc94a229b53d7c2d83bf2b39bbfa9a0

 HDLSDK/hdl-socket/src/main/java/com/hdl/sdk/socket/SocketBoot.java

@@ -5,13 +5,18 @@


import androidx.collection.ArrayMap;



import com.google.gson.JsonObject;

import com.hdl.sdk.common.config.TopicConstant;

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

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

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

import com.hdl.sdk.socket.annotation.ConnectStatus;

import com.hdl.sdk.socket.client.IClient;

import com.hdl.sdk.socket.client.IHeartbeat;

import com.hdl.sdk.socket.listener.SendListener;



import java.net.ConnectException;

import java.util.Date;

import java.util.concurrent.BlockingQueue;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.LinkedBlockingDeque;

@@ -29,8 +34,17 @@
    private ExecutorService connectThread;

    private ExecutorService sendThread;

    private ExecutorService receiveThread;

    private ExecutorService heartbeatThread;



    private final IClient client;

    private IHeartbeat iHeartbeat;

    public void SetHeartbeat(IHeartbeat iHeartbeat){

        this.iHeartbeat=iHeartbeat;

    }

    /**

     * 当前接收到数据的时间

     */

    private static long time=System.currentTimeMillis();



    /**

     * tcp是否已经连接

@@ -50,6 +64,7 @@
        initConnectThread();

        initReceiveThread();

        initSendThread();

        initHeartbeat();

    }



    /**

@@ -59,12 +74,13 @@
        try {

            LogUtils.i("TCP连接");

            client.onConnectStatus(ConnectStatus.CONNECTING);

            Thread.sleep(1500);

            Thread.sleep(1000);

            client.connect();

            connected=true;

            LogUtils.i("TCP连接成功");

            client.onConnectStatus(ConnectStatus.CONNECTED);

        }catch(Exception e) {

            LogUtils.e(e.getMessage());

            LogUtils.e("连接异常"+e.getMessage());

        }

    }



@@ -81,8 +97,8 @@
                    while (true) {

                        try {

                            SocketRequest socketRequest = mMessageQueue.take();

                            final String sendStr = new String(socketRequest.getData(), 0, socketRequest.getData().length);

                            LogUtils.i("发送数据：" + sendStr);

//                            final String sendStr = new String(socketRequest.getData(), 0, socketRequest.getData().length);

//                            LogUtils.i("发送数据：" + sendStr);

                            final String action = socketRequest.getAction();

                            try {

                                client.sendMsg(socketRequest.getData());

@@ -125,6 +141,7 @@
                            if (connected) {

                                //读取数据

                                client.onHandleResponse();

                                time= System.currentTimeMillis();

                            } else {

                                try {

                                    Thread.sleep(1000);

@@ -157,15 +174,45 @@
                            if (!connected) {

                                reconect();

                            }

                            Thread.sleep(10*1000);

                            Thread.sleep(3*1000);

                        } catch (Exception e) {



                            LogUtils.e("定时连接失败:" + e.getMessage());

                        }

                    }

                }

            });

        }

    }



    /**

     * 初始化重新心跳线程

     */

    private void initHeartbeat() {

        if (heartbeatThread == null) {

            heartbeatThread = ThreadToolUtils.getInstance().newFixedThreadPool(1);

            heartbeatThread.execute(new Runnable() {

                @Override

                public void run() {

                    while (true) {

                        try {

                            //10秒

                            if (connected && 10 * 1000 < (System.currentTimeMillis() - time)) {

                                time = System.currentTimeMillis();

                                //心跳检测

                                if (iHeartbeat != null)

                                    iHeartbeat.heartbeat();

                            }

                            Thread.sleep(1000);

                        } catch (Exception e) {

                            LogUtils.e("定时心跳检测网关异常：" + e.getMessage());

                        }

                    }

                }

            });

        }

    }





    /**

     * 重新连接

     */

@@ -194,7 +241,7 @@
            }

            mMessageQueue.put(request);

        } catch (Exception e) {



            LogUtils.e("发送数据失败：" + e.getMessage());

        }

    }