更改了udp的机制

hxb

2021-12-12 d8bf4f4d66715f002d024cae92862c1d83daa425

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

@@ -127,12 +127,10 @@
            public void run() {

                while (isRun.get()) {

                    if (client.isConnect()) {

                        LogUtils.d("=====", "==发送数据==");



                        try {

                            SocketRequest socketRequest = mMessageQueue.take();

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

                            LogUtils.d("=====", "==发送数据==："+sendStr);

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

                            final String action = socketRequest.getAction();

                            try {

                                client.sendMsg(socketRequest.getData());

@@ -172,28 +170,30 @@


    }



    /**

     * 初始化接收线程，只需要初始化一次

     */

    public void initReceiveThread() {

        if (receiveThread == null) {

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

        }

        receiveThread.execute(new Runnable() {

            @Override

            public void run() {

                while (isRun.get()) {

                    if (client.isConnect()) {

                        try {

                            //读取数据

                            client.onHandleResponse();

                        } catch (Exception e) {

                            e.printStackTrace();

                            LogUtils.d("====", "断开连接" + e.getMessage());

                            disconnectError();

            receiveThread.execute(new Runnable() {

                @Override

                public void run() {

                    while (isRun.get()) {

                        if (client.isConnect()) {

                            try {

                                //读取数据

                                client.onHandleResponse();

                            } catch (Exception e) {

                                e.printStackTrace();

                                disconnectError();

                            }

                        }

                    }

                    LogUtils.i("Socket 线程退出接收数据");

                }

            }

        });



            });

        }

    }





@@ -258,7 +258,6 @@
        if (!client.isConnect()) {

            resetConnect(false);

        }



    }



    /**

@@ -278,7 +277,6 @@
                    if (!client.isConnect() && isOpenRetry.get()) {

                        resetConnect(false);

                    }



                }

            }, 3000, TimeUnit.MILLISECONDS);

        }