2021-12-10 1.开启UDP心跳

JLChen

2021-12-10 739d5bad0d24c5f4913f8d8e09292b5b98991fac

2021-12-10 1.开启UDP心跳

 HDLSDK/app/src/main/java/com/hdl/hdlsdk/device/DevicesListAdapter.java

@@ -16,11 +16,16 @@
import com.chad.library.adapter.base.viewholder.BaseViewHolder;

import com.hdl.hdlsdk.DemoBean;

import com.hdl.hdlsdk.R;

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

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

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

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

import com.hdl.sdk.common.utils.gson.GsonConvert;

import com.hdl.sdk.connect.HDLLink;

import com.hdl.sdk.connect.bean.request.DeviceControlRequest;

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

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

import com.hdl.sdk.connect.config.HDLLinkConfig;



import java.util.ArrayList;

import java.util.List;

@@ -94,18 +99,16 @@
        statusBeanList.add(bean);

        request.setStatus(statusBeanList);

        requestList.add(request);

        HDLLink.getInstance().propertyDown(requestList, new HDLLinkCallBack() {

            @Override

            public void onSuccess(String data) {

                LogUtils.i(data);

//                responseTv.setText(data);

            }

        String time = String.valueOf(System.currentTimeMillis());



            @Override

            public void onError(HDLLinkException e) {

//                responseTv.setText(e.getMsg());

                LogUtils.i("code:"+e.getCode() + " " + e.getMsg());

            }

        });

        final BaseLocalResponse<List<DeviceControlRequest>> data = new BaseLocalResponse<>();

        data.setId(IdUtils.getUUId());

        data.setTime_stamp(time);

        data.setObjects(requestList);



        String topic = String.format(TopicConstant.PROPERTY_DOWN, HDLLinkConfig.getInstance().getGatewayId());



        HDLLink.getInstance().tcpSendMsg(topic, GsonConvert.getGson().toJson(data));

//        HDLLink.getInstance().udpSendMsg(topic, GsonConvert.getGson().toJson(data));

    }

}

 HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/connect/socket/HDLAuthSocket.java

@@ -99,7 +99,9 @@
        pipeLine.add(new LinkMessageDecoder());
        pipeLine.add(new LinkMessageEncoder());
        options.setHandleMessage(pipeLine);
        options.setEnabledHeartbeat(false);
        options.setHeartbeatTimeInterval(10*1000L);
        options.setHeartbeatData("UDP");
        options.setEnabledHeartbeat(true);//是否开启心跳包发送检测
        return options;
    }


 HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/connect/socket/HDLSocket.java

@@ -166,7 +166,10 @@
        pipeLine.add(new LinkMessageDecoder());

        pipeLine.add(new LinkMessageEncoder());

        options.setHandleMessage(pipeLine);

        options.setEnabledHeartbeat(false);

        options.setEnabledHeartbeat(false);//是否开启心跳包发送检测

//        options.setHeartbeatTimeInterval(10*1000L);

//        options.setHeartbeatData("TCP");

//        options.setEnabledHeartbeat(true);//是否开启心跳包发送检测

        return options;

    }