Просмотр исходного кода

[线程][修改]:复用已有线程

release
Stormeye Wu 7 лет назад
Родитель
Сommit
9daac0312c
1 измененных файлов: 6 добавлений и 0 удалений
  1. +6
    -0
      mlWechatOpen/src/main/java/com/iformall/mp/manager/WxMpManager.java

+ 6
- 0
mlWechatOpen/src/main/java/com/iformall/mp/manager/WxMpManager.java Просмотреть файл

@@ -5,6 +5,8 @@ import com.iformall.service.wechat.FmOpenService;
import me.chanjar.weixin.mp.api.WxMpMessageRouter; import me.chanjar.weixin.mp.api.WxMpMessageRouter;
import me.chanjar.weixin.mp.api.WxMpService; import me.chanjar.weixin.mp.api.WxMpService;
import me.chanjar.weixin.mp.constant.WxMpEventConstants; import me.chanjar.weixin.mp.constant.WxMpEventConstants;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;


@@ -21,6 +23,8 @@ import static me.chanjar.weixin.common.api.WxConsts.*;
@Service @Service
public class WxMpManager { public class WxMpManager {


private final Logger logger = LoggerFactory.getLogger(this.getClass());

private static Map<String, WxMpMessageRouter> myRouterMap = new ConcurrentHashMap<String, WxMpMessageRouter>(); private static Map<String, WxMpMessageRouter> myRouterMap = new ConcurrentHashMap<String, WxMpMessageRouter>();




@@ -52,8 +56,10 @@ public class WxMpManager {
public WxMpMessageRouter getRouter(WxMpService mpService) { public WxMpMessageRouter getRouter(WxMpService mpService) {
String appId = mpService.getWxMpConfigStorage().getAppId(); String appId = mpService.getWxMpConfigStorage().getAppId();
if (myRouterMap.containsKey(appId)) { if (myRouterMap.containsKey(appId)) {
logger.info("found appId : ", appId);
return myRouterMap.get(appId); return myRouterMap.get(appId);
} else { } else {
logger.info("found new appId : ", appId);
return newRouter(mpService); return newRouter(mpService);
} }
} }


Загрузка…
Отмена
Сохранить