HDLSDK_A_Android
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
562935844@qq.com
2022-05-13 a3f9e5ce8dce3d86a60a79b85ce44424a612c6fa 
 HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/connect/socket/HDLAuthSocket.java


@@ -1,7 +1,5 @@


package com.hdl.sdk.connect.socket;




import android.text.TextUtils;




import com.google.gson.Gson;


import com.google.gson.JsonObject;


import com.google.gson.reflect.TypeToken;


@@ -10,8 +8,8 @@


import com.hdl.sdk.common.exception.HDLLinkCode;


import com.hdl.sdk.common.exception.HDLLinkException;


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


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


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


import com.hdl.sdk.connect.HDLLink;


import com.hdl.sdk.connect.bean.response.AuthenticateResponse;


import com.hdl.sdk.connect.bean.response.NetworkAccessBroadcastResponse;


import com.hdl.sdk.connect.callback.BaseCallBack;


@@ -35,7 +33,6 @@


import com.hdl.sdk.socket.udp.UdpSocketBoot;


import com.hdl.sdk.socket.udp.UdpSocketOptions;




import java.net.InetSocketAddress;


import java.util.List;


import java.util.concurrent.atomic.AtomicBoolean;


import java.util.concurrent.atomic.AtomicInteger;


@@ -117,7 +114,7 @@


                udpSocketBoot.bind();


            }


        } catch (Exception e) {


//            return null;


              LogUtils.e("初始化Socket udp异常"+e.getMessage());


        }




        return udpSocketBoot;


@@ -136,9 +133,11 @@


        //2.构建监听Listener


//        authEvent =


        //3.监听网关广播的入网指令


        EventDispatcher.getInstance().remove(TopicConstant.GATEWAY_AUTH_BROADCAST);


        EventDispatcher.getInstance().register(TopicConstant.GATEWAY_AUTH_BROADCAST, new EventListener() {


            @Override


            public void onMessage(Object msg) {


                LogUtils.i("收到网关认证信息: ");


                NetworkAccessBroadcastResponse bean = getNetworkAccessBroadcastResponse(msg);


                if (bean != null) {


                    //移除监听


@@ -181,6 +180,9 @@


        HdlSocketHelper.sendUdp(getUdpBoot(), ip, UDP_PORT, message, new HdlSocketHelper.HdlSocketListener() {


            @Override


            public void onSucceed(Object msg) {




                LogUtils.i("onSucceed msg：" + msg);




                if (callBack == null) return;


                try {


                    AuthenticateResponse bean = getAuthenticateResponseBean(msg);


@@ -627,6 +629,8 @@


                }


            }


        });


        LogUtils.i("callBackSearchGatewayTimeout onError：搜索网关失败，超时");




    }