优化txUrl 和 TxManager请求方式，提供api方式自定义修改

Author: xlorne

tx-client/src/main/java/com/codingapi/tx/config/ConfigReader.java

@@ -1,8 +1,11 @@
 package com.codingapi.tx.config;
 
+import com.codingapi.tx.config.service.TxManagerTxUrlService;
 import com.lorne.core.framework.utils.config.ConfigUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationContext;
 import org.springframework.stereotype.Component;
 
 /**
@@ -11,60 +14,43 @@
 @Component
 public class ConfigReader {
 
-    private String txUrl;
-
-    private String configName = "tx.properties";
-
-    private String configKey = "url";
 
     private Logger logger = LoggerFactory.getLogger(ConfigReader.class);
 
 
-    public ConfigReader() {
-        loadConfig();
-    }
+    private TxManagerTxUrlService txManagerTxUrlService;
 
-    private void loadConfig(){
-        try {
-            txUrl = ConfigUtils.getString(configName, configKey);
+    @Autowired
+    private ApplicationContext spring;
 
-            //兼容3.0的配置地址
-            if (txUrl.contains("/tx/manager/getServer")) {
-                txUrl = txUrl.replace("getServer", "");
-            }
 
-            //添加后缀/
-            if (!txUrl.endsWith("/")){
-                txUrl+="/";
-            }
+    public String getTxUrl() {
 
+        try {
+            txManagerTxUrlService =  spring.getBean(TxManagerTxUrlService.class);
         }catch (Exception e){
             logger.error(e.getLocalizedMessage());
         }
-    }
 
-    /**
-     * 重新设置配置文件名称
-     * @param configName  配置文件名称
-     * @param key  配置文件key值
-     */
-    public void setConfigName(String configName,String key) {
-        this.configName = configName;
-        this.configKey = key;
-        loadConfig();
-    }
+        if(txManagerTxUrlService == null){
+            txManagerTxUrlService = new TxManagerTxUrlService() {
 
-    /**
-     * 设置TxManager服务地址 格式如 http://127.0.0.1:8899/tx/manager/
-     * @param txUrl
-     */
-    public void setTxUrl(String txUrl) {
-        this.txUrl = txUrl;
-    }
+                private final String configName = "tx.properties";
 
+                private final String configKey = "url";
 
-    public String getTxUrl() {
-        return txUrl;
+                @Override
+                public String getTxUrl() {
+                    return ConfigUtils.getString(configName,configKey);
+                }
+            };
+
+            logger.info("load default txManagerTxUrlService");
+        }else{
+            logger.info("load txManagerTxUrlService");
+        }
+
+        return txManagerTxUrlService.getTxUrl();
     }
 
 

tx-client/src/main/java/com/codingapi/tx/config/service/TxManagerTxUrlService.java

@@ -0,0 +1,9 @@
+package com.codingapi.tx.config.service;
+
+/**
+ * create by lorne on 2017/11/18
+ */
+public interface TxManagerTxUrlService {
+
+    String getTxUrl();
+}

tx-client/src/main/java/com/codingapi/tx/netty/service/TxManagerHttpRequestHelper.java

@@ -2,6 +2,10 @@
 
 
 import com.lorne.core.framework.utils.http.HttpUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationContext;
 import org.springframework.stereotype.Component;
 
 /**
@@ -11,15 +15,23 @@
 public class TxManagerHttpRequestHelper {
 
 
-    private HttpRequestService httpRequestService;
+    private TxManagerHttpRequestService httpRequestService;
+
+    @Autowired
+    private ApplicationContext spring;
+
+    private Logger logger = LoggerFactory.getLogger(TxManagerHttpRequestHelper.class);
 
-    public void setHttpRequestService(HttpRequestService httpRequestService) {
-        this.httpRequestService = httpRequestService;
-    }
 
     private void reloadHttpRequestService(){
+        try {
+            httpRequestService = spring.getBean(TxManagerHttpRequestService.class);
+        }catch (Exception e){
+            logger.error(e.getLocalizedMessage());
+        }
+
         if(httpRequestService==null){
-            httpRequestService = new HttpRequestService() {
+            httpRequestService = new TxManagerHttpRequestService() {
                 @Override
                 public String httpGet(String url) {
                     return HttpUtils.get(url);
@@ -30,6 +42,9 @@ public String httpPost(String url, String params) {
                     return HttpUtils.post(url, params);
                 }
             };
+            logger.info("load default HttpRequestService .");
+        }else {
+            logger.info("load HttpRequestService .");
         }
     }
 

…tx/netty/service/HttpRequestService.java …service/TxManagerHttpRequestService.javatx-client/src/main/java/com/codingapi/tx/netty/service/HttpRequestService.java renamed to tx-client/src/main/java/com/codingapi/tx/netty/service/TxManagerHttpRequestService.java tx-client/src/main/java/com/codingapi/tx/netty/service/HttpRequestService.java renamed to tx-client/src/main/java/com/codingapi/tx/netty/service/TxManagerHttpRequestService.java

@@ -3,7 +3,7 @@
 /**
  * create by lorne on 2017/11/17
  */
-public interface HttpRequestService {
+public interface TxManagerHttpRequestService {
 
      String httpGet(String url);