| | |
|---|
| | | package com.hdl.sdk.connect.socket;
|
|---|
| | |
|
|---|
| | | import android.text.TextUtils;
|
|---|
| | | import android.util.Log;
|
|---|
| | |
|
|---|
| | | import com.google.gson.JsonObject;
|
|---|
| | | import com.hdl.sdk.common.config.TopicConstant;
|
|---|
| | |
|---|
| | | 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.codec.MessagePipeLine;
|
|---|
| | | import com.hdl.sdk.socket.listener.ConnectStatusListener;
|
|---|
| | |
|---|
| | | * 广播自身信息给主网关
|
|---|
| | | */
|
|---|
| | | 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("/user/all/custom/gateway/broadcast", GsonConvert.getGson().toJson(request), true, new HDLLinkResponseCallBack() {
|
|---|
| | | new Thread(new Runnable() {
|
|---|
| | | @Override
|
|---|
| | | public void onSuccess(LinkResponse msg) {
|
|---|
| | | LogUtils.i("广播信息给主网关成功！");
|
|---|
| | | }
|
|---|
| | | public void run() {
|
|---|
| | | try {
|
|---|
| | | LogUtils.i("广播设备本身信息");
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public void onError(HDLLinkException e) {
|
|---|
| | | 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, new HDLLinkResponseCallBack() {
|
|---|
| | | @Override
|
|---|
| | | public void onSuccess(LinkResponse msg) {
|
|---|
| | | LogUtils.i("广播信息给主网关成功！");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public void onError(HDLLinkException e) {
|
|---|
| | | LogUtils.i("广播信息给主网关失败！");
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | HDLAuthSocket.getInstance().udpSendMsg(TopicConstant.BROADCAST, GsonConvert.getGson().toJson(request), true);
|
|---|
| | | HDLAuthSocket.getInstance().udpSendMsg(TopicConstant.BROADCAST, GsonConvert.getGson().toJson(request), true);
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | LogUtils.e("广播设备本身信息失败，失败信息：" + e.getMessage());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | }).start();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | private static class SingletonInstance {
|
|---|
| | | private static final HDLSocket INSTANCE = new HDLSocket();
|
|---|
| | | }
|
|---|
| | | // private static class SingletonInstance {
|
|---|
| | | // }
|
|---|
| | | private static final HDLSocket instance = new HDLSocket();
|
|---|
| | |
|
|---|
| | | public static HDLSocket getInstance() {
|
|---|
| | | return SingletonInstance.INSTANCE;
|
|---|
| | | return instance;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | SocketOptions options;
|
|---|
| | |
|---|
| | |
|
|---|
| | | public SocketBoot getTcp() throws RuntimeException {
|
|---|
| | | if (TextUtils.isEmpty(getTcpIp())) {
|
|---|
| | | LogUtils.e("请搜索网关");
|
|---|
| | | throw new RuntimeException("请搜索网关");
|
|---|
| | | }
|
|---|
| | | //如果没有初始化，或者网关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;
|
|---|
| | |
|---|
| | | 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) {
|
|---|
| | | LogUtils.i("sendMsg onSuccess");
|
|---|
| | | threadPool.shutdownNow();
|
|---|
| | | LogUtils.i("sendMsg eventListener remove");
|
|---|
| | | EventDispatcher.getInstance().remove(eventTag, this);
|
|---|
| | | if (callBack != null) {
|
|---|
| | | callBack.onSuccess(msg.toString());
|
|---|
| | | 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());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | };
|
|---|
| | | };
|
|---|
| | |
|
|---|
| | | 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));
|
|---|
| | | 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);
|
|---|
| | | }, 1000, 500, TimeUnit.MILLISECONDS);
|
|---|
| | | EventDispatcher.getInstance().register(eventTag, eventListener);
|
|---|
| | | }
|
|---|
| | | //先发送一次
|
|---|
| | | getTcp().sendMsg(data, new SendListener() {
|
|---|
| | | @Override
|
|---|
