| | |
|---|
| | | package com.hdl.sdk.connect.socket;
|
|---|
| | |
|
|---|
| | | import android.text.TextUtils;
|
|---|
| | | import android.util.Log;
|
|---|
| | |
|
|---|
| | | import com.google.gson.JsonObject;
|
|---|
| | | import com.google.gson.reflect.TypeToken;
|
|---|
| | | import com.hdl.sdk.common.config.TopicConstant;
|
|---|
| | | import com.hdl.sdk.common.event.EventDispatcher;
|
|---|
| | | import com.hdl.sdk.common.event.EventListener;
|
|---|
| | | import com.hdl.sdk.common.exception.HDLLinkCode;
|
|---|
| | | import com.hdl.sdk.common.exception.HDLLinkException;
|
|---|
| | | import com.hdl.sdk.common.utils.IdUtils;
|
|---|
| | | import com.hdl.sdk.common.utils.IpUtils;
|
|---|
| | | import com.hdl.sdk.common.utils.SPUtils;
|
|---|
| | | import com.hdl.sdk.common.utils.LogUtils;
|
|---|
| | | import com.hdl.sdk.common.utils.ThreadToolUtils;
|
|---|
| | | import com.hdl.sdk.common.utils.gson.GsonConvert;
|
|---|
| | | import com.hdl.sdk.connect.bean.request.BroadcastRequest;
|
|---|
| | | import com.hdl.sdk.connect.bean.response.BaseLocalResponse;
|
|---|
| | | import com.hdl.sdk.connect.bean.request.DeviceControlRequest;
|
|---|
| | | import com.hdl.sdk.connect.bean.request.FunctionAttributeRequest;
|
|---|
| | | import com.hdl.sdk.connect.bean.response.GatewaySearchBean;
|
|---|
| | | import com.hdl.sdk.connect.bean.LinkRequest;
|
|---|
| | | import com.hdl.sdk.connect.bean.LinkResponse;
|
|---|
| | | import com.hdl.sdk.connect.bean.request.PropertyReadRequest;
|
|---|
| | | import com.hdl.sdk.connect.bean.request.PropertyUpRequest;
|
|---|
| | | import com.hdl.sdk.connect.callback.BaseCallBack;
|
|---|
| | | import com.hdl.sdk.connect.callback.HDLLinkCallBack;
|
|---|
| | | import com.hdl.sdk.connect.callback.HDLLinkResponseCallBack;
|
|---|
| | | import com.hdl.sdk.connect.config.HDLLinkConfig;
|
|---|
| | | import com.hdl.sdk.connect.protocol.LinkMessageDecoder;
|
|---|
| | | import com.hdl.sdk.connect.protocol.LinkMessageEncoder;
|
|---|
| | | import com.hdl.sdk.socket.SocketBoot;
|
|---|
| | | import com.hdl.sdk.socket.SocketOptions;
|
|---|
| | | import com.hdl.sdk.socket.client.IHeartbeat;
|
|---|
| | | import com.hdl.sdk.socket.client.TcpClient;
|
|---|
| | | import com.hdl.sdk.socket.client.UdpClient;
|
|---|
| | | import com.hdl.sdk.socket.codec.MessagePipeLine;
|
|---|
| | | import com.hdl.sdk.socket.listener.ConnectStatusListener;
|
|---|
| | | import com.hdl.sdk.socket.listener.SendListener;
|
|---|
| | |
|
|---|
| | | import java.io.UnsupportedEncodingException;
|
|---|
| | | import java.util.ArrayList;
|
|---|
| | | import java.util.List;
|
|---|
| | | import java.util.concurrent.ScheduledExecutorService;
|
|---|
| | |
|---|
| | | */
|
|---|
| | | public class HDLSocket {
|
|---|
| | |
|
|---|
| | | // public interface CallBack extends BaseCallBack {
|
|---|
| | | // void onResponse(String data);
|
|---|
| | | // }
|
|---|
| | | //
|
|---|
| | | // /**
|
|---|
| | | // * udp默认组播ip
|
|---|
| | | // */
|
|---|
| | | // private static final String UDP_GROUP_IP = "239.0.168.188";
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * udp默认端口
|
|---|
| | | */
|
|---|
| | | private static final int UDP_PORT = 8585;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * tcp默认端口
|
|---|
| | | */
|
|---|
| | | private static final int TCP_PORT = 8586;
|
|---|
| | |
|
|---|
| | | // private String tcpIp;
|
|---|
| | | // private int tcpPort;
|
|---|
| | |
|
|---|
| | | // private int udpPort;
|
|---|
| | | // private String udpIp;
|
|---|
| | |
|
|---|
| | | // private static SocketBoot updBoot;
|
|---|
| | | private SocketBoot tcpBoot;
|
|---|
| | |
|
|---|
| | | private ConnectStatusListener statusListener;
|
|---|
| | |
|
|---|
| | | // private EventListener searchEvent;
|
|---|
| | | // private CallBack searchCallBack;
|
|---|
| | | // private ScheduledExecutorService searchGatewayThread;
|
|---|
| | | // private final AtomicInteger searchCount = new AtomicInteger(0);
|
|---|
| | |
|
|---|
| | | private HDLSocket() {
|
|---|
| | | statusListener = new ConnectStatusListener() {
|
|---|
| | | @Override
|
|---|
| | | public void onConnecting() {
|
|---|
| | |
|
|---|
| | | broadcastRequest();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | |
|---|
| | |
|
|---|
| | | }
|
|---|
| | | };
|
|---|
| | | // searchEvent = new EventListener() {
|
|---|
| | | // @Override
|
|---|
| | | // public void onMessage(Object msg) {
|
|---|
| | | // try {
|
|---|
| | | // if (msg instanceof LinkResponse) {
|
|---|
| | | // LinkResponse linkResponse = (LinkResponse) msg;
|
|---|
| | | // String data = linkResponse.getData();
|
|---|
| | | // if (!TextUtils.isEmpty(data)) {
|
|---|
| | | // final BaseLocalResponse<GatewaySearchBean> response = GsonConvert.getGson().fromJson(data, new TypeToken<BaseLocalResponse<GatewaySearchBean>>() {
|
|---|
| | | // }.getType());
|
|---|
| | | // GatewaySearchBean searchBean = response.getObjects();
|
|---|
| | | // if (searchBean != null) {
|
|---|
| | | //// gatewayId = searchBean.getGatewayId();
|
|---|
| | | //// if (!TextUtils.isEmpty(gatewayId)) {
|
|---|
| | | //// SPUtils.put(GATEWAY_KEY, gatewayId);
|
|---|
| | | //// }
|
|---|
| | | //// tcpIp = searchBean.getIp_address();
|
|---|
| | | //// if (!TextUtils.isEmpty(tcpIp)) {
|
|---|
| | | //// SPUtils.put(TCP_IP_KEY, tcpIp);
|
|---|
| | | //// }
|
|---|
| | | // }
|
|---|
| | | //
|
|---|
| | | // if (searchCallBack != null) {
|
|---|
| | | // searchCallBack.onResponse(linkResponse.toString());
|
|---|
| | | // }
|
|---|
| | | // }
|
|---|
| | | //
|
|---|
| | | // }
|
|---|
| | | // } catch (Exception e) {
|
|---|
| | | // if (searchCallBack != null) {
|
|---|
| | | // searchCallBack.onError("解析失败");
|
|---|
| | | // }
|
|---|
| | | // }
|
|---|
| | | //
|
|---|
| | | //
|
|---|
| | | // }
|
|---|
| | | // };
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 广播自身信息给主网关
|
|---|
| | | */
|
|---|
| | | private void broadcastRequest() {
|
|---|
| | | String time = String.valueOf(System.currentTimeMillis());
|
|---|
| | | if (null == HDLLinkConfig.getInstance().getDeviceInfoBean()) {
|
|---|
| | | LogUtils.i("DeviceInfoBean为空，请设置当前对象");
|
|---|
| | | return;
|
|---|
| | | }
|
|---|
| | | BroadcastRequest request = new BroadcastRequest(IdUtils.getUUId(), time, HDLLinkConfig.getInstance().getDeviceInfoBean(), "200");
|
|---|
| | | HDLAuthSocket.getInstance().udpSendMsg(TopicConstant.BROADCAST, GsonConvert.getGson().toJson(request),true);
|
|---|
| | | HDLAuthSocket.getInstance().udpSendMsg(TopicConstant.BROADCAST, GsonConvert.getGson().toJson(request), true, new HDLLinkResponseCallBack() {
|
|---|
| | | @Override
|
|---|
| | | public void onSuccess(LinkResponse msg) {
|
|---|
| | | LogUtils.i("广播信息给主网关成功！");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public void onError(HDLLinkException e) {
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | HDLAuthSocket.getInstance().udpSendMsg(TopicConstant.BROADCAST, GsonConvert.getGson().toJson(request),true);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | private static class SingletonInstance {
|
|---|
| | |
|---|
| | | return SingletonInstance.INSTANCE;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | // private SocketOptions getUdpOptions() {
|
|---|
| | | // final SocketOptions options = new SocketOptions();
|
|---|
| | | // final MessagePipeLine pipeLine = new MessagePipeLine();
|
|---|
| | | // pipeLine.add(new LinkMessageDecoder());
|
|---|
| | | // pipeLine.add(new LinkMessageEncoder());
|
|---|
| | | // options.setHandleMessage(pipeLine);
|
|---|
| | | // options.setEnabledHeartbeat(false);
|
|---|
| | | // return options;
|
|---|
| | | // }
|
|---|
| | |
|
|---|
| | | SocketOptions options;
|
|---|
| | | private SocketOptions getTcpOptions() {
|
|---|
| | | final SocketOptions options = new SocketOptions();
|
|---|
| | | if(null!=options){
|
|---|
| | | return options;
|
|---|
| | | }
|
|---|
| | | options = new SocketOptions();
|
|---|
| | | final MessagePipeLine pipeLine = new MessagePipeLine();
|
|---|
| | | pipeLine.add(new LinkMessageDecoder());
|
|---|
| | | pipeLine.add(new LinkMessageEncoder());
|
|---|
| | | options.setHandleMessage(pipeLine);
|
|---|
| | | options.setEnabledHeartbeat(false);
|
|---|
| | | options.addConnectStatusListener(statusListener);
|
|---|
| | | return options;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | private int getUdpPort() {
|
|---|
| | | return UDP_PORT;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public int getTcpPort() {
|
|---|
| | | return TCP_PORT;
|
|---|
| | |
|---|
| | | public String getGatewayId() {
|
|---|
| | | return HDLLinkConfig.getInstance().getGatewayId();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | // private String getUdpIp() {
|
|---|
| | | // if (TextUtils.isEmpty(udpIp)) {
|
|---|
| | | // udpIp = UDP_GROUP_IP;
|
|---|
| | | // }
|
|---|
| | | // return udpIp;
|
|---|
| | | // }
|
|---|
| | |
|
|---|
| | | // public void searchGateway() {
|
|---|
| | | // searchGateway(null);
|
|---|
| | | // }
|
|---|
| | | //
|
|---|
| | | // /**
|
|---|
| | | // * 组播搜索
|
|---|
| | | // */
|
|---|
| | | // public void searchGateway(CallBack callBack) {
|
|---|
| | | //// gatewayId = "";//重置网关ID
|
|---|
| | | //// this.searchCallBack = callBack;
|
|---|
| | | ////
|
|---|
| | | //// if (searchGatewayThread != null) {
|
|---|
| | | //// searchGatewayThread.shutdownNow();
|
|---|
| | | //// }
|
|---|
| | | ////
|
|---|
| | | ////
|
|---|
| | | //// new Thread(new Runnable() {
|
|---|
| | | //// @Override
|
|---|
| | | //// public void run() {
|
|---|
| | | //// while (TextUtils.isEmpty(gatewayId)) {
|
|---|
| | | //// //搜索网关
|
|---|
| | | //// searchGateway(IdUtils.getUUId(), searchEvent);
|
|---|
| | | //// try {
|
|---|
| | | //// Thread.sleep(1000L);
|
|---|
| | | //// } catch (InterruptedException e) {
|
|---|
| | | //// e.printStackTrace();
|
|---|
| | | //// }
|
|---|
| | | //// }
|
|---|
| | | //// }
|
|---|
| | | //// }).start();
|
|---|
| | | // }
|
|---|
| | | //
|
|---|
| | | //
|
|---|
| | | // /**
|
|---|
| | | // * 通过组播搜索网关
|
|---|
| | | // */
|
|---|
| | | // public void searchGateway(String msgId, EventListener eventListener) {
|
|---|
| | | // searchGateway(getUdpIp(), getUdpPort(), msgId, eventListener);
|
|---|
| | | // }
|
|---|
| | | //
|
|---|
| | | // /**
|
|---|
| | | // * 通过广播搜索网关
|
|---|
| | | // */
|
|---|
| | | // public void searchGatewayByBroadcast(String msgId, EventListener eventListener) {
|
|---|
| | | // searchGateway(IpUtils.getBroadcastAddress(), getUdpPort(), msgId, eventListener);
|
|---|
| | | // }
|
|---|
| | | //
|
|---|
| | | // /**
|
|---|
| | | // * 默认是组播搜索网关
|
|---|
| | | // */
|
|---|
| | | // public void searchGateway(String ip, int port, String msgId, EventListener eventListener) {
|
|---|
| | | //
|
|---|
| | | // if (updBoot == null) {
|
|---|
| | | // updBoot = UdpClient.init(ip, port, getUdpOptions());
|
|---|
| | | // updBoot.connect();
|
|---|
| | | // }
|
|---|
| | | //
|
|---|
| | | //
|
|---|
| | | // String time = String.valueOf(System.currentTimeMillis());
|
|---|
| | | // JsonObject jsonObject = new JsonObject();
|
|---|
| | | // jsonObject.addProperty("id", msgId);
|
|---|
| | | // jsonObject.addProperty("time_stamp", time);
|
|---|
| | | //
|
|---|
| | | // EventDispatcher.getInstance().registerIo(TopicConstant.GATEWAY_SEARCH_REPLY, eventListener);
|
|---|
| | | // LinkRequest message = new LinkRequest(TopicConstant.GATEWAY_SEARCH,
|
|---|
| | | // jsonObject.toString());
|
|---|
| | | //
|
|---|
| | | // try {
|
|---|
| | | // updBoot.sendMsg(message.getSendBytes());
|
|---|
| | | // } catch (UnsupportedEncodingException e) {
|
|---|
| | | // e.printStackTrace();
|
|---|
| | | // }
|
|---|
| | | //
|
|---|
| | | // }
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 获取设备列表
|
|---|
| | |
|---|
| | |
|
|---|
| | | public SocketBoot getTcp() throws RuntimeException {
|
|---|
| | | if (TextUtils.isEmpty(getTcpIp())) {
|
|---|
| | | LogUtils.e("请搜索网关");
|
|---|
| | | throw new RuntimeException("请搜索网关");
|
|---|
| | | }
|
|---|
| | | if (tcpBoot == null) {
|
|---|
| | | //如果没有初始化，或者网关IP更改了，就重新初始化
|
|---|
| | | if (tcpBoot == null||!getTcpOptions().getIp().equals(getTcpIp())) {
|
|---|
| | | tcpBoot = TcpClient.init(getTcpIp(), getTcpPort(), getTcpOptions());
|
|---|
| | | tcpBoot.SetHeartbeat(new IHeartbeat() {
|
|---|
| | | @Override
|
|---|
| | | public void heartbeat() {
|
|---|
| | |
|
|---|
| | | if(HDLLinkConfig.getInstance().getDeviceInfoBean()==null||HDLLinkConfig.getInstance().getDeviceInfoBean().getOID()==null) {
|
|---|
| | | LogUtils.i("DeviceInfoBean为空，需要设置才能正常心跳");
|
|---|
| | | return;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | String time = String.valueOf(System.currentTimeMillis());
|
|---|
| | | JsonObject jsonObject = new JsonObject();
|
|---|
| | | jsonObject.addProperty("id", IdUtils.getUUId());
|
|---|
| | | jsonObject.addProperty("time_stamp", time);
|
|---|
| | |
|
|---|
| | | String topic = String.format(TopicConstant.HEARTBEAT, HDLLinkConfig.getInstance().getDeviceInfoBean().getOID());
|
|---|
| | |
|
|---|
| | | LinkRequest message = new LinkRequest(topic,
|
|---|
| | | jsonObject.toString());
|
|---|
| | | sendMsg(message.getSendBytes(), null, null, null);
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | return tcpBoot;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 通用TCP发送指令 只发一次，不监听回复，不重发
|
|---|
| | | *
|
|---|
| | | * @param topic 发送数据
|
|---|
| | | * @param bodyStr 回复的主题
|
|---|
| | | */
|
|---|
| | | public void tcpSendMsg(String topic, String bodyStr) {
|
|---|
| | | try {
|
|---|
| | | if (TextUtils.isEmpty(topic) || TextUtils.isEmpty(bodyStr)) {
|
|---|
| | | LogUtils.e("udpSendMsg", "参数不能为空");
|
|---|
| | | return;
|
|---|
| | | }
|
|---|
| | | LinkRequest message = new LinkRequest(topic, bodyStr);
|
|---|
| | | getTcp().sendMsg(message.getSendBytes());
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | LogUtils.e("tcpSendMsg", "发送失败 :"+e.getMessage());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 发送指令
|
|---|
| | |
|---|
| | | public void sendMsg(byte[] data, String eventTag, HDLLinkCallBack callBack, SendListener sendListener) {
|
|---|
| | |
|
|---|
| | | try {
|
|---|
| | | final AtomicInteger sendCount = new AtomicInteger(0);
|
|---|
| | | if(eventTag!=null) {
|
|---|
| | | final AtomicInteger sendCount = new AtomicInteger(0);
|
|---|
| | |
|
|---|
| | | final ScheduledExecutorService threadPool = ThreadToolUtils.getInstance().newScheduledThreadPool(1);
|
|---|
| | | final EventListener eventListener = new EventListener() {
|
|---|
| | | @Override
|
|---|
| | | public void onMessage(Object msg) {
|
|---|
| | | if (msg instanceof LinkResponse) {
|
|---|
| | |
|
|---|
| | | if (callBack != null) {
|
|---|
| | | callBack.onSuccess(msg.toString());
|
|---|
| | | }
|
|---|
| | | threadPool.shutdownNow();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | };
|
|---|
| | |
|
|---|
| | | threadPool.scheduleWithFixedDelay(new Runnable() {
|
|---|
| | | @Override
|
|---|
| | | public void run() {
|
|---|
| | | if (sendCount.get() < 3) {
|
|---|
| | | sendCount.set(sendCount.get() + 1);
|
|---|
| | | getTcp().sendMsg(data);
|
|---|
| | | } else {
|
|---|
| | | threadPool.shutdownNow();
|
|---|
| | | EventDispatcher.getInstance().remove(eventTag, eventListener);
|
|---|
| | | ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {
|
|---|
| | | @Override
|
|---|
| | | public void run() {
|
|---|
| | | if (callBack != null) {
|
|---|
| | | callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
|---|
| | | }
|
|---|
| | | final ScheduledExecutorService threadPool = ThreadToolUtils.getInstance().newScheduledThreadPool(1);
|
|---|
| | | final EventListener eventListener = new EventListener() {
|
|---|
| | | @Override
|
|---|
| | | public void onMessage(Object msg) {
|
|---|
| | | if (msg instanceof LinkResponse) {
|
|---|
| | | LogUtils.i("sendMsg onSuccess");
|
|---|
| | | threadPool.shutdownNow();
|
|---|
| | | LogUtils.i("sendMsg eventListener remove");
|
|---|
| | | EventDispatcher.getInstance().remove(eventTag, this);
|
|---|
| | | if (callBack != null) {
|
|---|
| | | callBack.onSuccess(msg.toString());
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }, 1000, 500, TimeUnit.MILLISECONDS);
|
|---|
| | | EventDispatcher.getInstance().register(eventTag, eventListener);
|
|---|
| | | };
|
|---|
| | |
|
|---|
| | | threadPool.scheduleWithFixedDelay(new Runnable() {
|
|---|
| | | @Override
|
|---|
| | | public void run() {
|
|---|
| | | if (sendCount.get() < 3) {
|
|---|
| | | sendCount.set(sendCount.get() + 1);
|
|---|
| | | getTcp().sendMsg(data);
|
|---|
| | | } else {
|
|---|
| | | threadPool.shutdownNow();
|
|---|
| | | LogUtils.e("sendMsg eventListener remove");
|
|---|
| | | EventDispatcher.getInstance().remove(eventTag, eventListener);
|
|---|
| | | ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {
|
|---|
| | | @Override
|
|---|
| | | public void run() {
|
|---|
| | | if (callBack != null) {
|
|---|
| | | callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }, 1000, 500, TimeUnit.MILLISECONDS);
|
|---|
| | | EventDispatcher.getInstance().register(eventTag, eventListener);
|
|---|
| | | }
|
|---|
| | | //先发送一次
|
|---|
| | | getTcp().sendMsg(data, new SendListener() {
|
|---|
| | | @Override
|
|---|
| | | public void onSucceed() {
|
|---|
