From 43e38e768360ac8ced4f31fb4a423f2badda5587 Mon Sep 17 00:00:00 2001
From: JLChen <551775569@qq.com>
Date: 星期一, 13 十二月 2021 15:49:05 +0800
Subject: [PATCH] 2021-12-13 1.优化udp发送
---
HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/connect/socket/HDLSocket.java | 525 ++++++++++++++++++++++++++++------------------------------
1 files changed, 253 insertions(+), 272 deletions(-)
diff --git a/HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/connect/socket/HDLSocket.java b/HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/connect/socket/HDLSocket.java
index 7c94a2f..b03d0fe 100644
--- a/HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/connect/socket/HDLSocket.java
+++ b/HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/connect/socket/HDLSocket.java
@@ -7,19 +7,25 @@
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.LogUtils;
import com.hdl.sdk.common.utils.SPUtils;
import com.hdl.sdk.common.utils.ThreadToolUtils;
import com.hdl.sdk.common.utils.gson.GsonConvert;
-import com.hdl.sdk.connect.bean.BaseLocalResponse;
-import com.hdl.sdk.connect.bean.DeviceControlRequest;
-import com.hdl.sdk.connect.bean.FunctionAttributeRequest;
-import com.hdl.sdk.connect.bean.GatewaySearchBean;
+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.PropertyReadRequest;
-import com.hdl.sdk.connect.bean.PropertyUpRequest;
+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.config.HDLLinkConfig;
import com.hdl.sdk.connect.protocol.LinkMessageDecoder;
import com.hdl.sdk.connect.protocol.LinkMessageEncoder;
import com.hdl.sdk.socket.SocketBoot;
@@ -44,48 +50,14 @@
*/
public class HDLSocket {
- private static final String GATEWAY_KEY = "gateway_key";
- private static final String TCP_IP_KEY = "tcp_ip_key";
- private String gatewayId;
-
- public interface CallBack {
-
- void onError(String error);
-
- 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() {
@@ -104,43 +76,6 @@
}
};
- 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 static class SingletonInstance {
@@ -152,136 +87,36 @@
}
- 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;
- }
-
private SocketOptions getTcpOptions() {
final SocketOptions options = new SocketOptions();
final MessagePipeLine pipeLine = new MessagePipeLine();
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;
}
- private int getUdpPort() {
- return UDP_PORT;
- }
public int getTcpPort() {
return TCP_PORT;
}
public String getTcpIp() {
- if (!TextUtils.isEmpty(tcpIp)) {
- return tcpIp;
- }
- return SPUtils.getString(TCP_IP_KEY, "");
+ return HDLLinkConfig.getInstance().getIpAddress();
}
public String getGatewayId() {
- if (!TextUtils.isEmpty(gatewayId)) {
- return gatewayId;
- }
- return SPUtils.getString(GATEWAY_KEY, "");
+ 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.toString().getBytes("utf-8"));
- } catch (UnsupportedEncodingException e) {
- e.printStackTrace();
- }
-
- }
-
/**
* 鑾峰彇璁惧鍒楄〃
*/
- public void getDeviceList(CallBack callBack) {
+ public void getDeviceList(HDLLinkCallBack callBack) {
if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {
String time = String.valueOf(System.currentTimeMillis());
JsonObject jsonObject = new JsonObject();
@@ -295,7 +130,7 @@
String replyTopic = String.format(TopicConstant.GET_DEVICE_LIST_REPLY, getGatewayId());
try {
- sendMsg(message.toString().getBytes("utf-8"), replyTopic, callBack, new SendListener() {
+ sendMsg(message.getSendBytes(), replyTopic, callBack, new SendListener() {
@Override
public void onSucceed() {
@@ -304,18 +139,18 @@
@Override
public void onError() {
if (callBack != null) {
- callBack.onError("鑾峰彇璁惧鍒楄〃澶辫触");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_DEVICE_LIST_ERROR));
}
}
});
- } catch (UnsupportedEncodingException e) {
+ } catch (Exception e) {
if (callBack != null) {
- callBack.onError("鑾峰彇璁惧鍒楄〃澶辫触");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_DEVICE_LIST_ERROR));
}
}
} else {
if (callBack != null) {
- callBack.onError("ip鍦板潃涓㈠け");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_UNAUTHORIZED_ERROR));
}
}
}
@@ -324,7 +159,7 @@
/**
* 鑾峰彇鍔熻兘鍒楄〃
*/
- public void getFunctionList(CallBack callBack) {
+ public void getFunctionList(HDLLinkCallBack callBack) {
if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {
String time = String.valueOf(System.currentTimeMillis());
JsonObject jsonObject = new JsonObject();
@@ -338,7 +173,7 @@
String replyTopic = String.format(TopicConstant.GET_FUNCTION_LIST_REPLY, getGatewayId());
try {
- sendMsg(message.toString().getBytes("utf-8"), replyTopic, callBack, new SendListener() {
+ sendMsg(message.getSendBytes(), replyTopic, callBack, new SendListener() {
@Override
public void onSucceed() {
@@ -347,18 +182,18 @@
@Override
public void onError() {
if (callBack != null) {
- callBack.onError("鑾峰彇鍔熻兘鍒楄〃澶辫触");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_FUNCTION_LIST_ERROR));
}
}
});
- } catch (UnsupportedEncodingException e) {
+ } catch (Exception e) {
if (callBack != null) {
- callBack.onError("鑾峰彇鍔熻兘鍒楄〃澶辫触");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_FUNCTION_LIST_ERROR));
}
}
} else {
if (callBack != null) {
- callBack.onError("ip鍦板潃涓㈠け");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_UNAUTHORIZED_ERROR));
}
}
}
@@ -367,10 +202,10 @@
/**
* 鑾峰彇鍔熻兘灞炴��
*
+ * @param sids
* @param callBack
- * @param sid
*/
- public void getFunctionAttribute(CallBack callBack, String... sid) {
+ public void getFunctionAttribute(List<String> sids, HDLLinkCallBack callBack) {
if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {
String time = String.valueOf(System.currentTimeMillis());
@@ -378,7 +213,7 @@
data.setId(IdUtils.getUUId());
data.setTime_stamp(time);
List<FunctionAttributeRequest> list = new ArrayList<>();
- for (String s : sid) {
+ for (String s : sids) {
list.add(new FunctionAttributeRequest(s));
}
data.setObjects(list);
@@ -389,7 +224,7 @@
String replyTopic = String.format(TopicConstant.GET_FUNCTION_ATTRIBUTE_REPLY, getGatewayId());
try {
- sendMsg(message.toString().getBytes("utf-8"), replyTopic, callBack, new SendListener() {
+ sendMsg(message.getSendBytes(), replyTopic, callBack, new SendListener() {
@Override
public void onSucceed() {
@@ -398,18 +233,18 @@
@Override
public void onError() {
if (callBack != null) {
- callBack.onError("鑾峰彇鍔熻兘灞炴�уけ璐�");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_FUNCTION_PROPERTIES_ERROR));
}
}
});
- } catch (UnsupportedEncodingException e) {
+ } catch (Exception e) {
if (callBack != null) {
- callBack.onError("鑾峰彇鍔熻兘灞炴�уけ璐�");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_FUNCTION_PROPERTIES_ERROR));
}
}
} else {
if (callBack != null) {
- callBack.onError("ip鍦板潃涓㈠け");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_UNAUTHORIZED_ERROR));
}
}
}
@@ -417,7 +252,7 @@
/**
* 璁惧鎺у埗
*/
- public void propertyDown(List<DeviceControlRequest> request, CallBack callBack) {
+ public void propertyDown(List<DeviceControlRequest> request, HDLLinkCallBack callBack) {
if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {
String time = String.valueOf(System.currentTimeMillis());
@@ -427,10 +262,9 @@
data.setTime_stamp(time);
data.setObjects(request);
-
String topic = String.format(TopicConstant.PROPERTY_DOWN, getGatewayId());
LinkRequest message = new LinkRequest(topic,
- GsonConvert.getGson().toJson(request));
+ GsonConvert.getGson().toJson(data));
String replyTopic = String.format(TopicConstant.PROPERTY_DOWN_REPLY, getGatewayId());
try {
@@ -443,87 +277,90 @@
@Override
public void onError() {
if (callBack != null) {
- callBack.onError("鎺у埗鎸囦护鍙戦�佸け璐�");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
}
}
});
} catch (Exception e) {
if (callBack != null) {
- callBack.onError("鎺у埗鎸囦护鍙戦�佸け璐�");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
}
}
} else {
if (callBack != null) {
- callBack.onError("鎺у埗鎸囦护鍙戦�佸け璐�");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
}
}
}
- /**
- * 鐘舵�佷笂鎶�
- */
- public void propertyUp(List<PropertyUpRequest> request, CallBack callBack) {
- if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {
- String time = String.valueOf(System.currentTimeMillis());
-
- final BaseLocalResponse<List<PropertyUpRequest>> data = new BaseLocalResponse<>();
- data.setId(IdUtils.getUUId());
- data.setTime_stamp(time);
- data.setObjects(request);
-
-
- String topic = String.format(TopicConstant.PROPERTY_UP, getGatewayId());
- LinkRequest message = new LinkRequest(topic,
- GsonConvert.getGson().toJson(request));
-
- String replyTopic = String.format(TopicConstant.PROPERTY_UP_REPLY, getGatewayId());
- try {
- sendMsg(message.toString().getBytes("utf-8"), replyTopic, callBack, new SendListener() {
- @Override
- public void onSucceed() {
-
- }
-
- @Override
- public void onError() {
- if (callBack != null) {
- callBack.onError("鎸囦护鍙戦�佸け璐�");
- }
- }
- });
- } catch (UnsupportedEncodingException e) {
- if (callBack != null) {
- callBack.onError("鎸囦护鍙戦�佸け璐�");
- }
- }
- } else {
- if (callBack != null) {
- callBack.onError("鎸囦护鍙戦�佸け璐�");
- }
- }
- }
+// /**
+// * 鐘舵�佷笂鎶�
+// */
+// public void propertyUp(List<PropertyUpRequest> request, CallBack callBack) {
+// if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {
+// String time = String.valueOf(System.currentTimeMillis());
+//
+// final BaseLocalResponse<List<PropertyUpRequest>> data = new BaseLocalResponse<>();
+// data.setId(IdUtils.getUUId());
+// data.setTime_stamp(time);
+// data.setObjects(request);
+//
+//
+// String topic = String.format(TopicConstant.PROPERTY_UP, getGatewayId());
+// LinkRequest message = new LinkRequest(topic,
+// GsonConvert.getGson().toJson(request));
+//
+// String replyTopic = String.format(TopicConstant.PROPERTY_UP_REPLY, getGatewayId());
+// try {
+// sendMsg(message.getSendBytes(), replyTopic, callBack, new SendListener() {
+// @Override
+// public void onSucceed() {
+//
+// }
+//
+// @Override
+// public void onError() {
+// if (callBack != null) {
+// callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
+// }
+// }
+// });
+// } catch (Exception e) {
+// if (callBack != null) {
+// callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
+// }
+// }
+// } else {
+// if (callBack != null) {
+// callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
+// }
+// }
+// }
/**
* 璇诲彇鐘舵��
*/
- public void propertyRead(List<PropertyReadRequest> request, CallBack callBack) {
+ public void propertyRead(List<String> sids, HDLLinkCallBack callBack) {
if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {
String time = String.valueOf(System.currentTimeMillis());
-
final BaseLocalResponse<List<PropertyReadRequest>> data = new BaseLocalResponse<>();
data.setId(IdUtils.getUUId());
data.setTime_stamp(time);
- data.setObjects(request);
+ List<PropertyReadRequest> list = new ArrayList<>();
+ for (String s : sids) {
+ list.add(new PropertyReadRequest(s));
+ }
+ data.setObjects(list);
String topic = String.format(TopicConstant.PROPERTY_READ, getGatewayId());
LinkRequest message = new LinkRequest(topic,
- GsonConvert.getGson().toJson(request));
+ GsonConvert.getGson().toJson(data));
String replyTopic = String.format(TopicConstant.PROPERTY_READ_REPLY, getGatewayId());
try {
- sendMsg(message.toString().getBytes("utf-8"), replyTopic, callBack, new SendListener() {
+ sendMsg(message.getSendBytes(), replyTopic, callBack, new SendListener() {
@Override
public void onSucceed() {
@@ -532,18 +369,18 @@
@Override
public void onError() {
if (callBack != null) {
- callBack.onError("鎸囦护鍙戦�佸け璐�");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
}
}
});
- } catch (UnsupportedEncodingException e) {
+ } catch (Exception e) {
if (callBack != null) {
- callBack.onError("鎸囦护鍙戦�佸け璐�");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
}
}
} else {
if (callBack != null) {
- callBack.onError("鎸囦护鍙戦�佸け璐�");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
}
}
}
@@ -559,19 +396,159 @@
}
/**
- * 娓呯┖缂撳瓨
+ * 鑾峰彇鍦烘櫙鍒楄〃
*/
- public void clearCache() {
- SPUtils.remove(TCP_IP_KEY);
- SPUtils.remove(GATEWAY_KEY);
+ public void getSceneList(HDLLinkCallBack callBack) {
+ if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {
+ 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.SCENE_LIST_GET, getGatewayId());
+
+ LinkRequest message = new LinkRequest(topic,
+ jsonObject.toString());
+ String replyTopic = topic + "_reply";
+ try {
+ sendMsg(message.getSendBytes(), replyTopic, callBack, new SendListener() {
+ @Override
+ public void onSucceed() {
+
+ }
+
+ @Override
+ public void onError() {
+ if (callBack != null) {
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_FUNCTION_LIST_ERROR));
+ }
+ }
+ });
+ } catch (Exception e) {
+ if (callBack != null) {
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_FUNCTION_LIST_ERROR));
+ }
+ }
+ } else {
+ if (callBack != null) {
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_UNAUTHORIZED_ERROR));
+ }
+ }
}
+ /**
+ * 鍦烘櫙鎺у埗
+ * @param sids 鍦烘櫙sid鍒楄〃
+ * @param callBack 鍥炶皟
+ */
+ public void controlScene(List<String> sids, HDLLinkCallBack callBack) {
+ if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {
+ String time = String.valueOf(System.currentTimeMillis());
+ final BaseLocalResponse<List<PropertyReadRequest>> data = new BaseLocalResponse<>();
+ data.setId(IdUtils.getUUId());
+ data.setTime_stamp(time);
+
+ List<PropertyReadRequest> list = new ArrayList<>();
+ for (String s : sids) {
+ list.add(new PropertyReadRequest(s));
+ }
+ data.setObjects(list);
+
+ String topic = String.format(TopicConstant.SCENE_CONTROL, getGatewayId());
+ LinkRequest message = new LinkRequest(topic,
+ GsonConvert.getGson().toJson(data));
+
+ String replyTopic = topic + "_reply";
+ try {
+ sendMsg(message.getSendBytes(), replyTopic, callBack, new SendListener() {
+ @Override
+ public void onSucceed() {
+
+ }
+
+ @Override
+ public void onError() {
+ if (callBack != null) {
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
+ }
+ }
+ });
+ } catch (Exception e) {
+ if (callBack != null) {
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
+ }
+ }
+ } else {
+ if (callBack != null) {
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
+ }
+ }
+ }
+
+// /**
+// * 娓呯┖缂撳瓨
+// */
+// public void clearCache() {
+// SPUtils.remove(TCP_IP_KEY);
+// SPUtils.remove(GATEWAY_KEY);
+// }
+
+ /**
+ * 閫氱敤TCP鍙戦�佹寚浠�
+ * 1绉掓病鍝嶅簲灏辫浠栭噸鏂板彂閫�,閲嶈瘯3娆�
+ *
+ * @param topic 鍙戦�佹暟鎹�
+ * @param bodyStr 鍥炲鐨勪富棰�
+ * @param callBack 鍥炶皟
+ */
+ public void tcpSendMsg(String topic, String bodyStr, HDLLinkCallBack callBack) {
+ try {
+ LinkRequest message = new LinkRequest(topic, bodyStr);
+ String replyTopic = topic + "_reply";
+ sendMsg(message.getSendBytes(), replyTopic, callBack, new SendListener() {
+ @Override
+ public void onSucceed() {
+
+ }
+
+ @Override
+ public void onError() {
+ if (callBack != null) {
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
+ }
+ }
+ });
+ } catch (Exception e) {
+ if (callBack != null) {
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
+ }
+ }
+ }
+
+ /**
+ * 閫氱敤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());
+ }
+ }
/**
* 鍙戦�佹寚浠�
* 1绉掓病鍝嶅簲灏辫浠栭噸鏂板彂閫�,閲嶈瘯3娆�
*/
- public void sendMsg(byte[] data, String eventTag, CallBack callBack, SendListener sendListener) {
+ public void sendMsg(byte[] data, String eventTag, HDLLinkCallBack callBack, SendListener sendListener) {
try {
final AtomicInteger sendCount = new AtomicInteger(0);
@@ -581,11 +558,13 @@
@Override
public void onMessage(Object msg) {
if (msg instanceof LinkResponse) {
-
- if (callBack != null) {
- callBack.onResponse(msg.toString());
- }
+ LogUtils.i("sendMsg onSuccess");
threadPool.shutdownNow();
+ LogUtils.i("sendMsg eventListener remove");
+ EventDispatcher.getInstance().remove(eventTag, this);
+ if (callBack != null) {
+ callBack.onSuccess(msg.toString());
+ }
}
}
};
@@ -598,12 +577,13 @@
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("鍙戦�佸け璐�");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
}
}
});
@@ -611,6 +591,7 @@
}
}, 1000, 500, TimeUnit.MILLISECONDS);
EventDispatcher.getInstance().register(eventTag, eventListener);
+ //鍏堝彂閫佷竴娆�
getTcp().sendMsg(data, new SendListener() {
@Override
public void onSucceed() {
@@ -632,7 +613,7 @@
@Override
public void run() {
if (callBack != null) {
- callBack.onError("鍙戦�佸け璐�");
+ callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
}
}
});
--
Gitblit v1.8.0