From 0a8fd4aa92555875f58f67144c2c0c0a20a200af Mon Sep 17 00:00:00 2001
From: hxb <hxb@hdlchina.com.cn>
Date: 星期二, 20 八月 2024 09:57:13 +0800
Subject: [PATCH] 增加版本通过配置读取
---
HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/socket/udp/UdpSocketBoot.java | 38 +++++++++++++++++++++-----------------
1 files changed, 21 insertions(+), 17 deletions(-)
diff --git a/HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/socket/udp/UdpSocketBoot.java b/HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/socket/udp/UdpSocketBoot.java
index be4e1a4..0c088f0 100644
--- a/HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/socket/udp/UdpSocketBoot.java
+++ b/HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/socket/udp/UdpSocketBoot.java
@@ -35,6 +35,7 @@
/**
* 缁戝畾 socket
+ *
* @throws Exception 鍙兘绔彛鍐茬獊
*/
public void bind() throws Exception {
@@ -46,7 +47,7 @@
* 鍒濆鍖栨帴鏀剁嚎绋�
*/
private void initReceiveThread() {
- if(null!=receiveThread){
+ if (null != receiveThread) {
return;
}
receiveThread = ThreadToolUtils.getInstance().newFixedThreadPool(1);
@@ -57,7 +58,7 @@
try {
client.onHandleResponse();
} catch (Exception e) {
- LogUtils.i("鎺ユ敹绾跨▼寮傚父锛�"+e.getMessage());
+ LogUtils.i("鎺ユ敹绾跨▼寮傚父锛�" + e.getMessage());
}
}
}
@@ -67,34 +68,37 @@
/**
* 鍙戦�佹暟鎹�
+ *
* @param ipAddress 鐩殑鐨処P鍦板潃
- * @param port 绔彛
- * @param msg 鍙戦�佹暟鎹�
- * @param listener 鍙戦�佸洖璋�
+ * @param port 绔彛
+ * @param msg 鍙戦�佹暟鎹�
+ * @param listener 鍙戦�佸洖璋�
*/
- public void sendMsg(String ipAddress,int port,byte[] msg, SendListener listener) {
- sendMsg(ipAddress,port, msg, true, listener);
+ public void sendMsg(String ipAddress, int port, byte[] msg, SendListener listener) {
+ sendMsg(ipAddress, port, msg, true, listener);
}
/**
* 鍙戦�佹暟鎹�
+ *
* @param ipAddress 鐩殑鐨処P鍦板潃
- * @param port 绔彛
- * @param msg 鍙戦�佹暟鎹�
+ * @param port 绔彛
+ * @param msg 鍙戦�佹暟鎹�
*/
- public void sendMsg(String ipAddress,int port,byte[] msg) {
- sendMsg(ipAddress,port, msg, true, null);
+ public void sendMsg(String ipAddress, int port, byte[] msg) {
+ sendMsg(ipAddress, port, msg, true, null);
}
/**
* 鍙戦�佹暟鎹�
- * @param ipAddress 鐩殑IP鍦板潃
- * @param port 绔彛
- * @param msg 鍙戦�佺殑鏁版嵁
+ *
+ * @param ipAddress 鐩殑IP鍦板潃
+ * @param port 绔彛
+ * @param msg 鍙戦�佺殑鏁版嵁
* @param isRefreshRetry 鏄惁瑕侀噸鍙�
- * @param listener 鍙戦�佸洖璋�
+ * @param listener 鍙戦�佸洖璋�
*/
- public void sendMsg(String ipAddress,int port, byte[] msg, boolean isRefreshRetry, SendListener listener) {
+ public void sendMsg(String ipAddress, int port, byte[] msg, boolean isRefreshRetry, SendListener listener) {
if (isRefreshRetry) {
//閲嶇疆杩炴帴娆℃暟
resendCount.set(0);
@@ -118,7 +122,7 @@
isOpenRetry.set(false);
sendMap.clear();
receiveThread.shutdown();
- receiveThread=null;
+ receiveThread = null;
client.close();
}
}
--
Gitblit v1.8.0