update

pom.xml

@@ -20,12 +20,6 @@
         <graalvm.version>23.0.1</graalvm.version>
     </properties>
     <dependencies>
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-devtools</artifactId>
-            <scope>runtime</scope>
-            <optional>true</optional>
-        </dependency>
         <dependency>
             <groupId>com.mysql</groupId>
             <artifactId>mysql-connector-j</artifactId>
@@ -53,21 +47,22 @@
             <groupId>org.apache.kafka</groupId>
             <artifactId>kafka-clients</artifactId>
         </dependency>
+        <!-- https://mvnrepository.com/artifact/com.ibm.mq/com.ibm.mq.jakarta.client -->
         <dependency>
             <groupId>com.ibm.mq</groupId>
-            <artifactId>com.ibm.mq.allclient</artifactId>
-            <version>9.3.3.0</version>
+            <artifactId>com.ibm.mq.jakarta.client</artifactId>
+            <version>9.3.4.0</version>
         </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-jms</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>com.rabbitmq</groupId>
             <artifactId>amqp-client</artifactId>
             <version>5.18.0</version>
         </dependency>
-        <dependency>
-            <groupId>com.fasterxml.jackson.core</groupId>
-            <artifactId>jackson-databind</artifactId>
-            <version>2.16.0</version>
-        </dependency>
         <dependency>
             <groupId>commons-net</groupId>
             <artifactId>commons-net</artifactId>
@@ -97,7 +92,6 @@
         <dependency>
             <groupId>com.jayway.jsonpath</groupId>
             <artifactId>json-path</artifactId>
-            <version>2.9.0</version>
         </dependency>
 
         <dependency>
@@ -113,11 +107,6 @@
             <artifactId>guava</artifactId>
             <version>32.0.0-jre</version>
         </dependency>
-        <dependency>
-            <groupId>org.apache.activemq</groupId>
-            <artifactId>activemq-client</artifactId>
-            <version>5.18.3</version>
-        </dependency>
         <dependency>
             <groupId>org.elasticsearch.client</groupId>
             <artifactId>elasticsearch-rest-client</artifactId>

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

@@ -137,16 +137,16 @@ public class LogAop {
                                         Object columnlist = result.get("columnlist");
                                         if (columnlist != null) {
 
-                                            List list = DataFormatUtil.objectMapper.readValue(columnlist.toString(), List.class);
+                                            List list = DataFormatUtil.getObjectMapper().readValue(columnlist.toString(), List.class);
                                             body.put("filterColumns", list);
                                         }
                                         Object filterset = result.get("filterset");
                                         if (filterset != null) {
 
-                                            List list = DataFormatUtil.objectMapper.readValue(columnlist.toString(), List.class);
+                                            List list = DataFormatUtil.getObjectMapper().readValue(columnlist.toString(), List.class);
                                             body.put("filterLines", list.stream().map(it -> {
                                                 try {
-                                                    return DataFormatUtil.objectMapper.readValue(it.toString(), Map.class);
+                                                    return DataFormatUtil.getObjectMapper().readValue(it.toString(), Map.class);
                                                 } catch (JsonProcessingException e) {
                                                     throw new RuntimeException(e);
                                                 }
@@ -172,16 +172,16 @@ public class LogAop {
                                         Object columnlist = result.get("selectcolumnlist");
                                         if (columnlist != null) {
 
-                                            List list = DataFormatUtil.objectMapper.readValue(columnlist.toString(), List.class);
+                                            List list = DataFormatUtil.getObjectMapper().readValue(columnlist.toString(), List.class);
                                             body.put("filterColumns", list);
                                         }
                                         Object filterset = result.get("filterset");
                                         if (filterset != null) {
 
-                                            List list = DataFormatUtil.objectMapper.readValue(columnlist.toString(), List.class);
+                                            List list = DataFormatUtil.getObjectMapper().readValue(columnlist.toString(), List.class);
                                             body.put("filterLines", list.stream().map(it -> {
                                                 try {
-                                                    return DataFormatUtil.objectMapper.readValue(it.toString(), Map.class);
+                                                    return DataFormatUtil.getObjectMapper().readValue(it.toString(), Map.class);
                                                 } catch (JsonProcessingException e) {
                                                     throw new RuntimeException(e);
                                                 }
@@ -205,7 +205,7 @@ public class LogAop {
                         Object filterset = data.get("filterset");
                         if (Objects.nonNull(filterset) && !filterset.toString().trim().isEmpty()) {
                             try {
-                                List list = DataFormatUtil.objectMapper.readValue(filterset.toString(), List.class);
+                                List list = DataFormatUtil.getObjectMapper().readValue(filterset.toString(), List.class);
                                 body.put("filterLines", list);
                             } catch (JsonProcessingException e) {
                                 throw new RuntimeException(e);
@@ -213,7 +213,7 @@ public class LogAop {
                         }
                         Object selectcolumnlist = data.get("selectcolumnlist");
                         if (Objects.nonNull(selectcolumnlist) && !selectcolumnlist.toString().trim().isEmpty()) {
-                            List list = DataFormatUtil.objectMapper.readValue(selectcolumnlist.toString(), List.class);
+                            List list = DataFormatUtil.getObjectMapper().readValue(selectcolumnlist.toString(), List.class);
                             body.put("filterColumns", list);
                         }
                     }

src/main/java/com/scbfkj/uni/library/DataFormatUtil.java

@@ -17,33 +17,21 @@ import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.*;
+import java.util.concurrent.atomic.AtomicReference;
 
 public final class DataFormatUtil {
-    public final static ObjectMapper objectMapper = new ObjectMapper();
-    private final static String LOCAL_DATETIME_PATTERN = "yyyy-MM-dd HH:mm:ss";
-    private final static DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern(LOCAL_DATETIME_PATTERN);
-
-    static {
-        objectMapper.registerModule(new Jdk8Module());
-        //为jackjson注册序列化提供能力的对象
-        JavaTimeModule javaTimeModule = new JavaTimeModule();
-//系列化时间格式化
-        javaTimeModule.addSerializer(LocalDateTime.class, new LocalDateTimeSerializer(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
-        javaTimeModule.addSerializer(LocalDate.class, new LocalDateSerializer(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
-//反序列化时间格式化
-        javaTimeModule.addDeserializer(LocalDateTime.class, new LocalDateTimeDeserializer(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
-        javaTimeModule.addDeserializer(LocalDate.class, new LocalDateDeserializer(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
+    private static final AtomicReference<ObjectMapper> objectMapper = new AtomicReference<>();
+
+    private static final String LOCAL_DATETIME_PATTERN = "yyyy-MM-dd HH:mm:ss";
+    private static final DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern(LOCAL_DATETIME_PATTERN);
 
-        objectMapper.registerModule(javaTimeModule);
-        objectMapper.setSerializationInclusion(JsonInclude.Include.ALWAYS);
-    }
 
     public static JsonNode toJsonNode(Object source) throws JsonProcessingException {
-        return objectMapper.readTree(toString(source));
+        return getObjectMapper().readTree(toString(source));
     }
 
     public static <T> T stringToBean(String source, Class<T> clazz) throws JsonProcessingException {
-        return objectMapper.readValue(source, clazz);
+        return getObjectMapper().readValue(source, clazz);
     }
 
     public static Map<?, ?> stringToMap(String source) throws JsonProcessingException {
@@ -51,11 +39,11 @@ public final class DataFormatUtil {
     }
 
     public static ObjectNode stringToObjectNode(String source) throws JsonProcessingException {
-        return objectMapper.readValue(source, ObjectNode.class);
+        return getObjectMapper().readValue(source, ObjectNode.class);
     }
 
     public static ArrayNode stringToArrayNode(String source) throws JsonProcessingException {
-        return objectMapper.readValue(source, ArrayNode.class);
+        return getObjectMapper().readValue(source, ArrayNode.class);
     }
 
     public static String toString(Object source) {
@@ -72,7 +60,7 @@ public final class DataFormatUtil {
             return result.format(dateTimeFormatter);
         }
         try {
-            return objectMapper.writeValueAsString(source);
+            return getObjectMapper().writeValueAsString(source);
         } catch (JsonProcessingException e) {
             return source.toString();
         }
@@ -107,7 +95,9 @@ public final class DataFormatUtil {
     }
 
     public static List<Object> toList(Object value) {
-        if (Objects.isNull(value)) return null;
+        if (Objects.isNull(value)) {
+            return null;
+        }
         ArrayList<Object> result = new ArrayList<>();
         if (value instanceof Iterable<?> iterable) {
             iterable.forEach(result::add);
@@ -121,7 +111,9 @@ public final class DataFormatUtil {
     }
 
     public static Object[] toArray(Object value) {
-        if (Objects.isNull(value)) return null;
+        if (Objects.isNull(value)) {
+            return null;
+        }
         return Objects.requireNonNull(toList(value)).toArray();
     }
 
@@ -153,4 +145,26 @@ public final class DataFormatUtil {
         data.put("root", value);
         return data;
     }
+
+    public static ObjectMapper getObjectMapper() {
+        synchronized (objectMapper) {
+            if (objectMapper.get() == null) {
+                ObjectMapper objectMapper1 = new ObjectMapper();
+                objectMapper1.registerModule(new Jdk8Module());
+                //为jackjson注册序列化提供能力的对象
+                JavaTimeModule javaTimeModule = new JavaTimeModule();
+//系列化时间格式化
+                javaTimeModule.addSerializer(LocalDateTime.class, new LocalDateTimeSerializer(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+                javaTimeModule.addSerializer(LocalDate.class, new LocalDateSerializer(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
+//反序列化时间格式化
+                javaTimeModule.addDeserializer(LocalDateTime.class, new LocalDateTimeDeserializer(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+                javaTimeModule.addDeserializer(LocalDate.class, new LocalDateDeserializer(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
+
+                objectMapper1.registerModule(javaTimeModule);
+                objectMapper1.setSerializationInclusion(JsonInclude.Include.ALWAYS);
+                objectMapper.set(objectMapper1);
+            }
+        }
+        return objectMapper.get();
+    }
 }

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

@@ -1,104 +0,0 @@
-package com.scbfkj.uni.process;
-
-import com.scbfkj.uni.library.DataFormatUtil;
-import com.scbfkj.uni.library.UniReturnUtil;
-import org.apache.activemq.ActiveMQConnectionFactory;
-
-import javax.jms.*;
-import java.util.*;
-
-public class ActiveMQ {
-
-
-    private static final Map<String, Session> sessionMap = new HashMap<>();
-
-
-    /**
-     * 采集
-     *
-     * @return 读取内容信息
-     */
-    public static Map<String, Object> readMessage(String sourceObjectName, String connectConfig, String pollNumber) {
-        if (Objects.isNull(sourceObjectName) || Objects.isNull(connectConfig)) {
-            return UniReturnUtil.fail(Objects.isNull(sourceObjectName) ? "队列为空" : "连接字符串为空");
-        }
-        try {
-
-            int max = pollNumber == null ? 1 : Integer.parseInt(pollNumber);
-            if (max < 0) {
-                max = Math.abs(max);
-            }
-            Session session = createSession(connectConfig);
-
-            try (MessageConsumer consumer = session.createConsumer(session.createQueue(sourceObjectName))) {
-
-                ArrayList<String> result = new ArrayList<>();
-
-                for (int i = 0; i < max; i++) {
-                    TextMessage receive = (TextMessage) consumer.receive(100);
-                    if (Objects.nonNull(receive)) {
-                        result.add(receive.getText());
-                        session.commit();
-                    } else {
-                        break;
-                    }
-                }
-                return UniReturnUtil.success(result);
-            }
-        } catch (JMSException e) {
-            return UniReturnUtil.fail(e.getMessage());
-        }
-    }
-
-    private static Session createSession(String connectionStr) throws JMSException {
-
-        Session session = sessionMap.get(connectionStr);
-        if (session == null) {
-            Map<?, ?> connectionConfig = DataFormatUtil.toMap(connectionStr);
-
-            String host = connectionConfig.get("host").toString();
-            Object username = connectionConfig.get("username");
-            Object password = connectionConfig.get("password");
-            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(username == null ? null : username.toString(), password == null ? null : password.toString(), host);
-            Connection connection = connectionFactory.createConnection();
-            connection.start();
-            session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
-            sessionMap.put(connectionStr, session);
-            return session;
-
-        }
-        return session;
-
-
-    }
-
-
-    /**
-     * 数据发送
-     *
-     * @return 发送结果信息
-     */
-    public static Map<String, Object> sendMethod(String sourceObjectName, List<Object> data, String connectConfig) {
-        if (Objects.isNull(sourceObjectName) || Objects.isNull(data)) {
-            return UniReturnUtil.fail(Objects.isNull(sourceObjectName) ? ("队列为空 " + data) : ("数据内容为空 " + data));
-        }
-        try {
-            Session session = createSession(connectConfig);
-            try (MessageProducer producer = session.createProducer(session.createQueue(sourceObjectName))) {
-
-                for (Object datum : data) {
-                    //创建一个文本消息
-                    if (Objects.nonNull(datum)) {
-                        TextMessage textMessage = session.createTextMessage(datum.toString());
-                        producer.send(textMessage);//生产者发送消息
-                    }
-                }
-                session.commit();//会话提交
-                return UniReturnUtil.success(null);
-            }
-        } catch (JMSException e) {
-            return UniReturnUtil.fail(e.getMessage());
-        }
-    }
-
-}

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

@@ -118,34 +118,58 @@ public class DataBase {
     public int[] updateBatch(String connectionStr, String sql, List<Object[]> argsList) throws Exception {
         HikariPool dataSourcePool = getDataSourcePool(connectionStr);
         if (sql.trim().startsWith("insert")) {
-            try (Connection connection = dataSourcePool.getConnection();
-                 PreparedStatement preparedStatement = connection.prepareStatement(sql, PreparedStatement.RETURN_GENERATED_KEYS)
-            ) {
-                List<Integer> result = new ArrayList();
-                int index = 0;
-                try {
-                    while (argsList.size() > index) {
-                        Object[] args = argsList.get(index);
-                        for (int i = 0; i < args.length; i++) {
-                            preparedStatement.setObject(i + 1, args[i]);
+            if (connectionStr.contains("jdbc:sqlite")) {
+                try (Connection connection = dataSourcePool.getConnection();
+                     PreparedStatement preparedStatement = connection.prepareStatement(sql)
+                ) {
+                    List<Integer> result = new ArrayList();
+                    int index = 0;
+                    try {
+                        while (argsList.size() > index) {
+                            Object[] args = argsList.get(index);
+                            for (int i = 0; i < args.length; i++) {
+                                preparedStatement.setObject(i + 1, args[i]);
+                            }
+                            preparedStatement.addBatch();
+                            index++;
                         }
-                        preparedStatement.addBatch();
-                        index++;
+                        int[] ints = preparedStatement.executeBatch();
+                        return ints;
+                    } catch (SQLException e) {
+                        connection.rollback();
+                        throw e;
                     }
-                    preparedStatement.executeBatch();
-                    connection.commit();
-                    ResultSet rs = preparedStatement.getGeneratedKeys();
-                    if (rs.next()) {
-                        result.add(rs.getInt(1));
-                    }
-                    int[] ids = new int[result.size()];
-                    for (int i = 0; i < result.size(); i++) {
-                        ids[i] = result.get(i);
+                }
+            } else {
+                try (Connection connection = dataSourcePool.getConnection();
+                     PreparedStatement preparedStatement = connection.prepareStatement(sql, PreparedStatement.RETURN_GENERATED_KEYS)
+                ) {
+                    List<Integer> result = new ArrayList();
+                    int index = 0;
+                    try {
+                        while (argsList.size() > index) {
+                            Object[] args = argsList.get(index);
+                            for (int i = 0; i < args.length; i++) {
+                                preparedStatement.setObject(i + 1, args[i]);
+                            }
+                            preparedStatement.addBatch();
+                            index++;
+                        }
+                        preparedStatement.executeBatch();
+                        connection.commit();
+                        ResultSet rs = preparedStatement.getGeneratedKeys();
+                        if (rs.next()) {
+                            result.add(rs.getInt(1));
+                        }
+                        int[] ids = new int[result.size()];
+                        for (int i = 0; i < result.size(); i++) {
+                            ids[i] = result.get(i);
+                        }
+                        return ids;
+                    } catch (SQLException e) {
+                        connection.rollback();
+                        throw e;
                     }
-                    return ids;
-                } catch (SQLException e) {
-                    connection.rollback();
-                    throw e;
                 }
             }
         } else {

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

@@ -3,7 +3,14 @@ package com.scbfkj.uni.process;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.ibm.mq.MQException;
-import com.ibm.msg.client.wmq.compat.base.internal.*;
+import com.ibm.mq.jakarta.jms.MQDestination;
+import com.ibm.mq.jakarta.jms.MQQueueConnectionFactory;
+import com.scbfkj.uni.system.Config;
+import jakarta.jms.*;
+import org.springframework.jms.connection.CachingConnectionFactory;
+import org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter;
+import org.springframework.jms.core.JmsTemplate;
+import org.springframework.jms.core.MessageCreator;
 import org.springframework.util.StringUtils;
 
 import java.io.IOException;
@@ -11,75 +18,50 @@ import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 
-import static com.ibm.msg.client.wmq.compat.base.internal.MQC.MQCCSI_Q_MGR;
-
 
 public class IBMMQ {
 
 
-    private MQQueueManager queueManager = null;
+    private JmsTemplate jmsTemplate = null;
+
     private final ObjectMapper mapper = new ObjectMapper();
 
     public List<String> receptionMessage(
-            String host, Long port, String channel, String queueManager, String queueName, Long ccsid, String username, String password, Long receiveTimeout, Long pollSize, Long retry) throws MQException, InterruptedException {
-        MQQueueManager mqQueueManager = getMqQueueManager(host, port.intValue(), channel, queueManager, ccsid.intValue(), username, password);
-        MQQueue queue = mqQueueManager.accessQueue(
-                queueName,
-                MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT | MQC.MQOO_INQUIRE
-        );
-        MQGetMessageOptions gmo = new MQGetMessageOptions();
-        gmo.waitInterval = receiveTimeout.intValue();
+            String host, Long port, String channel, String queueManager, String queueName, Long ccsid, String username, String password, Long receiveTimeout, Long pollSize, Long retry) throws MQException, InterruptedException, JMSException {
+        JmsTemplate template = getJmsTemplate(host, port.intValue(), ccsid.intValue(), queueManager, channel, username, password);
 
+        jmsTemplate.setReceiveTimeout(receiveTimeout);
         long maxSize = 100;
         if (pollSize > 0) {
             maxSize = pollSize;
         }
         int maxRetry = 0;
         List<String> result = new ArrayList<>();
-        if (queue.getCurrentDepth() == 0) {
-            return result;
-        }
 
-        while (queue.getCurrentDepth() > 0) {
+
+        while (true) {
             try {
-                MQMessage message = new MQMessage();
-                queue.get(message, gmo);
-                if (message.getDataLength() > 0) {
-                    String messageResult = message.readStringOfByteLength(message.getDataLength());
-                    result.add(messageResult);
-                    if (maxSize <= result.size()) {
-                        return result;
+                Message message = template.receive(queueName);
+                if (message == null) {
+                    break;
+                } else if (message instanceof TextMessage msg) {
+                    String text = msg.getText();
+                    result.add(text);
+                    if (result.size() >= maxSize) {
+                        break;
                     }
                 }
             } catch (Exception e) {
                 maxRetry++;
                 if (maxRetry > retry) {
-                    e.printStackTrace();
-                    try {
-                        if (queue.isOpen()) {
-
-                            queue.close();
-                        }
-                    } catch (Exception ex) {
-                        ex.printStackTrace();
+                    if (Config.isDebug()) {
+                        e.printStackTrace();
                     }
-                    try {
-                        if (mqQueueManager.isOpen()) {
-                            mqQueueManager.close();
-                        }
-                    } catch (Exception ex) {
-                        ex.printStackTrace();
+                    if (jmsTemplate != null) {
+                        jmsTemplate = null;
                     }
-                    return result;
-                }
-            } finally {
-                try {
-                    if (queue.isOpen()) {
 
-                        queue.close();
-                    }
-                } catch (Exception ex) {
-                    ex.printStackTrace();
+                    return result;
                 }
             }
         }
@@ -90,102 +72,92 @@ public class IBMMQ {
 
 
     public void sendMessage(
-            String host, Long port, String channel, String queueManager, String queueName, int ccsid, String username,
-            String password,
-            Long characterSet,
+            String host, Long port, String channel, String queueManager, String queueName, Long ccsid, String username, String password,
             Object data
-    ) throws MQException {
+    ) throws JMSException {
+
+        JmsTemplate template = getJmsTemplate(host, port.intValue(), ccsid.intValue(), queueManager, channel, username, password);
 
-        MQQueueManager mqQueueManager = getMqQueueManager(host, port.intValue(), channel, queueManager, ccsid, username, password);
-        MQQueue queue = mqQueueManager.accessQueue(
-                queueName,
-                MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT | MQC.MQOO_INQUIRE | MQC.MQOO_FAIL_IF_QUIESCING
-        );
         try {
             if (data instanceof Object[] datas) {
                 for (Object it : datas) {
 
-                    execSend(characterSet, it, queue);
+                    execSend(template, it, queueName);
                 }
             } else if (data instanceof Iterable<?> datas) {
-                datas.forEach(it -> {
-                });
 
                 for (Object it : datas) {
 
-                    execSend(characterSet, it, queue);
+                    execSend(template, it, queueName);
                 }
             } else {
-                execSend(characterSet, data, queue);
+                execSend(template, data, queueName);
             }
 
         } catch (Exception e) {
-            e.printStackTrace();
-            try {
-                if (queue.isOpen()) {
-
-                    queue.close();
-                }
-            } catch (Exception ex) {
-                ex.printStackTrace();
+            if (Config.isDebug()) {
+                e.printStackTrace();
             }
-            try {
-                if (mqQueueManager.isOpen()) {
-                    mqQueueManager.close();
-                }
-            } catch (Exception ex) {
-                ex.printStackTrace();
+            if (jmsTemplate != null) {
+                jmsTemplate = null;
             }
 
-        } finally {
-            try {
-                if (queue.isOpen()) {
-
-                    queue.close();
-                }
-            } catch (Exception ex) {
-                ex.printStackTrace();
-            }
         }
     }
 
 
     private void execSend(
-            Long characterSet,
+            JmsTemplate template,
             Object data,
-            MQQueue queue
+            String queueName
     ) throws IOException, MQException {
-        MQMessage mqMessage = new MQMessage();
+        String message = mapper.writeValueAsString(data);
 
-        if (characterSet == null) {
-            mqMessage.characterSet = MQCCSI_Q_MGR;
-        } else {
-            mqMessage.characterSet = characterSet.intValue();
+        template.send(queueName, session -> session.createTextMessage(message));
+    }
 
-        }
 
-        mqMessage.write(mapper.writeValueAsBytes(data));
-        MQPutMessageOptions messageOptions = new MQPutMessageOptions();
-        queue.put(mqMessage, messageOptions); //发送消息
+    private MQQueueConnectionFactory createMqQueueConnectionFactory(String host, int port, int ccsid, String queueManager, String channel) throws JMSException {
+        MQQueueConnectionFactory mqQueueConnectionFactory = new MQQueueConnectionFactory();
+        mqQueueConnectionFactory.setHostName(host);
+        mqQueueConnectionFactory.setPort(port);
+        mqQueueConnectionFactory.setCCSID(ccsid);
+        mqQueueConnectionFactory.setQueueManager(queueManager);
+        mqQueueConnectionFactory.setChannel(channel);
+        mqQueueConnectionFactory.setTransportType(1);
+        return mqQueueConnectionFactory;
     }
 
 
-    private MQQueueManager getMqQueueManager(String host, int port, String channel, String queueManagerName, int ccsid, String username, String password) throws MQException {
+    private JmsTemplate createJmsTemplate(CachingConnectionFactory factory) {
+        JmsTemplate jmsTemplate = new JmsTemplate();
+        jmsTemplate.setConnectionFactory(factory);
+        return jmsTemplate;
+    }
+
+    private CachingConnectionFactory createCachingConnectionFactory(ConnectionFactory factory) {
+        CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory();
+        cachingConnectionFactory.setTargetConnectionFactory(factory);
+        return cachingConnectionFactory;
+    }
 
-        if (null == queueManager) {
-            HashMap<String, Object> prop = new HashMap<>();
-            prop.put(MQC.HOST_NAME_PROPERTY, host);
-            prop.put(MQC.PORT_PROPERTY, port);
-            prop.put(MQC.CHANNEL_PROPERTY, channel);
-            prop.put(MQC.CCSID_PROPERTY, ccsid);
-            if (StringUtils.hasText(username) && StringUtils.hasText(password)) {
-                prop.put(MQC.USER_ID_PROPERTY, username);
-                prop.put(MQC.PASSWORD_PROPERTY, password);
-            }
-            queueManager = new MQQueueManager(queueManagerName, prop);
-        }
-        return queueManager;
+    private UserCredentialsConnectionFactoryAdapter createAdapter(String username, String password, ConnectionFactory factory) {
+        UserCredentialsConnectionFactoryAdapter adapter = new UserCredentialsConnectionFactoryAdapter();
+        adapter.setUsername(username);
+        adapter.setPassword(password);
+        adapter.setTargetConnectionFactory(factory);
+        return adapter;
     }
 
+    private JmsTemplate getJmsTemplate(String host, int port, int ccsid, String queueManager, String channel, String username, String password) throws JMSException {
+        if (jmsTemplate == null) {
+            MQQueueConnectionFactory mqQueueConnectionFactory = createMqQueueConnectionFactory(host, port, ccsid, queueManager, channel);
+            UserCredentialsConnectionFactoryAdapter adapter = createAdapter(username, password, mqQueueConnectionFactory);
+            CachingConnectionFactory cachingConnectionFactory = createCachingConnectionFactory(adapter);
 
+            jmsTemplate = createJmsTemplate(cachingConnectionFactory);
+
+        }
+        return jmsTemplate;
+    }
 }

src/main/java/com/scbfkj/uni/system/SystemInit.java

@@ -31,6 +31,8 @@ public class SystemInit {
 
     @Value("${app.security.enable:true}")
     private boolean securityEnable = false;
+    @Value("${app.security.encrypt:true}")
+    private boolean encryptEnable = false;
     @Value("${app.container.code}")
     private String containerCode;
 
@@ -74,8 +76,13 @@ public class SystemInit {
         Config.setContainerCode(containerCode);
         Config.setSecurityEnable(securityEnable);
         Config.setDebug(debug);
-        Config.setCenterConnectionStr(DataEncryptionUtil.decryptRSAByPrivateKey(centerConfig));
-        Config.setSecurityConnectionStr(DataEncryptionUtil.decryptRSAByPrivateKey(securityConfig));
+        if(encryptEnable) {
+            Config.setCenterConnectionStr(DataEncryptionUtil.decryptRSAByPrivateKey(centerConfig));
+            Config.setSecurityConnectionStr(DataEncryptionUtil.decryptRSAByPrivateKey(securityConfig));
+        }else{
+            Config.setCenterConnectionStr(centerConfig);
+            Config.setSecurityConnectionStr(securityConfig);
+        }
         if (enableResetConfig) {
             cleanRemoteConfig(Config.getCenterConnectionStr(), "classpath:sql/systemset/*");
             cleanRemoteConfig(Config.getSecurityConnectionStr(), "classpath:sql/uniauth/*");

src/main/resources/application-dev.yml

@@ -1,8 +1,11 @@
 app:
   container:
     code: dev
+  debug: true
+  security:
+    encrypt: false
 db:
   center:
-    config: hLcDKcDr4MgqYdb8j0gF0nF806yUy1UdEp1nmztEdo5rNL8IZliDj7/feOp2Fc7j19m9jtiwFp5nPvClI1Ni4kxluI8MQepS8nBK3bEzRzsGSswNHa/Sjyw0GK9/ZnOaiD+lDQyI7+fVbmpdvkLy7QE07bpTIjdI1tcLx8Z9QWs=
+    config: '{"jdbcUrl":"jdbc:mysql://120.26.64.82:3306/systemset","username":"root","password":"123@bigdata","driverClassName":"com.mysql.cj.jdbc.Driver"}'
   security:
-    config: Jnj84d14EmSgKEXyAbSH+bratWGkpV89/VA5Er4yQOt7qlnKtGYJzBVJNNYMBdmSlW0G+nqDHMhJQcmHrwbjjChYuGeDcmKSRmvFQ9u7LwqmgEfazzKKoVawXmJ40dMsec2yaFyNnCM92xn1hzHvle5BL7x3kza2htGm+iOqO7Y=
+    config: '{"jdbcUrl":"jdbc:mysql://120.26.64.82:3306/uniauth","username":"root","password":"123@bigdata","driverClassName":"com.mysql.cj.jdbc.Driver"}'

src/main/resources/application-test.yml

@@ -1,8 +1,11 @@
 app:
   container:
     code: test
+  debug: true
+  security:
+    encrypt: false
 db:
   center:
-    config: hLcDKcDr4MgqYdb8j0gF0nF806yUy1UdEp1nmztEdo5rNL8IZliDj7/feOp2Fc7j19m9jtiwFp5nPvClI1Ni4kxluI8MQepS8nBK3bEzRzsGSswNHa/Sjyw0GK9/ZnOaiD+lDQyI7+fVbmpdvkLy7QE07bpTIjdI1tcLx8Z9QWs=
+    config: '{"jdbcUrl":"jdbc:mysql://120.26.64.82:3306/systemset","username":"root","password":"123@bigdata","driverClassName":"com.mysql.cj.jdbc.Driver"}'
   security:
-    config: Jnj84d14EmSgKEXyAbSH+bratWGkpV89/VA5Er4yQOt7qlnKtGYJzBVJNNYMBdmSlW0G+nqDHMhJQcmHrwbjjChYuGeDcmKSRmvFQ9u7LwqmgEfazzKKoVawXmJ40dMsec2yaFyNnCM92xn1hzHvle5BL7x3kza2htGm+iOqO7Y=
+    config: '{"jdbcUrl":"jdbc:mysql://120.26.64.82:3306/uniauth","username":"root","password":"123@bigdata","driverClassName":"com.mysql.cj.jdbc.Driver"}'

src/main/resources/application.yml

@@ -1,11 +1,10 @@
 app:
-  container:
-    code: dev
   enable-reset-config: false
   security:
     enable: true
+    encrypt: true
 server:
   port: 9500
 spring:
   profiles:
-    default: dev
+    default: test

src/test/java/com/scbfkj/uni/ControllerBaseTest.java

@@ -1,24 +0,0 @@
-package com.scbfkj.uni;
-
-import jakarta.servlet.http.Cookie;
-import org.junit.jupiter.api.BeforeEach;
-import org.springframework.mock.web.MockCookie;
-import org.springframework.test.context.ActiveProfiles;
-import org.springframework.test.web.servlet.MockMvc;
-import org.springframework.test.web.servlet.setup.MockMvcBuilders;
-import org.springframework.web.context.WebApplicationContext;
-
-
-@ActiveProfiles("dev")
-public abstract class ControllerBaseTest {
-
-
-    protected static String token;
-    protected MockMvc mockMvc;
-    protected Cookie cookie = MockCookie.parse("JSESSIONID=78C3FBDF21FFFBE46B8DD728D5C5DBF7");
-
-    @BeforeEach
-    public void before(WebApplicationContext webApplicationContext) {
-        mockMvc = MockMvcBuilders.webAppContextSetup(webApplicationContext).build();
-    }
-}

src/test/java/com/scbfkj/uni/UniApplicationTests.java

@@ -1,51 +0,0 @@
-package com.scbfkj.uni;
-
-import com.scbfkj.uni.library.DataEncryptionUtil;
-import org.junit.jupiter.api.Test;
-
-import java.security.NoSuchAlgorithmException;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-
-class UniApplicationTests {
-    private final static Map<String, List<String>> alias = new HashMap<>();
-
-    static {
-        alias.put("appid", List.of("appid", "app_id", "appId", "APPID"));
-        alias.put("appsecret", List.of("appSecret", "app_secret", "APP_SECRET", "appsecret", "APPSECRET"));
-        alias.put("sessionid", List.of("sessionId", "sessionid", "SESSIONID", "SESSION_ID", "session_id"));
-        alias.put("requestip", List.of("requestIp", "requestip", "request_ip", "REQUEST_IP", "request_ip", "REQUESTIP", "ip"));
-        alias.put("username", List.of("username", "userName", "user_name", "USER_NAME", "USERNAME"));
-        alias.put("password", List.of("password", "pwd", "PWD", "PASSWORD"));
-        alias.put("version", List.of("version", "Version", "VERSION"));
-        alias.put("verifycode", List.of("verifycode", "verifyCode", "code"));
-    }
-
-    @Test
-    void contextLoads() {
-        String sql = "insert into keyalias (keyname,aliasname) values";
-        StringBuilder stringBuilder = new StringBuilder(sql);
-        alias.forEach((key, value) -> {
-
-            value.forEach(it -> {
-                stringBuilder.append("('%s','%s'),".formatted(key, it));
-            });
-        });
-
-        System.out.println(stringBuilder);
-    }
-
-
-    @Test
-    void test2() throws NoSuchAlgorithmException {
-        long currentTimeMillis = System.currentTimeMillis();
-        long l = currentTimeMillis << 5;
-
-        String string = DataEncryptionUtil.signatureMD5(String.valueOf(l));
-        System.out.println(string);
-
-    }
-
-}

src/test/java/com/scbfkj/uni/api/GenericApiTest.java

@@ -1,19 +0,0 @@
-package com.scbfkj.uni.api;
-
-import com.scbfkj.uni.ControllerBaseTest;
-import org.junit.jupiter.api.Test;
-import org.springframework.http.MediaType;
-import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;
-import org.springframework.test.web.servlet.result.MockMvcResultHandlers;
-import org.springframework.test.web.servlet.result.MockMvcResultMatchers;
-
-class GenericApiTest extends ControllerBaseTest {
-
-    @Test
-    void matchService() throws Exception {
-        mockMvc.perform(MockMvcRequestBuilders.post("/openApi/hello").contentType(MediaType.APPLICATION_JSON_VALUE).content("{}")).andExpect(MockMvcResultMatchers.status().is4xxClientError())
-
-                .andDo(MockMvcResultHandlers.print());
-    }
-
-}

src/test/java/com/scbfkj/uni/api/SecurityApiTest.java

@@ -1,89 +0,0 @@
-package com.scbfkj.uni.api;
-
-import com.jayway.jsonpath.JsonPath;
-import com.scbfkj.uni.ControllerBaseTest;
-import org.hamcrest.core.IsEqual;
-import org.junit.jupiter.api.MethodOrderer;
-import org.junit.jupiter.api.Order;
-import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.TestMethodOrder;
-import org.springframework.http.MediaType;
-import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;
-import org.springframework.test.web.servlet.result.MockMvcResultHandlers;
-import org.springframework.test.web.servlet.result.MockMvcResultMatchers;
-
-@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
-class SecurityApiTest extends ControllerBaseTest {
-
-
-    @Test
-    @Order(1)
-    void getToken() throws Exception {
-
-        mockMvc.perform(MockMvcRequestBuilders.post("/user/getToken")
-                        .contentType(MediaType.APPLICATION_JSON_VALUE)
-                        .content("""
-                                {"appid":"test","appsecret":"test"}
-                                """)
-                        .cookie(cookie))
-
-                .andExpect(MockMvcResultMatchers.status().isOk())
-                .andExpect(MockMvcResultMatchers.jsonPath("code", IsEqual.equalTo("0")))
-                .andDo(result -> {
-                    String content = result.getResponse().getContentAsString();
-                    SecurityApiTest.token = JsonPath.read(content, "$.returnData.token");
-                })
-                .andDo(MockMvcResultHandlers.print());
-    }
-
-    @Test
-    @Order(2)
-    void refreshToken() throws Exception {
-        mockMvc.perform(MockMvcRequestBuilders.post("/user/refreshToken")
-                                .contentType(MediaType.APPLICATION_JSON_VALUE)
-//                        .header("token", token)
-                                .cookie(cookie)
-                                .content("")
-                )
-
-                .andExpect(MockMvcResultMatchers.status().isOk())
-                .andExpect(MockMvcResultMatchers.jsonPath("code", IsEqual.equalTo("0")))
-                .andDo(MockMvcResultHandlers.print());
-    }
-
-    @Test
-    void testToken() {
-    }
-
-    @Test
-    void getCode() {
-    }
-
-    @Test
-    void forceLogin() {
-    }
-
-    @Test
-    void login() {
-    }
-
-    @Test
-    void getPermissions() {
-    }
-
-    @Test
-    void changePwd() {
-    }
-
-    @Test
-    void logOut() {
-    }
-
-    @Test
-    void health() {
-    }
-
-    @Test
-    void getPubKey() {
-    }
-}

src/test/java/com/scbfkj/uni/api/TableConfigurationControllerTest.java

@@ -1,30 +0,0 @@
-package com.scbfkj.uni.api;
-
-import com.scbfkj.uni.ControllerBaseTest;
-import org.hamcrest.collection.IsCollectionWithSize;
-import org.hamcrest.core.IsEqual;
-import org.junit.jupiter.api.Test;
-import org.springframework.http.MediaType;
-import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;
-import org.springframework.test.web.servlet.result.MockMvcResultHandlers;
-import org.springframework.test.web.servlet.result.MockMvcResultMatchers;
-
-public class TableConfigurationControllerTest extends ControllerBaseTest {
-
-    @Test
-    void testQuery() throws Exception {
-
-        mockMvc.perform(MockMvcRequestBuilders.post("/openApi/query")
-                        .contentType(MediaType.APPLICATION_JSON_VALUE)
-//                        .header("token", token)
-                        .content("""
-                                {"serviceid":3,"datacontent":{"filter":{"pagecode":"applicationManagementTable"}},"event":"0"}
-                                """)
-                        .cookie(cookie))
-
-                .andExpect(MockMvcResultMatchers.status().isOk())
-                .andExpect(MockMvcResultMatchers.jsonPath("code", IsEqual.equalTo("0")))
-                .andExpect(MockMvcResultMatchers.jsonPath("returnData", IsCollectionWithSize.hasSize(15)))
-                .andDo(MockMvcResultHandlers.print());
-    }
-}

src/test/java/com/scbfkj/uni/library/DataEncryptionUtilTest.java

@@ -27,12 +27,12 @@ class DataEncryptionUtilTest {
 //                                """;
         String data = """
                                 {
-                  "jdbcUrl": "jdbc:kingbase8://120.26.64.82:54321/systemset",
+                  "jdbcUrl": "jdbc:mysql://120.26.64.82:3306/systemset",
                   "username": "root",
                   "password": "123@bigdata",
-                  "driverClassName": "com.kingbase8.Driver"
+                  "driverClassName": "com.mysql.cj.jdbc.Driver"
                 }""";
-        String encryptedData = DataEncryptionUtil.encryptByPublicKey(data, publicKeyString, type, algorithm);
+        String encryptedData = DataEncryptionUtil.encryptRSAByPublicKey(data);
         String decryptedData = DataEncryptionUtil.decryptRSAByPrivateKey(encryptedData);
         System.out.println(data + ": " + encryptedData);
         Assertions.assertEquals(data, decryptedData);

src/test/java/com/scbfkj/uni/library/DataFormatUtilTest.java

@@ -1,73 +0,0 @@
-package com.scbfkj.uni.library;
-
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.JsonNode;
-import org.junit.jupiter.api.Test;
-
-import java.util.HashMap;
-
-class DataFormatUtilTest {
-
-    @Test
-    void toJsonNode() throws JsonProcessingException {
-        JsonNode jsonNode = DataFormatUtil.toJsonNode("[{\"name\": \"Alice\", \"age\": 25}, {\"name\": \"Bob\", \"age\": 30}]");
-        System.out.println(jsonNode);
-        jsonNode = DataFormatUtil.toJsonNode(new HashMap<>() {{
-            put("a", 1);
-        }});
-        System.out.println(jsonNode);
-
-        jsonNode = DataFormatUtil.toJsonNode("HELLO");
-        System.out.println(jsonNode);
-    }
-
-    @Test
-    void stringToBean() {
-    }
-
-    @Test
-    void stringToMap() {
-    }
-
-    @Test
-    void stringToObjectNode() {
-    }
-
-    @Test
-    void stringToArrayNode() {
-    }
-
-    @Test
-    void testToString() {
-    }
-
-    @Test
-    void toDate() {
-    }
-
-    @Test
-    void toDateTime() {
-    }
-
-    @Test
-    void stringToDate() {
-    }
-
-    @Test
-    void stringToDateTime() {
-    }
-
-    @Test
-    void toList() {
-        System.out.println(DataFormatUtil.toList("HELLO WORLD"));
-    }
-
-    @Test
-    void toArray() {
-    }
-
-    @Test
-    void toMap() {
-        System.out.println(DataFormatUtil.toMap("HELLO WORLD"));
-    }
-}

src/test/java/com/scbfkj/uni/library/ImageUtilTest.java

@@ -1,15 +0,0 @@
-package com.scbfkj.uni.library;
-
-import org.junit.jupiter.api.Test;
-
-import java.awt.*;
-import java.io.IOException;
-
-class ImageUtilTest {
-
-    @Test
-    void stringToImage() throws IOException, FontFormatException {
-        String s = ImageUtil.stringToImage("1234");
-        System.out.println(s);
-    }
-}

src/test/java/com/scbfkj/uni/library/ScriptEngineUtilTest.java

@@ -1,5 +0,0 @@
-package com.scbfkj.uni.library;
-
-class ScriptEngineUtilTest {
-
-}

src/test/java/com/scbfkj/uni/library/script/JavaScriptEngineUtilTest.java

@@ -1,21 +0,0 @@
-package com.scbfkj.uni.library.script;
-
-import org.junit.jupiter.api.Test;
-
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.Map;
-
-class JavaScriptEngineUtilTest {
-
-    @Test
-    void invoke() throws Exception {
-        Map<String, Object> invoke = JavaScriptEngineUtil.invoke(new HashMap<>() {{
-            put("className", "com.scbfkj.uni.process.Kafka");
-            put("path", null);
-        }}, "sendMessage", "{\"bootstrap.servers\": \"127.0.0.1:9092\"}", "test", new ArrayList<String>() {{
-            add("HELLO WORLD");
-        }});
-        System.out.println(invoke);
-    }
-}

src/test/java/com/scbfkj/uni/library/script/JsScriptEngineUtilTest.java

@@ -1,251 +0,0 @@
-package com.scbfkj.uni.library.script;
-
-import org.junit.jupiter.api.Test;
-
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.Future;
-
-class JsScriptEngineUtilTest {
-
-    public static final String script2 = """
-            new Date()
-                        
-            """;
-    static final String script = """
-            (type) => {
-                switch (type) {
-                    case 'pageType':{
-                        return [{
-                            'id':'module',
-                            'name':'模块'
-                        },{
-                            'id':'page',
-                            'name':'页面'
-                        },{
-                            'id':'tree',
-                            'name':'树'
-                        },{
-                            'id':'table',
-                            'name':'表格'
-                        },{
-                            'id':'column',
-                            'name':'数据项'
-                        },{
-                            'id':'form',
-                            'name':'表单'
-                        },{
-                            'id':'chart',
-                            'name':'图表'
-                        },{
-                            'id':'button',
-                            'name':'按钮'
-                        }]
-                    }
-                    case 'boolean':{
-                        return [{
-                            'id':1,
-                            'name':'是'
-                        },{
-                            'id':0,
-                            'name':'否'
-                        }]
-                    }
-                    case 'taskType':{
-                        return [{
-                            'id':0,
-                            'name':'接口服务'
-                        },{
-                            'id':1,
-                            'name':'定时服务'
-                        },{
-                            'id':2,
-                            'name':'轮询服务'
-                        }]
-                    }
-                    case 'serviceType':{
-                        return [{
-                            'id':0,
-                            'name':'高级查询'
-                        },{
-                            'id':1,
-                            'name':'查询'
-                        },{
-                            'id':2,
-                            'name':'新增'
-                        },{
-                            'id':3,
-                            'name':'编辑'
-                        },{
-                            'id':4,
-                            'name':'删除'
-                        },{
-                            'id':5,
-                            'name':'其他'
-                        }]
-                    }
-                    case 'algorithmlibraryType':{
-                        return [{
-                            'id':'category',
-                            'name':'大类'
-                        },{
-                            'id':'algorithm',
-                            'name':'算法'
-                        },{
-                            'id':'parameter',
-                            'name':'参数'
-                        }]
-                    }
-                    case 'algorithmlibraryParamenterType':{
-                        return [{
-                            'id':'string',
-                            'name':'字符串'
-                        },{
-                            'id':'number',
-                            'name':'数字'
-                        }]
-                    }
-                    case 'datasource':{
-                        return [{
-                            'id':0,
-                            'name':'全局变量'
-                        },{
-                            'id':1,
-                            'name':'算法配置'
-                        },{
-                            'id':2,
-                            'name':'固定值'
-                        },{
-                            'id':3,
-                            'name':'数据订阅'
-                        }]
-                    }
-                    case 'openmode':{
-                        return [{
-                            'id':1,
-                            'name':'打开页面'
-                        },{
-                            'id':2,
-                            'name':'打开表单'
-                        },{
-                            'id':3,
-                            'name':'页面内联查询'
-                        },{
-                            'id':4,
-                            'name':'打开弹窗'
-                        }]
-                    }
-                    case 'charttype':{
-                        return [{
-                            'id':"line",
-                            'name':'折线图'
-                        },{
-                            'id':"bar",
-                            'name':'柱状图'
-                        },{
-                            'id':"pie",
-                            'name':'饼图'
-                        },{
-                            'id':"radar",
-                            'name':'雷达图'
-                        }]
-                    }
-                    case 'renderType':{
-                        return [{
-                            'id':'radio',
-                            'name':'radio'
-                        },{
-                            'id':'checkbox',
-                            'name':'checkbox'
-                        },{
-                            'id':'textarea',
-                            'name':'textarea'
-                        },{
-                            'id':'text',
-                            'name':'text'
-                        },{
-                            'id':'password',
-                            'name':'password'
-                        },{
-                            'id':'unpassword',
-                            'name':'unpassword'
-                        },{
-                            'id':'number',
-                            'name':'number'
-                        },{
-                            'id':'select',
-                            'name':'select'
-                        },{
-                            'id':'cascader',
-                            'name':'cascader'
-                        },{
-                            'id':'switch',
-                            'name':'switch'
-                        },{
-                            'id':'time',
-                            'name':'time'
-                        },{
-                            'id':'date',
-                            'name':'date'
-                        },{
-                            'id':'datetime',
-                            'name':'datetime'
-                        },{
-                            'id':'upload',
-                            'name':'upload'
-                        }]
-                    }
-                    default:{
-                        return []
-                    }
-                }
-            }
-            """;
-
-    @Test
-    void testPool() {
-
-        ArrayList<String> list = new ArrayList<>();
-        list.add("pageType");
-        list.add("boolean");
-        list.add("taskType");
-        list.add("serviceType");
-        list.add("algorithmlibraryType");
-        list.add("algorithmlibraryParamenterType");
-        list.add("datasource");
-        list.add("openmode");
-        list.add("charttype");
-        list.add("renderType");
-        ArrayList<Future<Map>> objects = new ArrayList<>();
-        long start = System.currentTimeMillis();
-        for (int i = 0; i < 10000; i++) {
-            String type = list.get(i % list.size());
-            CompletableFuture<Map> future = CompletableFuture.supplyAsync(() -> {
-                Map value = null;
-                try {
-                    value = JsScriptEngineUtil.eval(script2);
-                } catch (Exception e) {
-                    e.printStackTrace();
-                }
-                return value;
-            });
-            objects.add(future);
-        }
-        objects.stream().map(valueFuture -> {
-            try {
-                return valueFuture.get();
-            } catch (InterruptedException | ExecutionException e) {
-                e.printStackTrace();
-                return null;
-            }
-        }).forEach(System.out::println);
-
-        long end = System.currentTimeMillis();
-        System.out.println("thread new object:" + (end - start));
-
-    }
-
-
-}

src/test/java/com/scbfkj/uni/process/ElasticsearchTest.java

@@ -1,105 +0,0 @@
-package com.scbfkj.uni.process;
-
-import org.junit.jupiter.api.Test;
-
-import java.util.Collections;
-import java.util.Map;
-
-class ElasticsearchTest {
-
-    @Test
-    void exec3() {
-        Map<String, Object> exec = Elasticsearch.exec("""
-                                                {
-                  "host": [
-                    "http://120.26.64.82:9200"
-                  ],
-                  "username": null,
-                  "password": null,
-                  "auth": null
-                }
-                                                """, "test", "search", Collections.singletonList(
-                """
-                        {
-                           "query": {
-                             "match": {
-                               "a": 1
-                             }
-                           }
-                         }"""));
-        System.out.println(exec);
-    }
-
-    @Test
-    void exec() {
-        Map<String, Object> exec = Elasticsearch.exec("""
-                                                {
-                  "host": [
-                    "http://120.26.64.82:9200"
-                  ],
-                  "username": null,
-                  "password": null,
-                  "auth": null
-                }
-                                                """, "test", "CREATE", Collections.singletonList("""
-                                {
-                  "a": 1,
-                  "b": 2
-                }
-                                """));
-        System.out.println(exec);
-    }
-
-    @Test
-    void exec4() {
-        Map<String, Object> exec = Elasticsearch.exec("""
-                                                {
-                  "host": [
-                    "http://120.26.64.82:9200"
-                  ],
-                  "username": null,
-                  "password": null,
-                  "auth": null
-                }
-                                                """, "test", "UPDATE", Collections.singletonList("""
-                                {
-                  "_id": "_VtWZowBdZt8yNMHSgge",
-                  "data": {
-                    "a": 1,
-                    "b": 3
-                  }
-                }
-                                                """));
-        System.out.println(exec);
-    }
-
-    @Test
-    void exec5() {
-        Map<String, Object> exec = Elasticsearch.exec("""
-                                                {
-                  "host": [
-                    "http://120.26.64.82:9200"
-                  ],
-                  "username": null,
-                  "password": null,
-                  "auth": null
-                }
-                                                """, "test", "DELETE", Collections.singletonList("_VtWZowBdZt8yNMHSgge"));
-        System.out.println(exec);
-    }
-
-    @Test
-    void exec2() {
-        Map<String, Object> exec = Elasticsearch.exec("""
-                                                {
-                  "host": [
-                    "http://120.26.64.82:9200"
-                  ],
-                  "username": null,
-                  "password": null,
-                  "auth": null
-                }
-                                                """, "test", "get", Collections.singletonList("_FtTZowBdZt8yNMH2gg7"));
-        System.out.println(exec);
-    }
-}

src/test/java/com/scbfkj/uni/process/IBMMQTest.java

@@ -0,0 +1,45 @@
+package com.scbfkj.uni.process;
+
+import org.junit.jupiter.api.Test;
+
+
+import com.ibm.mq.MQException;
+import jakarta.jms.JMSException;
+
+import java.lang.reflect.Array;
+import java.util.ArrayList;
+import java.util.List;
+
+class IBMMQTest {
+    private final IBMMQ ibmmq = new IBMMQ();
+
+    //
+    @Test
+    void receptionMessage() throws InterruptedException, MQException, JMSException {
+        List<String> strings = ibmmq.receptionMessage(
+                "120.26.64.82",
+                1414L,
+                "DEV.ADMIN.SVRCONN",
+                "QM1",
+                "DEV.QUEUE.1",
+                1208L,
+                "admin",
+                "passw0rd",
+                300L,
+                100L,
+                3L
+        );
+        strings.forEach(System.out::println);
+    }
+
+    @Test
+    void sendMessage() throws JMSException {
+        ArrayList<String> strings = new ArrayList<>();
+        for (int i = 0; i < 100; i++) {
+            strings.add("hello" + i);
+        }
+        ibmmq.sendMessage(
+                "120.26.64.82", 1414L, "DEV.ADMIN.SVRCONN", "QM1", "DEV.QUEUE.1", 1208L, "admin", "passw0rd", strings
+        );
+    }
+}

src/test/java/com/scbfkj/uni/process/KafkaTest.java

@@ -1,21 +0,0 @@
-package com.scbfkj.uni.process;
-
-import org.junit.jupiter.api.Test;
-
-import java.util.ArrayList;
-import java.util.Map;
-
-class KafkaTest {
-
-    @Test
-    void sendMessage() throws Exception {
-        Map<String, Object> map = Kafka.sendMessage("{\"bootstrap.servers\": \"127.0.0.1:9092\"}", "test", new ArrayList<>() {{
-            add("HELLO WORLD");
-        }});
-    }
-
-    @Test
-    void receptionMessage() throws Exception {
-        Map<String, Object> map = Kafka.receptionMessage("{\"bootstrap.servers\": \"127.0.0.1:9092\"}", "test", "1");
-    }
-}

src/test/java/com/scbfkj/uni/service/DataProcessServiceTest.java

@@ -1,39 +0,0 @@
-package com.scbfkj.uni.service;
-
-import org.junit.jupiter.api.Test;
-
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Objects;
-
-class DataProcessServiceTest {
-
-    @Test
-    void processByAlgorithm() throws Exception {
-        String data = "hello world";
-        String prikey = "12087a12bee95f5d4ffad39bc664d36d3e5befcec9e38e32214347cf263c7479";
-        String pubkey = "04343d06aa7d9fbf3897906755c0172a43faeec77b346a26636ea67bd9a7e319774024ddac2c0ac697ec4b9333db3f823e29ad11cdce4ff377d2d4b3dd64c47310";
-        HashMap<String, Object> config = new HashMap<>() {{
-            put("path", "sm2-1.0-SNAPSHOT-jar-with-dependencies.jar");
-            put("className", "com.bfkj.SM2");
-        }};
-        DataProcessService dataProcessService = new DataProcessService();
-        Map<String, Object> map = dataProcessService.processByAlgorithm("1", new ArrayList<>() {{
-            add(config);
-            add("encrypt");
-            add(data);
-            add(pubkey);
-        }});
-        System.out.println(map);
-        String data2 = map.get("returnData").toString();
-        map = dataProcessService.processByAlgorithm("1", new ArrayList<>() {{
-            add(config);
-            add("decrypt");
-            add(data2);
-            add(prikey);
-        }});
-        System.out.println(map);
-        System.out.println(Objects.equals(data, map.get("returnData")));
-    }
-}