From 3beffd06aa145959811de597a69c3834d3abe8c8 Mon Sep 17 00:00:00 2001 From: aijinhui <aijinhui> Date: 星期二, 17 十月 2023 17:20:02 +0800 Subject: [PATCH] 锁管理 --- ard-work/src/main/java/com/ruoyi/test/ReadAccessDatabase.java | 41 ++++++++++++++++++++++++++++++----------- 1 files changed, 30 insertions(+), 11 deletions(-) diff --git a/ard-work/src/main/java/com/ruoyi/test/ReadAccessDatabase.java b/ard-work/src/main/java/com/ruoyi/test/ReadAccessDatabase.java index 2dcf2b0..e9d1151 100644 --- a/ard-work/src/main/java/com/ruoyi/test/ReadAccessDatabase.java +++ b/ard-work/src/main/java/com/ruoyi/test/ReadAccessDatabase.java @@ -10,6 +10,11 @@ import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; + +import java.io.IOException; +import java.net.InetSocketAddress; +import java.net.Socket; +import java.net.SocketAddress; import java.sql.*; @@ -18,18 +23,21 @@ public class ReadAccessDatabase { public static void main(String[] args) { + Boolean aBoolean = IsConnectTcpServer("127.0.0.1", 1200, 100); + String message = aBoolean ? "success" : "fail"; + log.info(message); // 澶氫釜鏁版嵁搴撴枃浠惰矾寰� - String[] dbPaths = { - "D:\\Workspaces\\ard\\瀹夌憺杈惧伐浣滆祫鏂橽\mdb\\閬撹矾涓績绾�.mdb" -// "D:\\Workspaces\\ard\\瀹夌憺杈惧伐浣滆祫鏂橽\mdb\\闃查鏋�-鐏屾湪.mdb", - // 娣诲姞鏇村鐨勬暟鎹簱鏂囦欢璺緞 - }; - - // 閬嶅巻姣忎釜鏁版嵁搴撴枃浠� - for (String dbPath : dbPaths) { - readDataFromAccessDatabase(dbPath); - } +// String[] dbPaths = { +// "D:\\Workspaces\\ard\\瀹夌憺杈惧伐浣滆祫鏂橽\mdb\\閬撹矾涓績绾�.mdb" +//// "D:\\Workspaces\\ard\\瀹夌憺杈惧伐浣滆祫鏂橽\mdb\\闃查鏋�-鐏屾湪.mdb", +// // 娣诲姞鏇村鐨勬暟鎹簱鏂囦欢璺緞 +// }; +// +// // 閬嶅巻姣忎釜鏁版嵁搴撴枃浠� +// for (String dbPath : dbPaths) { +// readDataFromAccessDatabase(dbPath); +// } } public static void readDataFromAccessDatabase(String dbPath) { @@ -73,7 +81,7 @@ // 鍙互鏍规嵁鍏蜂綋鐨勮〃缁撴瀯缁х画鑾峰彇鍏朵粬瀛楁鐨勬暟鎹� // 鍦ㄨ繖閲屽鐞嗚幏鍙栧埌鐨勬暟鎹紝渚嬪杈撳嚭鍒版帶鍒跺彴鎴栦繚瀛樺埌闆嗗悎涓� - log.info("ID: " + id + ", No: " + no+ ", Name: " + name); + log.info("ID: " + id + ", No: " + no + ", Name: " + name); } // 鍏抽棴杩炴帴 resultSet.close(); @@ -86,6 +94,17 @@ } } + public static Boolean IsConnectTcpServer(String ip,Integer port,Integer timeOut) { + try { + Socket socket = new Socket(); + socket.connect(new InetSocketAddress(ip, port), timeOut); + socket.close(); + return true; + } catch (IOException e) { + // log.error(e.getMessage()); + return false; + } + } } -- Gitblit v1.9.3