测试

haoban-manage3-service/src/test/java/ServiceTest.java

@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.gic.api.base.commons.JSONResponse;
 import com.gic.haoban.base.api.common.ServiceResponse;
 import com.gic.haoban.manage.api.service.StaffApiService;
+import com.gic.haoban.manage.api.service.TestApiService;
 import com.gic.haoban.manage.api.service.WxEnterpriseRelatedApiService;
 import com.gic.redis.data.util.RedisUtil;
 import com.gic.wechat.api.dto.qywx.*;
@@ -11,8 +12,10 @@ import com.gic.wechat.api.enums.QywxMediaTypeEnum;
 import com.gic.wechat.api.service.qywx.QywxDepartmentApiService;
 import com.gic.wechat.api.service.qywx.QywxSuiteApiService;
 import com.gic.wechat.api.service.qywx.QywxUserApiService;
+import org.apache.logging.log4j.core.util.ExecutorServices;
 import org.junit.Test;
 import org.junit.runner.RunWith;
+import org.quartz.spi.ThreadPool;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
@@ -28,6 +31,9 @@ import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.Iterator;
 import java.util.List;
+import java.util.concurrent.Executor;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 
 @RunWith(SpringJUnit4ClassRunner.class)
 @ContextConfiguration(locations = {"classpath:applicationContext-conf.xml"})
@@ -47,9 +53,24 @@ public class ServiceTest {
     @Autowired
     private StaffApiService staffApiService;
 
+    @Autowired
+    private TestApiService testApiService;
+
+
+    private final ExecutorService pools = Executors.newFixedThreadPool(50);
+
     @Test
 	public void test() {
-		System.err.println(RedisUtil.getCache("init-enterprise-ca66a01b79474c40b3e7c7f93daf1a3b"));
+        int i=2000;
+        while (i-->0) {
+            int finalI = i;
+            pools.execute(new Runnable(){
+                @Override
+                public void run() {
+                    testApiService.checkThread(finalI +"",100L);
+                }
+            });
+        }
 	}
 
 

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/TestController.java

@@ -8,6 +8,8 @@ import com.gic.haoban.manage.web.errCode.HaoBanErrCode;
 import com.gic.haoban.manage.web.qo.QywxXcxSendMessageQo;
 import com.gic.wechat.api.dto.qywx.QywxXcxSendMessageDTO;
 import com.gic.wechat.api.service.qywx.QywxSuiteApiService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;
@@ -26,13 +28,16 @@ import java.util.concurrent.Executors;
 @RequestMapping("/test")
 public class TestController extends WebBaseController {
 
+
+    private static final Logger logger= LoggerFactory.getLogger(TestController.class);
+
     @Autowired
     private QywxSuiteApiService qywxSuiteApiService;
 
     @Autowired
     private MemberUnionidRelatedApiService memberUnionidRelatedApiService;
 
-    private final ExecutorService pools = Executors.newFixedThreadPool(50);
+    private final ExecutorService pools = Executors.newFixedThreadPool(500);
 
     @Autowired
     private TestApiService testApiService;
@@ -67,7 +72,9 @@ public class TestController extends WebBaseController {
             pools.execute(new Runnable(){
                 @Override
                 public void run() {
+                    long start = System.currentTimeMillis();
                     testApiService.checkThread(finalI +"",Long.valueOf(t));
+                    logger.info("时间:{}",System.currentTimeMillis()-start);
                 }
             });
         }