add HttpMessageReporter

mybatis-flex-core/src/main/java/com/mybatisflex/core/audit/AuditManager.java

@@ -61,10 +61,23 @@ public class AuditManager {
         return messageCollector;
     }
 
+
+    public static void setMessageReporter(MessageReporter messageReporter){
+        MessageCollector newMessageCollector = new ScheduledMessageCollector(10,messageReporter);
+        setMessageCollector(newMessageCollector);
+    }
+
     public static void setMessageCollector(MessageCollector messageCollector) {
+        releaseScheduledMessageCollector();
         AuditManager.messageCollector = messageCollector;
     }
 
+    private static void releaseScheduledMessageCollector() {
+        if (messageCollector instanceof ScheduledMessageCollector){
+            ((ScheduledMessageCollector) messageCollector).release();
+        }
+    }
+
     public static <T> T startAudit(AuditRunnable<T> supplier, BoundSql boundSql) throws SQLException {
         AuditMessage auditMessage = messageCreator.create();
         if (auditMessage == null) {

mybatis-flex-core/src/main/java/com/mybatisflex/core/audit/ScheduledMessageCollector.java

@@ -48,6 +48,12 @@ public class ScheduledMessageCollector implements MessageCollector, Runnable {
     public ScheduledMessageCollector(long period, MessageReporter messageSender) {
         this.period = period;
         this.messageSender = messageSender;
+        scheduler = Executors.newSingleThreadScheduledExecutor(runnable -> {
+            Thread thread = new Thread(runnable, "ScheduledMessageCollector");
+            thread.setDaemon(true);
+            return thread;
+        });
+        scheduler.scheduleAtFixedRate(this, period, period, TimeUnit.SECONDS);
     }
 
 
@@ -80,4 +86,8 @@ public class ScheduledMessageCollector implements MessageCollector, Runnable {
 
         messageSender.sendMessages(sendMessages);
     }
+
+    public void release() {
+        scheduler.shutdown();
+    }
 }

mybatis-flex-core/src/main/java/com/mybatisflex/core/audit/http/HttpMessageReporter.java

@@ -40,7 +40,7 @@ public class HttpMessageReporter implements MessageReporter {
         HttpUtil.post(url, jsonFormatter.toJSONString(messages));
     }
 
-    interface JSONFormatter {
+    public interface JSONFormatter {
         String toJSONString(Object object);
     }