去除多余配置

server-common/src/main/java/com/makeit/config/AsyncConfig.java

-package com.makeit.config;
-
-import com.alibaba.ttl.threadpool.TtlExecutors;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
-
-import java.util.concurrent.Executor;
-import java.util.concurrent.ThreadPoolExecutor;
-
-@Configuration
-public class AsyncConfig {
-
-    @Bean(name = "asyncTaskExecutor")
-    public Executor asyncTaskExecutor() {
-        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
-        executor.setCorePoolSize(5);
-        executor.setMaxPoolSize(10);
-        executor.setQueueCapacity(500);
-        executor.setThreadNamePrefix("async-service-");
-        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
-        executor.setKeepAliveSeconds(60);
-        executor.setAllowCoreThreadTimeOut(false);
-        executor.initialize();
-        return TtlExecutors.getTtlExecutor(executor);
-    }
-
-}

server-web/src/main/java/com/makeit/mqtt/PushCallback.java

@@ -43,7 +43,6 @@ import javax.annotation.Resource;
 import java.math.BigDecimal;
 import java.util.List;
 import java.util.Objects;
-import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
 
 
@@ -104,7 +103,7 @@ public class PushCallback implements MqttCallbackExtended {
     }
 
     @Override
-    @Async("asyncTaskExecutor")
+    @Async
     public void messageArrived(String topic, MqttMessage message) {
         try {
             // 收到消息并设置返回字符串格式