加入获取handler锁

src/main/java/cn/quantgroup/xyqb/service/register/AbstractUserRegisterService.java

@@ -3,6 +3,7 @@ package cn.quantgroup.xyqb.service.register;
 import cn.quantgroup.xyqb.service.register.handler.AbstractUserRegisterHandler;
 import cn.quantgroup.xyqb.util.ApplicationContextHolder;
 import com.google.common.collect.Maps;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeansException;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
@@ -12,11 +13,12 @@ import java.util.Map;
 /**
  * Created by liqing on 2017/12/5 0005.
  */
+@Slf4j
 public abstract class AbstractUserRegisterService implements IUserRegisterService,ApplicationContextAware {
 
     private static Map<String, AbstractUserRegisterHandler> userRegisterHandlerMap = Maps.newConcurrentMap();
-    private static final String USER_REGISTER_HANDLER_DEFAULT_KEY = "default";
-    private static final String USER_REGISTER_HANDLER_EXT_KEY = "ext";
+    private static final String USER_REGISTER_HANDLER_DEFAULT_KEY = "register_default";
+    private static final String USER_REGISTER_HANDLER_EXT_KEY = "register_ext";
 
     @Override
     public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
@@ -76,7 +78,12 @@ public abstract class AbstractUserRegisterService implements IUserRegisterServic
     protected AbstractUserRegisterHandler getDefaultUserRegisterHandler(){
         AbstractUserRegisterHandler curUserRegisterHandler = userRegisterHandlerMap.get(USER_REGISTER_HANDLER_DEFAULT_KEY);
         if (curUserRegisterHandler == null){
-            curUserRegisterHandler = createDefaultUserRegisterHandler(ApplicationContextHolder.getApplicationContext());
+            synchronized (USER_REGISTER_HANDLER_DEFAULT_KEY){
+                curUserRegisterHandler = userRegisterHandlerMap.get(USER_REGISTER_HANDLER_DEFAULT_KEY);
+                if (curUserRegisterHandler == null){
+                    curUserRegisterHandler = createDefaultUserRegisterHandler(ApplicationContextHolder.getApplicationContext());
+                }
+            }
         }
         return curUserRegisterHandler;
     }
@@ -88,8 +95,14 @@ public abstract class AbstractUserRegisterService implements IUserRegisterServic
     protected AbstractUserRegisterHandler getExtUserRegisterHandler(){
         AbstractUserRegisterHandler curUserRegisterHandler = userRegisterHandlerMap.get(USER_REGISTER_HANDLER_EXT_KEY);
         if (curUserRegisterHandler == null){
-            curUserRegisterHandler = createExtUserRegisterHandler(ApplicationContextHolder.getApplicationContext());
+            synchronized (USER_REGISTER_HANDLER_EXT_KEY){
+                curUserRegisterHandler = userRegisterHandlerMap.get(USER_REGISTER_HANDLER_EXT_KEY);
+                if (curUserRegisterHandler == null){
+                    curUserRegisterHandler = createExtUserRegisterHandler(ApplicationContextHolder.getApplicationContext());
+                }
+            }
         }
         return curUserRegisterHandler;
     }
+
 }