Merge branch 'master' into tx-lcn-foxdd

Author: xlorne

README.md

@@ -2,9 +2,14 @@
 
   "LCN并不生产事务，LCN只是本地事务的搬运工"
 
+## 框架介绍   
+
+  LCN分布式事务框架是一款事务协调性的框架，框架本身并不创建事务，只是对本地事务做协调控制。因此该框架与其他第三方的框架兼容性强，支持所有的关系型数据库事务，支持多数据源，支持与第三方数据库框架一块使用（例如 sharding-jdbc），在使用框架的时候只需要添加分布式事务的注解即可，对业务的侵入性低。LCN框架主要是为微服务框架提供分布式事务的支持，在微服务框架上做了进一步的事务机制优化，在一些负载场景上LCN事务机制要比本地事务机制的性能更好，4.0以后框架开方了插件机制可以让更多的第三方框架支持进来。
+
+
 ## 官方网址
 
-[www.txlcn.org](http://www.txlcn.org)
+[https://www.txlcn.org](https://www.txlcn.org)
 
 
 ## 框架特点
@@ -21,7 +26,7 @@
 
 ## 原理介绍
 
-[原理介绍](https://github.com/codingapi/tx-lcn/wiki)  [视频讲解](http://www.txlcn.org/v4/index.html)
+[原理介绍](https://github.com/codingapi/tx-lcn/wiki)  [视频讲解](https://www.txlcn.org/v4/index.html)
 
 ## 目录说明
 

transaction-dubbo/pom.xml

@@ -74,7 +74,7 @@
         <dependency>
             <groupId>com.alibaba</groupId>
             <artifactId>dubbo</artifactId>
-            <version>2.5.3</version>
+            <version>2.5.7</version>
             <exclusions>
                 <exclusion>
                     <groupId>org.springframework</groupId>

transaction-springcloud/src/main/java/com/codingapi/ribbon/loadbalancer/LcnLoadBalancerRule.java

@@ -1,6 +1,8 @@
 package com.codingapi.ribbon.loadbalancer;
 
+
 import com.alibaba.fastjson.JSONObject;
+
 import com.codingapi.tx.aop.bean.TxTransactionLocal;
 import com.lorne.core.framework.utils.encode.MD5Util;
 import com.netflix.loadbalancer.Server;

transaction-springcloud/src/main/java/com/codingapi/ribbon/loadbalancer/LcnNoOpLoadBalancerProxy.java

@@ -25,8 +25,10 @@ public LcnNoOpLoadBalancerProxy(){
 	@Override
 	public Server chooseServer(Object key){
 		logger.info("enter chooseServer method, key:" + key);
+
 		List<Server> serverList = new ArrayList<Server>();
 		return lcnLoadBalancerRule.proxy(serverList, super.chooseServer(key));
+
 	}
 
 }

transaction-springcloud/src/main/java/com/codingapi/ribbon/loadbalancer/LcnZoneAwareLoadBalancerProxy.java

@@ -26,12 +26,14 @@ public LcnZoneAwareLoadBalancerProxy(IClientConfig clientConfig, IRule rule,
 	@Override
 	public Server chooseServer(Object key){
 		logger.info("enter chooseServer method, key:" + key);
+
 		List<Server> serverList = new ArrayList<Server>();
 		//获取处理之后的serverlist
 		serverList = super.getServerListImpl().getUpdatedListOfServers();
 		//获取过滤之后的serverlist
 		serverList = super.getFilter().getFilteredListOfServers(serverList);
 		return lcnLoadBalancerRule.proxy(serverList, super.chooseServer(key));
+
 	}
 
 }

tx-client/src/main/java/com/codingapi/tx/Constants.java

@@ -1,8 +1,5 @@
 package com.codingapi.tx;
 
-import java.util.Map;
-import java.util.concurrent.ConcurrentHashMap;
-
 import com.codingapi.tx.model.TxServer;
 
 /**
@@ -28,11 +25,6 @@ public class Constants {
      * 模块唯一标示
      */
     public static String uniqueKey;
-    
-    /**
-     * 用于优化ribbon负载
-     */
-    public static Map<String, Object> cacheModelInfo = new ConcurrentHashMap<>();
 
 
 }

tx-plugins-db/src/main/java/com/codingapi/tx/datasource/bean/LCNDataSourceLocal.java

@@ -0,0 +1,29 @@
+package com.codingapi.tx.datasource.bean;
+
+/**
+ * create by lorne on 2017/12/7
+ */
+public class LCNDataSourceLocal {
+
+    private final static ThreadLocal<LCNDataSourceLocal> currentLocal = new ThreadLocal<LCNDataSourceLocal>();
+
+    public static LCNDataSourceLocal current() {
+        return currentLocal.get();
+    }
+
+    public static void setCurrent(LCNDataSourceLocal current) {
+        currentLocal.set(current);
+    }
+
+    private String key;
+
+
+    public String getKey() {
+        return key;
+    }
+
+    public void setKey(String key) {
+        this.key = key;
+    }
+
+}

tx-plugins-db/src/main/java/com/codingapi/tx/datasource/relational/LCNConnection.java

@@ -0,0 +1,11 @@
+package com.codingapi.tx.datasource.relational;
+
+import com.codingapi.tx.datasource.ILCNResource;
+
+import java.sql.Connection;
+
+/**
+ * create by lorne on 2017/12/7
+ */
+public interface LCNConnection extends  Connection,ILCNResource<Connection> {
+}

tx-plugins-db/src/main/java/com/codingapi/tx/datasource/relational/LCNDBConnection.java

@@ -22,7 +22,7 @@
  * create by lorne on 2017/7/29
  */
 
-public class LCNDBConnection extends AbstractTransactionThread implements Connection,ILCNResource<Connection> {
+public class LCNDBConnection extends AbstractTransactionThread implements LCNConnection {
 
 
     private Logger logger = LoggerFactory.getLogger(LCNDBConnection.class);
@@ -178,7 +178,9 @@ public TxTask getWaitTask() {
 
     @Override
     public void setAutoCommit(boolean autoCommit) throws SQLException {
-        connection.setAutoCommit(false);
+        if(connection!=null) {
+            connection.setAutoCommit(false);
+        }
     }
 
     @Override

tx-plugins-db/src/main/java/com/codingapi/tx/datasource/relational/LCNDynamicTransactionDataSource.java

@@ -0,0 +1,80 @@
+package com.codingapi.tx.datasource.relational;
+
+import com.codingapi.tx.aop.bean.TxTransactionLocal;
+import com.codingapi.tx.datasource.bean.LCNDataSourceLocal;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.sql.DataSource;
+import java.sql.Connection;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+
+/**
+ * 关系型数据库动态代理连接池对象
+ * create by lorne on 2017/7/29
+ */
+
+public class LCNDynamicTransactionDataSource extends LCNTransactionDataSource {
+
+
+    private Logger logger = LoggerFactory.getLogger(LCNDynamicTransactionDataSource.class);
+
+
+    private Map<String,DataSource> dataSourceMap = new ConcurrentHashMap<>();
+
+
+    private String getNowDataSourceKey(){
+        if(LCNDataSourceLocal.current()==null){
+            return "default";
+        }
+        return LCNDataSourceLocal.current().getKey();
+    }
+
+    @Override
+    public boolean hasGroup(String group) {
+        return super.hasGroup(getNowDataSourceKey()+group);
+    }
+
+    @Override
+    protected Connection createLcnConnection(Connection connection, TxTransactionLocal txTransactionLocal) {
+        nowCount++;
+        if(txTransactionLocal.isHasStart()){
+            LCNStartConnection lcnStartConnection = new LCNStartConnection(connection,subNowCount);
+            logger.info("get new start connection - > "+txTransactionLocal.getGroupId());
+            pools.put(getNowDataSourceKey()+txTransactionLocal.getGroupId(), lcnStartConnection);
+            txTransactionLocal.setHasConnection(true);
+            return lcnStartConnection;
+        }else {
+            LCNDBConnection lcn = new LCNDBConnection(connection, dataSourceService, subNowCount);
+            logger.info("get new connection ->" + txTransactionLocal.getGroupId());
+            pools.put(getNowDataSourceKey()+txTransactionLocal.getGroupId(), lcn);
+            txTransactionLocal.setHasConnection(true);
+            return lcn;
+        }
+    }
+
+    public void addDataSource(String key, DataSource dataSource){
+        dataSourceMap.put(key,dataSource);
+        logger.info("add datasource of "+key);
+    }
+
+    public void setDataSource(DataSource dataSource) {
+        super.setDataSource(dataSource);
+        addDataSource("default",dataSource);
+        logger.info("load default datasource.");
+    }
+
+    @Override
+    protected DataSource getDataSource() {
+        logger.info("getDataSource--->");
+        if(LCNDataSourceLocal.current()==null){
+            return super.getDataSource();
+        }else{
+            String key = LCNDataSourceLocal.current().getKey();
+            logger.info("get datasource of "+key);
+            return dataSourceMap.get(key);
+        }
+    }
+}