From f7f4dc8cd0bf15953ee47146d3ef74b4dd4950a4 Mon Sep 17 00:00:00 2001
From: aijinhui <aijinhui>
Date: 星期四, 12 十月 2023 09:44:01 +0800
Subject: [PATCH] mq测试
---
ard-work/src/main/java/com/ruoyi/test/ReadAccessDatabase.java | 49 +++++++++++++++++++++++++++++++------------------
1 files changed, 31 insertions(+), 18 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 2d48af9..e9d1151 100644
--- a/ard-work/src/main/java/com/ruoyi/test/ReadAccessDatabase.java
+++ b/ard-work/src/main/java/com/ruoyi/test/ReadAccessDatabase.java
@@ -8,34 +8,36 @@
* @Version: 1.0
**/
-import com.ruoyi.common.utils.ConfigUtils;
-import com.ruoyi.common.utils.DictUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
-import javax.annotation.PostConstruct;
+import java.io.IOException;
+import java.net.InetSocketAddress;
+import java.net.Socket;
+import java.net.SocketAddress;
import java.sql.*;
-import java.util.Collection;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
+
@Slf4j
@Component
public class ReadAccessDatabase {
public static void main(String[] args) {
- // 澶氫釜鏁版嵁搴撴枃浠惰矾寰�
- String[] dbPaths = {
- "D:\\Workspaces\\ard\\瀹夌憺杈惧伐浣滆祫鏂橽\mdb\\閬撹矾涓績绾�.mdb"
-// "D:\\Workspaces\\ard\\瀹夌憺杈惧伐浣滆祫鏂橽\mdb\\闃查鏋�-鐏屾湪.mdb",
- // 娣诲姞鏇村鐨勬暟鎹簱鏂囦欢璺緞
- };
+ Boolean aBoolean = IsConnectTcpServer("127.0.0.1", 1200, 100);
+ String message = aBoolean ? "success" : "fail";
+ log.info(message);
- // 閬嶅巻姣忎釜鏁版嵁搴撴枃浠�
- 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) {
@@ -79,7 +81,7 @@
// 鍙互鏍规嵁鍏蜂綋鐨勮〃缁撴瀯缁х画鑾峰彇鍏朵粬瀛楁鐨勬暟鎹�
// 鍦ㄨ繖閲屽鐞嗚幏鍙栧埌鐨勬暟鎹紝渚嬪杈撳嚭鍒版帶鍒跺彴鎴栦繚瀛樺埌闆嗗悎涓�
- log.info("ID: " + id + ", No: " + no+ ", Name: " + name);
+ log.info("ID: " + id + ", No: " + no + ", Name: " + name);
}
// 鍏抽棴杩炴帴
resultSet.close();
@@ -92,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