重构类结构

discovery-plugin-config-center/src/main/java/com/nepxion/discovery/plugin/configcenter/ConfigInitializer.java

+package com.nepxion.discovery.plugin.configcenter;
+
+/**
+ * <p>Title: Nepxion Discovery</p>
+ * <p>Description: Nepxion Discovery</p>
+ * <p>Copyright: Copyright (c) 2017-2050</p>
+ * <p>Company: Nepxion</p>
+ * @author Haojun Ren
+ * @version 1.0
+ */
+
+import java.io.InputStream;
+
+import javax.annotation.PostConstruct;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+
+import com.nepxion.discovery.plugin.configcenter.constant.ConfigConstant;
+import com.nepxion.discovery.plugin.configcenter.loader.ConfigLoader;
+import com.nepxion.discovery.plugin.framework.constant.PluginConstant;
+
+public class ConfigInitializer {
+    private static final Logger LOG = LoggerFactory.getLogger(ConfigInitializer.class);
+
+    @Value("${" + PluginConstant.SPRING_APPLICATION_REGISTER_CONTROL_ENABLED + ":true}")
+    private Boolean registerControlEnabled;
+
+    @Value("${" + PluginConstant.SPRING_APPLICATION_DISCOVERY_CONTROL_ENABLED + ":true}")
+    private Boolean discoveryControlEnabled;
+
+    @Value("${" + ConfigConstant.SPRING_APPLICATION_DISCOVERY_REMOTE_CONFIG_ENABLED + ":true}")
+    private Boolean remoteConfigEnabled;
+
+    @Autowired(required = false)
+    private ConfigLoader configLoader;
+
+    @Autowired
+    private ConfigParser configParser;
+
+    @PostConstruct
+    public void initialize() {
+        if (!registerControlEnabled && !discoveryControlEnabled) {
+            LOG.info("********** Register and Discovery controls are all disabled, ignore to initialize **********");
+
+            return;
+        }
+
+        if (configLoader == null) {
+            LOG.info("********** ConfigLoader isn't provided, ignore to initialize **********");
+
+            return;
+        }
+
+        LOG.info("********** {} config starts to initialize **********", remoteConfigEnabled ? "Remote" : "Local");
+
+        InputStream inputStream = null;
+        if (remoteConfigEnabled) {
+            inputStream = configLoader.getRemoteInputStream();
+        } else {
+            inputStream = configLoader.getLocalInputStream();
+        }
+        configParser.parse(inputStream);
+    }
+}
\ No newline at end of file

discovery-plugin-config-center/src/main/java/com/nepxion/discovery/plugin/configcenter/ConfigSubscriber.java

@@ -11,8 +11,6 @@ package com.nepxion.discovery.plugin.configcenter;
 
 import java.io.InputStream;
 
-import javax.annotation.PostConstruct;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -20,7 +18,6 @@ import org.springframework.beans.factory.annotation.Value;
 
 import com.google.common.eventbus.Subscribe;
 import com.nepxion.discovery.plugin.configcenter.constant.ConfigConstant;
-import com.nepxion.discovery.plugin.configcenter.loader.ConfigLoader;
 import com.nepxion.discovery.plugin.framework.constant.PluginConstant;
 import com.nepxion.eventbus.annotation.EventBus;
 import com.nepxion.eventbus.core.Event;
@@ -29,46 +26,15 @@ import com.nepxion.eventbus.core.Event;
 public class ConfigSubscriber {
     private static final Logger LOG = LoggerFactory.getLogger(ConfigSubscriber.class);
 
-    @Value("${" + PluginConstant.SPRING_APPLICATION_REGISTER_CONTROL_ENABLED + ":true}")
-    private Boolean registerControlEnabled;
-
     @Value("${" + PluginConstant.SPRING_APPLICATION_DISCOVERY_CONTROL_ENABLED + ":true}")
     private Boolean discoveryControlEnabled;
 
     @Value("${" + ConfigConstant.SPRING_APPLICATION_DISCOVERY_REMOTE_CONFIG_ENABLED + ":true}")
     private Boolean remoteConfigEnabled;
 
-    @Autowired(required = false)
-    private ConfigLoader configLoader;
-
     @Autowired
     private ConfigParser configParser;
 
-    @PostConstruct
-    public void initialize() {
-        if (!registerControlEnabled && !discoveryControlEnabled) {
-            LOG.info("********** Register and Discovery controls are all disabled, ignore to initialize **********");
-
-            return;
-        }
-
-        if (configLoader == null) {
-            LOG.info("********** ConfigLoader isn't provided, ignore to initialize **********");
-
-            return;
-        }
-
-        LOG.info("********** {} config starts to initialize **********", remoteConfigEnabled ? "Remote" : "Local");
-
-        InputStream inputStream = null;
-        if (remoteConfigEnabled) {
-            inputStream = configLoader.getRemoteInputStream();
-        } else {
-            inputStream = configLoader.getLocalInputStream();
-        }
-        configParser.parse(inputStream);
-    }
-
     @Subscribe
     public void subscribe(Event event) {
         if (!discoveryControlEnabled) {

discovery-plugin-config-center/src/main/java/com/nepxion/discovery/plugin/configcenter/configuration/ConfigAutoConfiguration.java

@@ -12,12 +12,18 @@ package com.nepxion.discovery.plugin.configcenter.configuration;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
+import com.nepxion.discovery.plugin.configcenter.ConfigInitializer;
 import com.nepxion.discovery.plugin.configcenter.ConfigParser;
 import com.nepxion.discovery.plugin.configcenter.ConfigSubscriber;
 
 @Configuration
 public class ConfigAutoConfiguration {
     @Bean
+    public ConfigInitializer configInitializer() {
+        return new ConfigInitializer();
+    }
+
+    @Bean
     public ConfigParser configParser() {
         return new ConfigParser();
     }