listenWx fix

long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/common/ThreadPoolFactory.java

@@ -13,9 +13,9 @@ import java.util.concurrent.TimeUnit;
 public final class ThreadPoolFactory {
     private final static ExecutorService DEFAULT = new CommonThreadPoolExecutor(
             32,
-            128,
+            256,
             0L, TimeUnit.SECONDS,
-            new LinkedBlockingQueue<>(1000),
+            new LinkedBlockingQueue<>(20000),
             new ThreadFactoryBuilder().setNameFormat("DEFAULT-%d").build(),
             new ThreadPoolExecutor.AbortPolicy());
     public final static ExecutorService RECALL = new CommonThreadPoolExecutor(

long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/service/WXListenService.java

@@ -20,11 +20,15 @@ public class WXListenService {
     public void listenWx(String xmlData) {
 
         ThreadPoolFactory.defaultPool().submit(() -> {
+            Long start = System.currentTimeMillis();
             userManagementService.listenWx(xmlData);
+            log.info("listenWx userManagementService cost: {} ms", System.currentTimeMillis() - start);
         });
 
         ThreadPoolFactory.defaultPool().submit(() -> {
+            Long start = System.currentTimeMillis();
             messageSendCallbackService.listenWx(xmlData);
+            log.info("listenWx messageSendCallbackService cost: {} ms", System.currentTimeMillis() - start);
         });
 
     }