更新

src/main/java/com/scbfkj/uni/api/GenericApi.java

@@ -64,7 +64,11 @@ public class GenericApi {
 			return ResponseEntity.ok(Map.of("code", "400", "msg", "请求体不能为空"));
 		}
 		String uri = RequestUtil.getUri(); // 获取当前请求的URI
-
+		return execService(body, uri);
+	}
+	
+	public static ResponseEntity<Map<String, Object>> execService(final Map<String, Object> body,
+	                                                                        final String uri) throws Exception {
 		// 查询数据库，尝试匹配服务
 		List<Map<String, Object>> serviceinfoList = DATA_BASE.query(Config.getCenterConnectionStr(), """
 				select serviceid
@@ -81,6 +85,5 @@ public class GenericApi {
 		// 执行服务处理并返回处理结果
 		return ResponseEntity.ok(new ProcessUtil().process(body));
 	}
-
 }
 

src/main/java/com/scbfkj/uni/api/LogAop.java

@@ -1,6 +1,13 @@
 package com.scbfkj.uni.api;
 
 import com.google.common.util.concurrent.RateLimiter;
+
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Component;
+
 import com.scbfkj.uni.library.DataAliasGetUtil;
 import com.scbfkj.uni.library.DataFormatUtil;
 import com.scbfkj.uni.library.RequestUtil;
@@ -9,15 +16,14 @@ import com.scbfkj.uni.process.DataBase;
 import com.scbfkj.uni.service.LoggerService;
 import com.scbfkj.uni.system.Config;
 import com.scbfkj.uni.utils.Util;
-import jakarta.annotation.Resource;
-import org.aspectj.lang.ProceedingJoinPoint;
-import org.aspectj.lang.annotation.Around;
-import org.aspectj.lang.annotation.Aspect;
-import org.springframework.http.ResponseEntity;
-import org.springframework.stereotype.Component;
 
 import java.time.LocalDateTime;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
 import java.util.concurrent.TimeUnit;
 
 /**
@@ -26,207 +32,224 @@ import java.util.concurrent.TimeUnit;
 @Component
 @Aspect
 public class LogAop {
-
-	// 用于存储限流规则的映射
-	private static final Map<String, RateLimiter> rateLimiterMap = new HashMap<>();
-	// 数据库操作实例
-	private static final DataBase DATA_BASE = new DataBase();
-	// 工具类实例
-	@Resource
-	private Util util;
-
-	/**
-	 * 环绕通知，拦截指定包下的Api请求。
-	 *
-	 * @param joinPoint 切点表达式匹配到的连接点
-	 *
-	 * @return 返回处理后的响应实体
-	 *
-	 * @throws Throwable 抛出异常时处理
-	 */
-	@Around(value = "within(com.scbfkj.uni.api.*Api)")
-	public ResponseEntity<Object> invokeAround(ProceedingJoinPoint joinPoint) throws Throwable {
-
-		String methodName = joinPoint.getSignature().getName();
-		String className = joinPoint.getSignature().getDeclaringTypeName();
-
-		if ( "matchService".equals(methodName) && GenericApi.class.getName().equals(className) ) {
-			String requestBody = RequestUtil.getRequestBody();
-			if ( requestBody != null ) {
-				Map<String, Object> body = (Map<String, Object>) DataFormatUtil.toMap(requestBody);
-				joinPoint.getArgs()[0] = body;
-			}
-		}
-
-		LocalDateTime requestTime = LocalDateTime.now();
-		// 获取请求信息
-		String uri = RequestUtil.getUri();
-		Object[] args = joinPoint.getArgs();
-		Map<String, Object> returnData = null;
-		String message = null;
-		Map<String, Object> userInfo = RequestUtil.getUserInfo();
-
-		Optional<String> serviceid = Optional.empty();
-		String userId = RequestUtil.getUserId();
-		
-
-		try {
-			Map<String, Object> body = null;
-			// 检查除特定接口外的服务状态
-			if ( args.length > 0 && ! uri.startsWith("/controlApi") && ! uri.startsWith("/file") && ! uri.startsWith("/user") && ! uri.startsWith("/foxlibc") && ! uri.startsWith("/ws") ) {
-				Object arg = args[0];
-				if ( arg instanceof Map<?, ?> map ) {
-					body = (Map<String, Object>) map;
-					Util.addFilter(body, serviceid, uri, true);
-					serviceid = DataAliasGetUtil.getValue("serviceid", (Map<String, Object>) map);
-					if ( serviceid.isEmpty() ) {
-						List<Map<String, Object>> query = DATA_BASE.query(Config.getCenterConnectionStr(), "select * from serviceinfo where urilist=?", uri);
-						if ( ! query.isEmpty() ) {
-							serviceid = DataAliasGetUtil.getValue("serviceid", query.get(0));
-						}
-					}
-					if ( serviceid.isPresent() ) {
-						// 检查服务运行状态
-						List<Map<String, Object>> mapList = DATA_BASE.query(Config.getCenterConnectionStr(), "select runstate from servicestate where stoptime is null and  serviceid=? and containercode = ?", serviceid.get(), Config.getContainerCode());
-						if ( mapList.isEmpty() ) {
-							throw new RuntimeException("服务没有运行或者被熔断");
-						} else {
-							Map<String, Object> serviceState = mapList.get(0);
-							Object o = serviceState.get("runstate");
-							// 判断服务状态
-							if ( Objects.equals(o.toString(), "0") ) {
-								throw new RuntimeException("服务没有运行或者被熔断");
-							}
-						}
-					}
-				}
-			}
-
-			// 检查是否符合限流规则
-			message = checkratelimitrule(uri);
-			if ( Objects.nonNull(message) ) {
-				return ResponseEntity.ok(UniReturnUtil.fail(message));
-			}
-
-			// 继续执行原方法逻辑
-			ResponseEntity<Map<String, Object>> responseEntity = (ResponseEntity<Map<String, Object>>) joinPoint.proceed(args);
-			Map<String, Object> responseEntityBody = responseEntity.getBody();
-			if ( responseEntity.getStatusCode().is2xxSuccessful() ) {
-				if ( Config.isDebug() ) {
-					System.out.println("返回值：" + DataFormatUtil.toString(returnData));
-				}
-				// 处理返回数据，如果是调试模式，直接返回
-				if ( "0".equals(responseEntityBody.get("code")) && serviceid.isPresent() ) {
-					List<Map<String, Object>> serviceInfoes = DATA_BASE.query(Config.getCenterConnectionStr(), "select * from serviceinfo where serviceid=?", serviceid.get());
-					if ( ! serviceInfoes.isEmpty() ) {
-						Map<String, Object> serviceInfo = serviceInfoes.get(0);
-						Object raw = serviceInfo.get("raw");
-						if ( raw != null && raw.toString().equalsIgnoreCase("1") ) {
-							Object data = responseEntityBody.getOrDefault("returnData", responseEntityBody);
-							if ( data instanceof List<?> d && d.size() == 1 ) {
-								data = d.get(0);
-							}
-							return ResponseEntity.ok(data);
-						}
-					}
-				}
-				return ResponseEntity.ok(responseEntityBody);
-			} else {
-				returnData = responseEntityBody;
-			}
-
-		} catch ( Throwable e ) {
-			if ( Config.isDebug() ) {
-				e.printStackTrace();
-			}
-			// 错误处理，生成错误日志消息
-			message = UniReturnUtil.getMessage(e);
-			returnData = UniReturnUtil.fail(message);
-		} finally {
-			// 记录日志
-			HashMap<String, Object> logData = new HashMap<>();
-			logData.put("requesttime", requestTime);
-			logData.put("requestpath", uri);
-			logData.put("requestdata", DataFormatUtil.toString(args));
-			logData.put("sessionid", RequestUtil.getSessionId());
-			logData.put("returndata", DataFormatUtil.toString(returnData));
-			logData.put("returntime", LocalDateTime.now());
-			try {
-				logData.put("applicationid", RequestUtil.getAppId());
-			} catch ( Exception e ) {
-				if ( Config.isDebug() ) {
-					e.printStackTrace();
-				}
-			}
-			LoggerService.log(LoggerService.LogType.INTERFACE, logData);
-		}
-
-		Object code = returnData.get("code");
-		// 过滤返回数据
-		if ( ! Config.isDebug() && Objects.nonNull(code) && "0".equals(code.toString()) && Objects.nonNull(userInfo) && ! "0".equals(userInfo.get("usergroupid").toString()) ) {
-			Object returnData1 = returnData.get("returnData");
-			if ( returnData1 instanceof List<?> ls ) {
-				if ( serviceid.isPresent() ) {
-					try {
-						List<String> columns = DATA_BASE.query(Config.getSecurityConnectionStr(), "select pagecode from pageconfiguration where pageconfigurationid  in (select userpermissions.pageconfigurationid from userpermissions where  userid =? and  serviceid = ?)", userId, serviceid.get()).stream().map(it -> it.get("pagecode").toString()).toList();
-						List<Object> list = ls.stream().map(it -> {
-							if ( it instanceof Map<?, ?> map ) {
-								HashMap<Object, Object> map1 = new HashMap<>();
-								columns.forEach(key -> {
-									map1.put(key, map.get(key));
-								});
-								return map1;
-							} else {
-								return it;
-							}
-						}).toList();
-						returnData.put("returnData", list);
-
-					} catch ( Exception e ) {
-						returnData.put("returnData", new ArrayList<>());
-					}
-
-				}
-			}
-		}
-		return ResponseEntity.ok(returnData);
-	}
-
-	/**
-	 * 检查请求是否符合限流规则。
-	 *
-	 * @param uri 请求的URI
-	 *
-	 * @return 如果请求超过限流规则，则返回提示消息；否则返回null。
-	 *
-	 * @throws Exception 抛出异常时处理
-	 */
-	private String checkratelimitrule(String uri) throws Exception {
-		// 从数据库查询限流规则
-		List<Map<String, Object>> ratelimitruleList = DATA_BASE.query(Config.getSecurityConnectionStr(), "select * from ratelimitrule ");
-		Optional<Map<String, Object>> optional = ratelimitruleList.stream().filter(it -> {
-			Object pathMatch = it.get("pathmatch");
-			if ( Objects.isNull(pathMatch) ) return true;
-			return uri.matches(pathMatch.toString());
-		}).findFirst();
-		if ( optional.isPresent() ) {
-			Map<String, Object> map = optional.get();
-			String pathMatch = map.get("pathmatch").toString();
-			if ( ! rateLimiterMap.containsKey(pathMatch) ) {
-				// 创建新的限流器
-				String duration = map.getOrDefault("duration", 1).toString();
-				String limitValue = map.getOrDefault("limitvalue", 100).toString();
-				rateLimiterMap.put(pathMatch, RateLimiter.create(Double.parseDouble(limitValue), Integer.parseInt(duration), TimeUnit.SECONDS));
-			}
-			RateLimiter rateLimiter = rateLimiterMap.get(pathMatch);
-			String timeOut = map.getOrDefault("timeout", 1).toString();
-			// 尝试获取许可，如果失败则表示请求超过限流阈值
-			boolean acquire = rateLimiter.tryAcquire(Integer.parseInt(timeOut), TimeUnit.SECONDS);
-			if ( ! acquire ) {
-				return map.getOrDefault("returnmessage", "请求频率过高，请降低请求频率").toString();
-			}
-		}
-		return null;
-	}
+    // 用于存储限流规则的映射
+    private static final Map<String, RateLimiter> rateLimiterMap = new HashMap<>();
+    
+    // 数据库操作实例
+    private static final DataBase DATA_BASE = new DataBase();
+    
+    /**
+     * 环绕通知，拦截指定包下的Api请求。
+     *
+     * @param joinPoint 切点表达式匹配到的连接点
+     *
+     * @return 返回处理后的响应实体
+     *
+     * @throws Throwable 抛出异常时处理
+     */
+    @Around(value = "within(com.scbfkj.uni.api.*Api)")
+    public ResponseEntity<Object> invokeAround(ProceedingJoinPoint joinPoint) throws Throwable {
+        String methodName = joinPoint.getSignature().getName();
+        String className = joinPoint.getSignature().getDeclaringTypeName();
+        if ("matchService".equals(methodName) && GenericApi.class.getName().equals(className)) {
+            String requestBody = RequestUtil.getRequestBody();
+            if (requestBody != null) {
+                Map<String, Object> body = (Map<String, Object>) DataFormatUtil.toMap(requestBody);
+                joinPoint.getArgs()[0] = body;
+            }
+        }
+        String uri = RequestUtil.getUri();
+        LocalDateTime requestTime = LocalDateTime.now();
+        // 获取请求信息
+        Object[] args = joinPoint.getArgs();
+        Map<String, Object> returnData = null;
+        String message = null;
+        Map<String, Object> userInfo = RequestUtil.getUserInfo();
+        Optional<String> serviceid = Optional.empty();
+        String userId = RequestUtil.getUserId();
+        try {
+            Map<String, Object> body = null;
+            // 检查除特定接口外的服务状态
+            if (args.length > 0 && ! uri.startsWith("/ws")) {
+                Object arg = args[0];
+                if (arg instanceof Map<?, ?> map) {
+                    body = (Map<String, Object>) map;
+                    Util.addFilter(body, serviceid, uri, true);
+                    serviceid = DataAliasGetUtil.getValue("serviceid", (Map<String, Object>) map);
+                    if (serviceid.isEmpty()) {
+                        List<Map<String, Object>> query = DATA_BASE.query(Config.getCenterConnectionStr(),
+                                                                          "select * from serviceinfo where urilist=?",
+                                                                          uri);
+                        if (! query.isEmpty()) {
+                            serviceid = DataAliasGetUtil.getValue("serviceid", query.get(0));
+                        }
+                    }
+                    if (serviceid.isPresent() && ! uri.startsWith("/controlApi") && ! uri.startsWith("/file") &&
+                            ! uri.startsWith("/user") && ! uri.startsWith("/foxlibc")) {
+                        // 检查服务运行状态
+                        List<Map<String, Object>> mapList = DATA_BASE.query(Config.getCenterConnectionStr(),
+                                                                            "select runstate from servicestate where " +
+                                                                                    "stoptime is null and  " +
+                                                                                    "serviceid=? and containercode = ?",
+                                                                            serviceid.get(), Config.getContainerCode());
+                        if (mapList.isEmpty()) {
+                            throw new RuntimeException("服务没有运行或者被熔断");
+                        } else {
+                            Map<String, Object> serviceState = mapList.get(0);
+                            Object o = serviceState.get("runstate");
+                            // 判断服务状态
+                            if (Objects.equals(o.toString(), "0")) {
+                                throw new RuntimeException("服务没有运行或者被熔断");
+                            }
+                        }
+                    }
+                }
+            }
+            // 检查是否符合限流规则
+            message = checkratelimitrule(uri);
+            if (Objects.nonNull(message)) {
+                return ResponseEntity.ok(UniReturnUtil.fail(message));
+            }
+            List<Map<String, Object>> maps =
+                    DATA_BASE.query(Config.getSecurityConnectionStr(), "select 1 from apiinfo where requestpath = ? " +
+                                            "limit 1 offset 0",
+                                    uri);
+            ResponseEntity<Map<String, Object>> responseEntity;
+            if (! maps.isEmpty()) {
+                responseEntity = GenericApi.execService(body, uri);
+            } else {
+                responseEntity = (ResponseEntity<Map<String, Object>>) joinPoint.proceed(args);
+            }
+            // 继续执行原方法逻辑
+            Map<String, Object> responseEntityBody = responseEntity.getBody();
+            if (responseEntity.getStatusCode().is2xxSuccessful()) {
+                if (Config.isDebug()) {
+                    System.out.println("返回值：" + DataFormatUtil.toString(returnData));
+                }
+                // 处理返回数据，如果是调试模式，直接返回
+                if ("0".equals(responseEntityBody.get("code")) && serviceid.isPresent()) {
+                    List<Map<String, Object>> serviceInfoes = DATA_BASE.query(Config.getCenterConnectionStr(),
+                                                                              "select * from serviceinfo where " +
+                                                                                      "serviceid=?",
+                                                                              serviceid.get());
+                    if (! serviceInfoes.isEmpty()) {
+                        Map<String, Object> serviceInfo = serviceInfoes.get(0);
+                        Object raw = serviceInfo.get("raw");
+                        if (raw != null && raw.toString().equalsIgnoreCase("1")) {
+                            Object data = responseEntityBody.getOrDefault("returnData", responseEntityBody);
+                            if (data instanceof List<?> d && d.size() == 1) {
+                                data = d.get(0);
+                            }
+                            return ResponseEntity.ok(data);
+                        }
+                    }
+                }
+                return ResponseEntity.ok(responseEntityBody);
+            } else {
+                returnData = responseEntityBody;
+            }
+        } catch (Throwable e) {
+            if (Config.isDebug()) {
+                e.printStackTrace();
+            }
+            // 错误处理，生成错误日志消息
+            message = UniReturnUtil.getMessage(e);
+            returnData = UniReturnUtil.fail(message);
+        } finally {
+            // 记录日志
+            HashMap<String, Object> logData = new HashMap<>();
+            logData.put("requesttime", requestTime);
+            logData.put("requestpath", uri);
+            logData.put("requestdata", DataFormatUtil.toString(args));
+            logData.put("sessionid", RequestUtil.getSessionId());
+            logData.put("returndata", DataFormatUtil.toString(returnData));
+            logData.put("returntime", LocalDateTime.now());
+            try {
+                logData.put("applicationid", RequestUtil.getAppId());
+            } catch (Exception e) {
+                if (Config.isDebug()) {
+                    e.printStackTrace();
+                }
+            }
+            LoggerService.log(LoggerService.LogType.INTERFACE, logData);
+        }
+        Object code = returnData.get("code");
+        // 过滤返回数据
+        if (! Config.isDebug() && Objects.nonNull(code) && "0".equals(code.toString()) && Objects.nonNull(userInfo) &&
+                ! "0".equals(userInfo.get("usergroupid").toString())) {
+            Object returnData1 = returnData.get("returnData");
+            if (returnData1 instanceof List<?> ls) {
+                if (serviceid.isPresent()) {
+                    try {
+                        List<String> columns = DATA_BASE.query(Config.getSecurityConnectionStr(),
+                                                               "select pagecode from pageconfiguration where " +
+                                                                       "pageconfigurationid  in (select " +
+                                                                       "userpermissions.pageconfigurationid from " +
+                                                                       "userpermissions where  userid =? and  " +
+                                                                       "serviceid = ?)",
+                                                               userId, serviceid.get()).stream()
+                                                        .map(it -> it.get("pagecode").toString()).toList();
+                        List<Object> list = ls.stream().map(it -> {
+                            if (it instanceof Map<?, ?> map) {
+                                HashMap<Object, Object> map1 = new HashMap<>();
+                                columns.forEach(key -> {
+                                    map1.put(key, map.get(key));
+                                });
+                                return map1;
+                            } else {
+                                return it;
+                            }
+                        }).toList();
+                        returnData.put("returnData", list);
+                    } catch (Exception e) {
+                        returnData.put("returnData", new ArrayList<>());
+                    }
+                }
+            }
+        }
+        return ResponseEntity.ok(returnData);
+    }
+    
+    /**
+     * 检查请求是否符合限流规则。
+     *
+     * @param uri 请求的URI
+     *
+     * @return 如果请求超过限流规则，则返回提示消息；否则返回null。
+     *
+     * @throws Exception 抛出异常时处理
+     */
+    private String checkratelimitrule(String uri) throws Exception {
+        // 从数据库查询限流规则
+        List<Map<String, Object>> ratelimitruleList =
+                DATA_BASE.query(Config.getSecurityConnectionStr(), "select * from ratelimitrule ");
+        Optional<Map<String, Object>> optional = ratelimitruleList.stream().filter(it -> {
+            Object pathMatch = it.get("pathmatch");
+            if (Objects.isNull(pathMatch)) {
+                return true;
+            }
+            return uri.matches(pathMatch.toString());
+        }).findFirst();
+        if (optional.isPresent()) {
+            Map<String, Object> map = optional.get();
+            String pathMatch = map.get("pathmatch").toString();
+            if (! rateLimiterMap.containsKey(pathMatch)) {
+                // 创建新的限流器
+                String duration = map.getOrDefault("duration", 1).toString();
+                String limitValue = map.getOrDefault("limitvalue", 100).toString();
+                rateLimiterMap.put(pathMatch,
+                                   RateLimiter.create(Double.parseDouble(limitValue), Integer.parseInt(duration),
+                                                      TimeUnit.SECONDS));
+            }
+            RateLimiter rateLimiter = rateLimiterMap.get(pathMatch);
+            String timeOut = map.getOrDefault("timeout", 1).toString();
+            // 尝试获取许可，如果失败则表示请求超过限流阈值
+            boolean acquire = rateLimiter.tryAcquire(Integer.parseInt(timeOut), TimeUnit.SECONDS);
+            if (! acquire) {
+                return map.getOrDefault("returnmessage", "请求频率过高，请降低请求频率").toString();
+            }
+        }
+        return null;
+    }
 }
 

src/main/java/com/scbfkj/uni/library/script/JavaScriptEngineUtil.java

@@ -1,14 +1,15 @@
 package com.scbfkj.uni.library.script;
 
-import com.fasterxml.jackson.databind.JsonNode;
-import com.scbfkj.uni.library.DataFormatUtil;
-import com.scbfkj.uni.library.UniReturnUtil;
 import org.apache.commons.pool2.BaseKeyedPooledObjectFactory;
 import org.apache.commons.pool2.KeyedObjectPool;
 import org.apache.commons.pool2.PooledObject;
 import org.apache.commons.pool2.impl.DefaultPooledObject;
 import org.apache.commons.pool2.impl.GenericKeyedObjectPool;
 
+import com.fasterxml.jackson.databind.JsonNode;
+import com.scbfkj.uni.library.DataFormatUtil;
+import com.scbfkj.uni.library.UniReturnUtil;
+
 import java.io.File;
 import java.lang.reflect.InvocationTargetException;
 import java.lang.reflect.Method;
@@ -19,100 +20,115 @@ import java.util.Map;
 import java.util.Objects;
 
 public class JavaScriptEngineUtil {
-/**
- * 创建并管理Java应用执行实例的池子。这个池子keyed到具体的执行路径和类名上，允许复用Java方法的执行实例。
- */
-private static final KeyedObjectPool<String, JavaApply> javaRefPool = new GenericKeyedObjectPool<>(new BaseKeyedPooledObjectFactory<String, JavaApply>() {
-
-    /**
-     * 根据提供的key创建一个新的JavaApply实例。
-     * @param key 包含执行路径、类名和方法名的JSON字符串。
-     * @return 一个初始化好的JavaApply实例，准备放入池中供调用。
-     * @throws Exception 如果过程中出现错误，比如类加载失败或方法找不到。
-     */
-    @Override
-    public JavaApply create(String key) throws Exception {
-        // 从key解析出路径、类名和方法名
-        JsonNode jsonNode = DataFormatUtil.toJsonNode(key);
-        JsonNode path = jsonNode.get("path");
-        JsonNode className = jsonNode.get("className");
-        JsonNode method = jsonNode.get("methodName");
-        ClassLoader classLoader = null;
-        // 根据提供的路径加载外部类
-        if (Objects.nonNull(path) && !path.isNull()) {
-            String userPath = System.getProperty("user.dir");
-            File file = new File(userPath.concat(File.separator).concat("plugins").concat(File.separator).concat(path.asText()));
-            // 检查文件是否存在
-            if (!file.exists()) {
-                throw new RuntimeException("外部文件加载不存在：".concat(userPath).concat(File.separator).concat("plugins").concat(File.separator).concat(path.asText()));
-            }
-            URL url = file.toURI().toURL();
-            classLoader = new URLClassLoader(new URL[]{url}, Thread.currentThread().getContextClassLoader());
-        } else {
-            classLoader = Thread.currentThread().getContextClassLoader();
-        }
-        // 加载指定的类和方法
-        Class<?> classExample = classLoader.loadClass(className.asText());
-        Method javaMethod = null;
-        Method closeMethod = null;
-        for (Method currentMethod : classExample.getMethods()) {
-            String methodName = currentMethod.getName();
-            if (methodName.equals(method.asText())) {
-                javaMethod = currentMethod;
-            } else if ("close".equals(methodName)) {
-                closeMethod = currentMethod;
-            }
-        }
-
-        Object classInstance = null;
-        if (javaMethod != null) {
-            int modifiers = javaMethod.getModifiers();
-            boolean aStatic = Modifier.isStatic(modifiers);
-            // 如果方法非静态，则实例化类
-            if (!aStatic) {
-                classInstance = classExample.getConstructor().newInstance();
-            }
-        }
-
-        // 返回包含类实例、方法和关闭方法的JavaApply对象
-        return new JavaApply(classInstance, javaMethod, closeMethod);
-    }
-    /**
-     * 将JavaApply实例包装成池能够管理的形式。
-     * @param value 需要被包装的JavaApply实例。
-     * @return 一个DefaultPooledObject，包含了一个JavaApply实例。
-     */
-    @Override
-    public PooledObject<JavaApply> wrap(JavaApply value) {
-        return new DefaultPooledObject<>(value);
-    }
     /**
-     * 销毁从池中取出并使用后的JavaApply实例，调用其关闭方法。
-     * @param key 与该实例对应的key。
-     * @param p 包含了需要销毁的JavaApply实例的DefaultPooledObject。
-     * @throws Exception 如果在销毁过程中出现错误。
+     * 创建并管理Java应用执行实例的池子。这个池子keyed到具体的执行路径和类名上，允许复用Java方法的执行实例。
      */
-    @Override
-    public void destroyObject(String key, PooledObject<JavaApply> p) throws Exception {
-        JavaApply javaApply = p.getObject();
-        javaApply.invokeClose();
-    }
-});
-
+    private static final KeyedObjectPool<String, JavaApply> javaRefPool =
+            new GenericKeyedObjectPool<>(new BaseKeyedPooledObjectFactory<String, JavaApply>() {
+                /**
+                 * 根据提供的key创建一个新的JavaApply实例。
+                 * @param key 包含执行路径、类名和方法名的JSON字符串。
+                 * @return 一个初始化好的JavaApply实例，准备放入池中供调用。
+                 * @throws Exception 如果过程中出现错误，比如类加载失败或方法找不到。
+                 */
+                @Override
+                public JavaApply create(String key) throws Exception {
+                    // 从key解析出路径、类名和方法名
+                    JsonNode jsonNode = DataFormatUtil.toJsonNode(key);
+                    JsonNode path = jsonNode.get("path");
+                    JsonNode className = jsonNode.get("className");
+                    JsonNode method = jsonNode.get("methodName");
+                    ClassLoader classLoader = null;
+                    // 根据提供的路径加载外部类
+                    Class<?> classExample = null;
+                    try {
+                        if (Objects.nonNull(path) && ! path.isNull()) {
+                            String userPath = System.getProperty("user.dir");
+                            File file = new File(
+                                    userPath.concat(File.separator).concat("plugins").concat(File.separator)
+                                            .concat(path.asText()));
+                            // 检查文件是否存在
+                            if (! file.exists()) {
+                                throw new RuntimeException(
+                                        "外部文件加载不存在：".concat(userPath).concat(File.separator).concat("plugins")
+                                                             .concat(File.separator).concat(path.asText()));
+                            }
+                            URL url = file.toURI().toURL();
+                            classLoader =
+                                    new URLClassLoader(new URL[]{url}, Thread.currentThread().getContextClassLoader());
+                            classExample = classLoader.loadClass(className.asText());
+                        } else {
+                            classLoader = Thread.currentThread().getContextClassLoader();
+                            classExample = classLoader.loadClass(className.asText());
+                        }
+                    }catch (Exception e){
+                        e.printStackTrace();
+                        throw new RuntimeException(e);
+                    }
+                    // 加载指定的类和方法
+                    Method javaMethod = null;
+                    Method closeMethod = null;
+                    for (Method currentMethod : classExample.getMethods()) {
+                        String methodName = currentMethod.getName();
+                        if (methodName.equals(method.asText())) {
+                            javaMethod = currentMethod;
+                        } else if ("close".equals(methodName)) {
+                            closeMethod = currentMethod;
+                        }
+                    }
+                    Object classInstance = null;
+                    if (javaMethod != null) {
+                        int modifiers = javaMethod.getModifiers();
+                        boolean aStatic = Modifier.isStatic(modifiers);
+                        // 如果方法非静态，则实例化类
+                        if (! aStatic) {
+                            classInstance = classExample.getConstructor().newInstance();
+                        }
+                    }
+                    // 返回包含类实例、方法和关闭方法的JavaApply对象
+                    return new JavaApply(classInstance, javaMethod, closeMethod);
+                }
+                
+                /**
+                 * 将JavaApply实例包装成池能够管理的形式。
+                 * @param value 需要被包装的JavaApply实例。
+                 * @return 一个DefaultPooledObject，包含了一个JavaApply实例。
+                 */
+                @Override
+                public PooledObject<JavaApply> wrap(JavaApply value) {
+                    return new DefaultPooledObject<>(value);
+                }
+                
+                /**
+                 * 销毁从池中取出并使用后的JavaApply实例，调用其关闭方法。
+                 * @param key 与该实例对应的key。
+                 * @param p 包含了需要销毁的JavaApply实例的DefaultPooledObject。
+                 * @throws Exception 如果在销毁过程中出现错误。
+                 */
+                @Override
+                public void destroyObject(String key, PooledObject<JavaApply> p) throws Exception {
+                    JavaApply javaApply = p.getObject();
+                    javaApply.invokeClose();
+                }
+            });
+    
     /**
      * 根据提供的数据源、表达式和参数，调用相应的函数并返回结果。
+     *
      * @param datasource 包含调用所需数据源信息的Map对象，其中必须包含方法名。
      * @param expression 表达式，指定要调用的方法名。
      * @param args 调用方法时传递的参数数组。
+     *
      * @return 返回一个Map对象，包含调用结果或错误信息。
+     *
      * @throws Exception 如果调用过程中发生异常，则抛出。
      */
-    public static Map<String, Object> invoke(Map<String, Object> datasource, String expression, Object... args) throws Exception {
+    public static Map<String, Object> invoke(Map<String, Object> datasource, String expression, Object... args)
+            throws Exception {
         // 将表达式设置为要调用的方法名
         datasource.put("methodName", expression);
         // 通过数据源生成唯一的key
         String key = DataFormatUtil.toString(datasource);
-
         JavaApply javaApply = null;
         try {
             // 从对象池中根据key借用JavaApply对象
@@ -132,14 +148,17 @@ private static final KeyedObjectPool<String, JavaApply> javaRefPool = new Generi
             }
         }
     }
+    
     /**
      * JavaApply类用于封装对象实例、应用方法和关闭方法的调用。
      */
     private static class JavaApply {
         private Object instance; // 应用实例
+        
         private Method apply; // 应用的具体方法
+        
         private Method close; // 关闭资源的方法
-
+        
         /**
          * 构造函数，初始化应用实例、应用方法和关闭方法。
          *
@@ -152,37 +171,37 @@ private static final KeyedObjectPool<String, JavaApply> javaRefPool = new Generi
             this.apply = apply;
             this.close = close;
         }
-
+        
         // 获取应用实例的方法
         public Object getInstance() {
             return instance;
         }
-
+        
         // 设置应用实例的方法
         public void setInstance(Object instance) {
             this.instance = instance;
         }
-
+        
         // 获取应用方法的方法
         public Method getApply() {
             return apply;
         }
-
+        
         // 设置应用方法的方法
         public void setApply(Method apply) {
             this.apply = apply;
         }
-
+        
         // 获取关闭方法的方法
         public Method getClose() {
             return close;
         }
-
+        
         // 设置关闭方法的方法
         public void setClose(Method close) {
             this.close = close;
         }
-
+        
         /**
          * 调用关闭方法。
          *
@@ -194,12 +213,14 @@ private static final KeyedObjectPool<String, JavaApply> javaRefPool = new Generi
                 close.invoke(instance);
             }
         }
-
+        
         /**
          * 调用应用方法。
          *
          * @param args 方法调用的参数。
+         *
          * @return 方法的返回值。
+         *
          * @throws InvocationTargetException 如果调用目标抛出异常。
          * @throws IllegalAccessException 如果没有权限访问方法。
          */
@@ -208,7 +229,7 @@ private static final KeyedObjectPool<String, JavaApply> javaRefPool = new Generi
             // 参数类型检查与转换
             for (int i = 0; i < parameterTypes.length; i++) {
                 Object arg = args[i];
-                if (!parameterTypes[i].isInstance(arg)) {
+                if (! parameterTypes[i].isInstance(arg)) {
                     if (arg != null) {
                         args[i] = DataFormatUtil.castType(arg, parameterTypes[i]);
                     }
@@ -217,5 +238,4 @@ private static final KeyedObjectPool<String, JavaApply> javaRefPool = new Generi
             return apply.invoke(instance, args);
         }
     }
-
 }

src/main/java/com/scbfkj/uni/process/ESB.java

@@ -0,0 +1,61 @@
+/*
+ * 版权所有 (c)
+ */
+
+package com.scbfkj.uni.process;
+
+import com.ibm.msg.client.jms.JmsConnectionFactory;
+import com.ibm.msg.client.jms.JmsConstants;
+import com.ibm.msg.client.jms.JmsFactoryFactory;
+import com.ibm.msg.client.wmq.WMQConstants;
+
+import javax.jms.Connection;
+import javax.jms.JMSException;
+import javax.jms.MessageProducer;
+import javax.jms.Queue;
+import javax.jms.Session;
+
+/**
+ * @author l7871
+ * @apiNote: 说明描述
+ * @description
+ * @date 2024/8/1 下午3:03
+ * @since
+ */
+public class ESB {
+        public void sendESBMessage(String data) throws JMSException {
+        JmsFactoryFactory ff = JmsFactoryFactory.getInstance(JmsConstants.WMQ_PROVIDER);
+        JmsConnectionFactory factory = ff.createConnectionFactory();
+        factory.setIntProperty(WMQConstants.WMQ_CONNECTION_MODE, WMQConstants.WMQ_CM_CLIENT);
+        factory.setStringProperty(WMQConstants.WMQ_QUEUE_MANAGER, "QM_GW_DIB");
+        factory.setStringProperty(WMQConstants.WMQ_HOST_NAME, "edip.airchina.com.cn");
+        factory.setIntProperty(WMQConstants.WMQ_PORT, 14100);
+        factory.setStringProperty(WMQConstants.WMQ_CHANNEL, "SVRCONN_QM_GW_DIB");
+        factory.setStringProperty(WMQConstants.WMQ_APPLICATIONNAME, "TEST Application");
+        factory.setIntProperty(WMQConstants.WMQ_CCSID, 1208);
+        factory.setStringProperty(WMQConstants.USERID, "BFPTS");
+        factory.setStringProperty(WMQConstants.PASSWORD, "=GDlgr)s5wIma");
+        Connection connection = null;
+        Session session = null;
+        MessageProducer producer = null;
+        try {
+            connection = factory.createConnection();
+            session = connection.createSession();
+            connection.start();
+            Queue queue = session.createQueue("COM.PUBSUB.PUBLISH.Q");
+            producer = session.createProducer(queue);
+            producer.send(session.createTextMessage(data));
+            System.out.println("已发送消息：" + data);
+        } finally {
+            if (producer != null) {
+                producer.close();
+            }
+            if (session != null) {
+                session.close();
+            }
+            if (connection != null) {
+                connection.close();
+            }
+        }
+    }
+}

src/main/java/com/scbfkj/uni/process/IBMMQ2.java

@@ -0,0 +1,285 @@
+package com.scbfkj.uni.process;
+
+import com.ibm.msg.client.jms.JmsConnectionFactory;
+import com.ibm.msg.client.jms.JmsConstants;
+import com.ibm.msg.client.jms.JmsFactoryFactory;
+import com.ibm.msg.client.wmq.WMQConstants;
+import com.scbfkj.uni.exceptions.ConnectionNotFoundException;
+import com.scbfkj.uni.system.Config;
+
+import javax.jms.Connection;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.MessageConsumer;
+import javax.jms.MessageProducer;
+import javax.jms.Queue;
+import javax.jms.Session;
+import javax.jms.TextMessage;
+import javax.jms.Topic;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
+
+/**
+ * IBM MQ客户端类，用于发送和接收消息。
+ */
+public class IBMMQ2 {
+    private static final DataBase DATA_BASE = new DataBase();
+    
+    private JmsConnectionFactory jmsConnectionFactory = null;
+    
+    public List<String> receptionMessageByDataSourceId(String dataSourceId, String channel, String targetUri,
+                                                       Long ccsid, Long receiveTimeout, Long pollSize)
+            throws Exception {
+        // 根据数据源ID查询连接配置
+        Map<String, Object> config = queryConnectionStr(dataSourceId);
+        long port = 1414L; // 默认端口号
+        // 从连接配置中解析主机名和端口号
+        String host = Objects.toString(config.get("host"));
+        if (host.contains(":")) {
+            String[] split = host.split(":");
+            port = Long.parseLong(split[1]);
+            host = split[0];
+        }
+        // 从连接配置中解析用户名和密码
+        String username = null;
+        String password = null;
+        Object username1 = config.get("username");
+        if (Objects.nonNull(username1)) {
+            username = username1.toString();
+        }
+        Object password1 = config.get("password");
+        if (Objects.nonNull(password1)) {
+            password = password1.toString();
+        }
+        // 使用解析出的配置信息进行消息接收
+        return receptionMessage(host, port, channel, targetUri, ccsid, username, password, receiveTimeout, pollSize);
+    }
+    
+    public List<String> receptionMessage(String host, Long port, String channel, String targetUri, Long ccsid,
+                                         String username, String password, Long receiveTimeout, Long pollSize)
+            throws JMSException {
+        JmsConnectionFactory factory = getJmsConnectionFactory(host, port, channel, ccsid, username, password);
+        Connection connection = null;
+        Session session = null;
+        MessageConsumer consumer = null;
+        List<String> result = new ArrayList<>();
+        try {
+            connection = factory.createConnection();
+            session = connection.createSession();
+            connection.start();
+            if (targetUri.startsWith("queue://")) {
+                Queue queue = session.createQueue(targetUri);
+                consumer = session.createConsumer(queue);
+            } else if (targetUri.startsWith("topic://")) {
+                Topic topic = session.createTopic(targetUri);
+                consumer = session.createConsumer(topic);
+            }
+            while (true) {
+                Message receive = consumer.receive(receiveTimeout);
+                if (receive != null) {
+                    if (receive instanceof TextMessage textMessage) {
+                        result.add(textMessage.getText());
+                    } else {
+                        result.add(receive.toString());
+                    }
+                    if (result.size() > pollSize) {
+                        return result;
+                    }
+                } else {
+                    return result;
+                }
+            }
+        } finally {
+            if (consumer != null) {
+                consumer.close();
+            }
+            if (session != null) {
+                session.close();
+            }
+            if (connection != null) {
+                connection.close();
+            }
+        }
+    }
+    
+    /**
+     * 通过数据源ID发送单例消息。
+     * 此方法将指定的消息数据作为列表中的单个元素发送，适用于需要发送单一消息体的情况。
+     *
+     * @param dataSourceId 数据源ID，用于标识消息发送的目标数据源。
+     * @param channel 通道名称，指定消息将通过的通道。
+     * @param queueManager 队列管理器名称，指定消息将由哪个队列管理器处理。
+     * @param queueName 队列名称，指定消息将被发送到的队列。
+     * @param ccsid CCSID（字符集编码序列ID），指定消息的字符集。
+     * @param data 要发送的消息数据对象。
+     *
+     * @throws Exception 如果发送过程中遇到任何错误，则抛出异常。
+     */
+    public void sendSingletonMessageByDataSourceId(String dataSourceId, String channel, String queueManager,
+                                                   String queueName, Long ccsid, String data) throws Exception {
+        // 使用Collections.singletonList将数据封装为列表，然后调用sendMessageByDataSourceId方法进行发送
+        sendMessageByDataSourceId(dataSourceId, channel, queueManager, queueName, ccsid,
+                                  Collections.singletonList(data));
+    }
+    
+    public void sendSingletonMessageToTopicByDataSourceId(String dataSourceId, String channel, String queueManager,
+                                                          String topic, Long ccsid, String data) throws Exception {
+        // 使用Collections.singletonList将数据封装为列表，然后调用sendMessageByDataSourceId方法进行发送
+        sendMessageToTopicByDataSourceId(dataSourceId, channel, queueManager, topic, ccsid,
+                                         Collections.singletonList(data));
+    }
+    
+    /**
+     * 根据数据源ID发送消息。
+     * 该方法通过查询数据源配置，获取连接信息，并使用提供的参数通过指定的通道、队列管理器和队列名称发送消息。
+     *
+     * @param dataSourceId 数据源ID，用于查询连接配置。
+     * @param channel 通信通道名称。
+     * @param queueManager 队列管理器名称。
+     * @param targetUri 目标队列名称。
+     * @param ccsid 编码集标识符。
+     * @param data 要发送的消息数据列表。
+     *
+     * @throws Exception 如果发送消息过程中遇到任何错误，则抛出异常。
+     */
+    public void sendMessageByDataSourceId(String dataSourceId, String channel, String queueManager, String targetUri,
+                                          Long ccsid, List<String> data) throws Exception {
+        // 根据dataSourceId查询连接配置
+        Map<String, Object> config = queryConnectionStr(dataSourceId);
+        long port = 1414L; // 默认端口号
+        // 从配置中解析主机名和端口号
+        String host = Objects.toString(config.get("host"));
+        if (host.contains(":")) {
+            String[] split = host.split(":");
+            port = Long.parseLong(split[1]);
+            host = split[0];
+        }
+        // 解析用户名和密码 from 配置
+        String username = null;
+        String password = null;
+        Object username1 = config.get("username");
+        if (Objects.nonNull(username1)) {
+            username = username1.toString();
+        }
+        Object password1 = config.get("password");
+        if (Objects.nonNull(password1)) {
+            password = password1.toString();
+        }
+        // 发送消息
+        sendMessage(host, port, channel, queueManager, ccsid, username, password, targetUri, data);
+    }
+    
+    public void sendMessageToTopicByDataSourceId(String dataSourceId, String channel, String queueManager,
+                                                 String targetUri, Long ccsid, List<String> data) throws Exception {
+        // 根据dataSourceId查询连接配置
+        Map<String, Object> config = queryConnectionStr(dataSourceId);
+        long port = 1414L; // 默认端口号
+        // 从配置中解析主机名和端口号
+        String host = Objects.toString(config.get("host"));
+        if (host.contains(":")) {
+            String[] split = host.split(":");
+            port = Long.parseLong(split[1]);
+            host = split[0];
+        }
+        // 解析用户名和密码 from 配置
+        String username = null;
+        String password = null;
+        Object username1 = config.get("username");
+        if (Objects.nonNull(username1)) {
+            username = username1.toString();
+        }
+        Object password1 = config.get("password");
+        if (Objects.nonNull(password1)) {
+            password = password1.toString();
+        }
+        // 发送消息
+        sendMessage(host, port, channel, queueManager, ccsid, username, password, targetUri, data);
+    }
+    
+    public void sendSingletonMessage(String host, Long port, String channel, String queueManager, String targetUri,
+                                     Long ccsid, String username, String password, String data) throws JMSException {
+        sendMessage(host, port, channel, queueManager, ccsid, username, password, targetUri, List.of(data));
+        // 将数据封装为单元素列表，并调用sendMessage方法发送消息
+    }
+    
+    private void sendMessage(String host, Long port, String channel, String queueManager, Long ccsid, String user,
+                             String password, String targetUri, List<String> data) throws JMSException {
+        JmsConnectionFactory factory = getJmsConnectionFactory(host, port, channel, ccsid, user, password);
+        Connection connection = null;
+        Session session = null;
+        MessageProducer producer = null;
+        try {
+            connection = factory.createConnection();
+            session = connection.createSession();
+            connection.start();
+            if (targetUri.startsWith("queue://")) {
+                Queue queue = session.createQueue(targetUri);
+                producer = session.createProducer(queue);
+            } else if (targetUri.startsWith("topic://")) {
+                Topic topic = session.createTopic(targetUri);
+                producer = session.createProducer(topic);
+            }
+            for (String item : data) {
+                producer.send(session.createTextMessage(item));
+            }
+            session.commit();
+        } finally {
+            if (producer != null) {
+                producer.close();
+            }
+            if (session != null) {
+                session.close();
+            }
+            if (connection != null) {
+                connection.close();
+            }
+        }
+    }
+    
+    private JmsConnectionFactory getJmsConnectionFactory(final String host, final Long port, final String channel,
+                                                         final Long ccsid, final String user, final String password)
+            throws JMSException {
+        if (jmsConnectionFactory == null) {
+            JmsFactoryFactory ff = JmsFactoryFactory.getInstance(JmsConstants.WMQ_PROVIDER);
+            jmsConnectionFactory = ff.createConnectionFactory();
+            jmsConnectionFactory.setIntProperty(WMQConstants.WMQ_CONNECTION_MODE, WMQConstants.WMQ_CM_CLIENT);
+            jmsConnectionFactory.setStringProperty(WMQConstants.WMQ_HOST_NAME, host);
+            jmsConnectionFactory.setIntProperty(WMQConstants.WMQ_PORT, port.intValue());
+            jmsConnectionFactory.setStringProperty(WMQConstants.WMQ_CHANNEL, channel);
+            jmsConnectionFactory.setStringProperty(WMQConstants.WMQ_APPLICATIONNAME, "UNI Application");
+            jmsConnectionFactory.setIntProperty(WMQConstants.WMQ_CCSID, ccsid.intValue());
+            jmsConnectionFactory.setStringProperty(WMQConstants.USERID, user);
+            jmsConnectionFactory.setStringProperty(WMQConstants.PASSWORD, password);
+        }
+        return jmsConnectionFactory;
+    }
+    
+    /**
+     * 查询指定数据源ID的连接字符串信息。
+     *
+     * @param datasourceId 数据源的唯一标识符。
+     *
+     * @return 返回一个包含主机名、密码和用户名的Map对象。
+     *
+     * @throws Exception 如果查询过程中发生错误，或者未找到指定的数据源ID，则抛出异常。
+     */
+    private static Map<String, Object> queryConnectionStr(String datasourceId) throws Exception {
+        // 执行数据库查询，获取符合条件的第一条记录
+        Optional<Map<String, Object>> result = DATA_BASE.query(Config.getCenterConnectionStr(), """
+                select host,
+                password,
+                username,
+                from datasource
+                where datasourceid = ?""", datasourceId).stream().findFirst();
+        // 如果查询结果为空，抛出连接未找到异常
+        if (result.isEmpty()) {
+            throw new ConnectionNotFoundException("数据源错误：没有找到数据源");
+        }
+        // 返回查询结果
+        return result.get();
+    }
+}

src/main/resources/application.yml

@@ -12,4 +12,5 @@ server:
   port: 9500
 spring:
   profiles:
-    default: test
+    default: test
+debug: false