chore: optimize performance

Author: cjbi

src/main/java/tech/wetech/flexmodel/application/ApiRuntimeApplicationService.java

@@ -5,6 +5,7 @@
 import graphql.GraphQL;
 import io.netty.handler.codec.http.HttpResponseStatus;
 import io.vertx.ext.web.RoutingContext;
+import io.vertx.mutiny.core.eventbus.EventBus;
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
 import lombok.extern.slf4j.Slf4j;
@@ -56,6 +57,9 @@ public class ApiRuntimeApplicationService {
   @Inject
   SettingsService settingsService;
 
+  @Inject
+  EventBus eventBus;
+
   public ExecutionResult execute(String operationName, String query, Map<String, Object> variables) {
     GraphQL graphQL = graphQLProvider.getGraphQL();
     if (variables == null) {
@@ -192,7 +196,8 @@ public void log(RoutingContext routingContext, Runnable runnable) {
       apiData.setStatus(routingContext.response().getStatusCode());
       apiData.setMessage(routingContext.response().getStatusMessage());
       apiData.setExecTime(System.currentTimeMillis() - beginTime);
-      routingContext.addEndHandler(handle-> apiLogService.create(apiLog));}
+      eventBus.publish("request.logging", apiLog);
+    }
 
   }
 

src/main/java/tech/wetech/flexmodel/infrastructrue/LogEventConsumer.java

@@ -0,0 +1,23 @@
+package tech.wetech.flexmodel.infrastructrue;
+
+import io.quarkus.vertx.ConsumeEvent;
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.inject.Inject;
+import tech.wetech.flexmodel.codegen.entity.ApiLog;
+import tech.wetech.flexmodel.domain.model.api.ApiLogService;
+
+/**
+ * @author cjbi
+ */
+@ApplicationScoped
+public class LogEventConsumer {
+
+  @Inject
+  ApiLogService apiLogService;
+
+  @ConsumeEvent("request.logging") // 监听特定地址的事件
+  public void consume(ApiLog apiLog) {
+    apiLogService.create(apiLog);
+  }
+
+}

src/main/java/tech/wetech/flexmodel/infrastructrue/SettingsEventConsumer.java

@@ -16,10 +16,9 @@
 @ApplicationScoped
 public class SettingsEventConsumer {
 
-
   @ConsumeEvent("settings-changed") // 监听特定地址的事件
   public void consume(SettingsChanged event) {
-    log.info("Received message: {}", event.getMessage());
+    log.info("Received settings message: {}", event.getMessage());
     // 处理事件
     List<String> invalidKeys = new ArrayList<>();
     ApiRateLimiterHolder.getMap().forEach((k, v) -> {