From 212f4027dab9904bf414371500a479b7bc4a8b95 Mon Sep 17 00:00:00 2001 From: yanps Date: Thu, 7 Dec 2023 14:30:57 +0800 Subject: [PATCH] fix: socket --- .../java/org/nl/acs/socket/ClientUDWReceive.java | 3 +++ .../main/java/org/nl/acs/socket/SocketConfig.java | 3 +++ .../org/nl/acs/socket/SocketListenerAutoRun.java | 3 +++ .../java/org/nl/acs/socket/SocketProperties.java | 4 +++- .../java/org/nl/acs/socket/SocketService.java | 15 ++++++++++++++- 5 files changed, 26 insertions(+), 2 deletions(-) diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/ClientUDWReceive.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/ClientUDWReceive.java index 09a5c8a..f9c7e68 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/ClientUDWReceive.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/ClientUDWReceive.java @@ -12,6 +12,9 @@ import java.io.ByteArrayOutputStream; import java.io.InputStream; import java.net.Socket; +/** + * @author 20220102CG\noblelift + */ public class ClientUDWReceive implements Runnable { private static final Logger log = LoggerFactory.getLogger(ClientUDWReceive.class); private InputStream is; diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/SocketConfig.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/SocketConfig.java index 54f72a6..591dbee 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/SocketConfig.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/SocketConfig.java @@ -1,5 +1,8 @@ package org.nl.acs.socket; +/** + * @author 20220102CG\noblelift + */ public class SocketConfig { public static String udw_unit_key = "socket"; diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/SocketListenerAutoRun.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/SocketListenerAutoRun.java index d7e1c96..119fc62 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/SocketListenerAutoRun.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/SocketListenerAutoRun.java @@ -15,6 +15,9 @@ import java.util.Map; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; +/** + * @author 20220102CG\noblelift + */ @Component public class SocketListenerAutoRun extends AbstractAutoRunnable implements SocketService { private static final Logger log = LoggerFactory.getLogger(SocketListenerAutoRun.class); diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/SocketProperties.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/SocketProperties.java index 03f2f82..006ce71 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/SocketProperties.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/SocketProperties.java @@ -1,5 +1,7 @@ package org.nl.acs.socket; - +/** + * @author 20220102CG\noblelift + */ public class SocketProperties { public static Integer server_port = 10000; diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/SocketService.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/SocketService.java index 6e439d8..adec19d 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/SocketService.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/socket/SocketService.java @@ -1,9 +1,22 @@ package org.nl.acs.socket; import java.io.OutputStream; - +/** + * @author 20220102CG\noblelift + */ public interface SocketService { + /** + * 判断客户端是否在线 + * + * @param var1 + * @return + */ boolean isOnline(String var1); + /** + * 获取客户端输出流 + * @param var1 + * @return + */ OutputStream getOutputStream(String var1); }