From 51d44d9754d94dc6fb122cd4cd002af0b55ba23c Mon Sep 17 00:00:00 2001 From: liuhanqing Date: Tue, 26 Aug 2025 17:16:23 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9socket=E8=BF=9E=E6=8E=A5?= =?UTF-8?q?=E5=BC=82=E5=B8=B8=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/ruoyi/out/tagTask/thread/TagInReadThread.java | 8 +++++++- .../com/ruoyi/out/tagTask/thread/TagOutReadThread.java | 7 +++++++ 2 files changed, 14 insertions(+), 1 deletion(-) diff --git a/ruoyi-admin/src/main/java/com/ruoyi/out/tagTask/thread/TagInReadThread.java b/ruoyi-admin/src/main/java/com/ruoyi/out/tagTask/thread/TagInReadThread.java index 313be35..40ced75 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/out/tagTask/thread/TagInReadThread.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/out/tagTask/thread/TagInReadThread.java @@ -52,7 +52,11 @@ public class TagInReadThread implements Runnable { public void run() { while (true) { try (Socket socket = getSocket(ip)) { - + if (socket==null){ + log.info("电子标签服务器连接失败,请检查ip:{}", ip); + Thread.sleep(5000); + continue; + } BasTag param = new BasTag(); param.setIp(ip); param.setSpare3("2"); @@ -131,6 +135,8 @@ public class TagInReadThread implements Runnable { } } catch (IOException e) { log.error(e.getMessage(), e); + } catch (InterruptedException e) { + throw new RuntimeException(e); } } diff --git a/ruoyi-admin/src/main/java/com/ruoyi/out/tagTask/thread/TagOutReadThread.java b/ruoyi-admin/src/main/java/com/ruoyi/out/tagTask/thread/TagOutReadThread.java index e8550da..10ba6d6 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/out/tagTask/thread/TagOutReadThread.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/out/tagTask/thread/TagOutReadThread.java @@ -57,6 +57,11 @@ public class TagOutReadThread implements Runnable { try (Socket socket = getSocket(ip)) { //下发标签 + if (socket==null){ + log.info("电子标签服务器连接失败,请检查ip:{}", ip); + Thread.sleep(5000); + continue; + } for (Long tagId : collect.keySet()) { List allTagTasks = collect.get(tagId); Optional first = allTagTasks.stream().filter(x -> "0".equals(x.getStatus())).findFirst(); @@ -134,6 +139,8 @@ public class TagOutReadThread implements Runnable { } catch (IOException e) { throw new RuntimeException(e); + } catch (InterruptedException e) { + throw new RuntimeException(e); } }