测试

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

@@ -3,6 +3,7 @@ package com.gic.haoban.manage.web.controller;
 import com.gic.haoban.common.utils.EntityUtil;
 import com.gic.haoban.common.utils.HaobanResponse;
 import com.gic.haoban.manage.api.service.MemberUnionidRelatedApiService;
+import com.gic.haoban.manage.api.service.TestApiService;
 import com.gic.haoban.manage.web.errCode.HaoBanErrCode;
 import com.gic.haoban.manage.web.qo.QywxXcxSendMessageQo;
 import com.gic.wechat.api.dto.qywx.QywxXcxSendMessageDTO;
@@ -12,6 +13,8 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.ArrayList;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 
 /**
  * Created 2020/4/9.
@@ -28,6 +31,11 @@ public class TestController extends WebBaseController {
     @Autowired
     private MemberUnionidRelatedApiService memberUnionidRelatedApiService;
 
+    private final ExecutorService pools = Executors.newFixedThreadPool(50);
+
+    @Autowired
+    private TestApiService testApiService;
+
     @RequestMapping("/send-message-test")
     public HaobanResponse testSendMessage(QywxXcxSendMessageQo qo) {
         QywxXcxSendMessageDTO messageDTO = EntityUtil.changeEntityByOrika(QywxXcxSendMessageDTO.class, qo);
@@ -49,4 +57,18 @@ public class TestController extends WebBaseController {
         memberUnionidRelatedApiService.cleanByCid(cid);
         return resultResponse(HaoBanErrCode.ERR_1);
     }
+
+    @RequestMapping("/test-dubbo")
+    public HaobanResponse dubbo(String cid) {
+        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/webapp/WEB-INF/dubbo-haoban-manage-web.xml

@@ -62,5 +62,6 @@
 					 id="dealSyncOperationApiService"/>
 					 
 	<dubbo:reference id="quartzService" interface="com.gic.quartz.api.service.QuartzService" timeout="10000"/>
+	<dubbo:reference id="testApiService" interface="com.gic.haoban.manage.api.service.TestApiService" timeout="10000"/>
 	
 </beans>