From 71564904763e573a681f38be7053c9a83abda307 Mon Sep 17 00:00:00 2001
From: whycq <913841844@qq.com>
Date: 星期日, 19 二月 2023 12:58:29 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/thread/BarcodeThread.java | 14 ++++++++------
1 files changed, 8 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/BarcodeThread.java b/src/main/java/com/zy/core/thread/BarcodeThread.java
index d82420a..18202bd 100644
--- a/src/main/java/com/zy/core/thread/BarcodeThread.java
+++ b/src/main/java/com/zy/core/thread/BarcodeThread.java
@@ -42,7 +42,7 @@
connect();
while (true) {
try {
- byte[] read = read(8, 100);
+ byte[] read = read(8, 200);
if (null != read) {
String s = new String(read);
if (!Cools.isEmpty(s)) {
@@ -57,7 +57,7 @@
OutputQueue.BARCODE.offer(jsonObject);
}
}
- Thread.sleep(100);
+ Thread.sleep(50);
} catch (SocketTimeoutException ignore) {
} catch (Exception e) {
// e.printStackTrace();
@@ -114,10 +114,10 @@
}
public byte[] read(int bufferSize, int timeOut) throws IOException {
-// if (socket == null) {
-// connect();
-// }
- connect();
+ if (socket == null || !socket.isConnected() || socket.isClosed()) {
+ connect();
+ }
+// connect();
socket.setSoTimeout(timeOut);
byte[] bytes = new byte[bufferSize];
int len = dataInputStream.read(bytes);
@@ -125,6 +125,8 @@
if (len > 0) {
tempBytes = new byte[len];
System.arraycopy(bytes, 0, tempBytes, 0, len);
+ } else {
+ connect();
}
return tempBytes;
}
--
Gitblit v1.9.1