From ab60f22fca5d551771b0d8289c9db60ef7ef44e9 Mon Sep 17 00:00:00 2001
From: JLChen <551775569@qq.com>
Date: 星期一, 13 十二月 2021 16:33:31 +0800
Subject: [PATCH] 2021-12-13 1.更新
---
HDLSDK/hdl-socket/src/main/java/com/hdl/sdk/socket/SocketBoot.java | 44 +++++++++++++++++++++++---------------------
1 files changed, 23 insertions(+), 21 deletions(-)
diff --git a/HDLSDK/hdl-socket/src/main/java/com/hdl/sdk/socket/SocketBoot.java b/HDLSDK/hdl-socket/src/main/java/com/hdl/sdk/socket/SocketBoot.java
index 70e9962..5d20229 100644
--- a/HDLSDK/hdl-socket/src/main/java/com/hdl/sdk/socket/SocketBoot.java
+++ b/HDLSDK/hdl-socket/src/main/java/com/hdl/sdk/socket/SocketBoot.java
@@ -34,6 +34,10 @@
private final IClient client;
+// public IClient getClient() {
+// return client;
+// }
+
/**
* socket鏄惁鍦ㄨ繍琛�
*/
@@ -127,12 +131,10 @@
public void run() {
while (isRun.get()) {
if (client.isConnect()) {
- LogUtils.d("=====", "==鍙戦�佹暟鎹�==");
-
try {
SocketRequest socketRequest = mMessageQueue.take();
final String sendStr = new String(socketRequest.getData(), 0, socketRequest.getData().length);
- LogUtils.d("=====", "==鍙戦�佹暟鎹�==锛�"+sendStr);
+ LogUtils.i("鍙戦�佹暟鎹細"+sendStr);
final String action = socketRequest.getAction();
try {
client.sendMsg(socketRequest.getData());
@@ -172,28 +174,30 @@
}
+ /**
+ * 鍒濆鍖栨帴鏀剁嚎绋嬶紝鍙渶瑕佸垵濮嬪寲涓�娆�
+ */
public void initReceiveThread() {
if (receiveThread == null) {
receiveThread = ThreadToolUtils.getInstance().newFixedThreadPool(1);
- }
- receiveThread.execute(new Runnable() {
- @Override
- public void run() {
- while (isRun.get()) {
- if (client.isConnect()) {
- try {
- //璇诲彇鏁版嵁
- client.onHandleResponse();
- } catch (Exception e) {
- e.printStackTrace();
- LogUtils.d("====", "鏂紑杩炴帴" + e.getMessage());
- disconnectError();
+ receiveThread.execute(new Runnable() {
+ @Override
+ public void run() {
+ while (isRun.get()) {
+ if (client.isConnect()) {
+ try {
+ //璇诲彇鏁版嵁
+ client.onHandleResponse();
+ } catch (Exception e) {
+ e.printStackTrace();
+ disconnectError();
+ }
}
}
+ LogUtils.i("Socket 绾跨▼閫�鍑烘帴鏀舵暟鎹�");
}
- }
- });
-
+ });
+ }
}
@@ -258,7 +262,6 @@
if (!client.isConnect()) {
resetConnect(false);
}
-
}
/**
@@ -278,7 +281,6 @@
if (!client.isConnect() && isOpenRetry.get()) {
resetConnect(false);
}
-
}
}, 3000, TimeUnit.MILLISECONDS);
}
--
Gitblit v1.8.0