ribbon loadbalancer optimisation

Author: foxdd

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

@@ -7,6 +7,9 @@
 import com.codingapi.tx.aop.bean.TxTransactionLocal;
 import com.netflix.loadbalancer.Server;
 
+/**
+ * created by foxdd 2017-12-05
+ */
 public class LcnLoadBalancerRule {
 
 	private Logger logger = LoggerFactory.getLogger(LcnLoadBalancerRule.class);
@@ -29,7 +32,6 @@ public Server proxy(Server server){
 		if(cachedServer == null){
 			logger.info("The server of key:" + key + " has not been cached yet!");
 			Constants.cacheModelInfo.put(key, server);
-			txTransactionLocal.getCachedModelList().add(key);
 			return server;
 		} else{
 			logger.info("The cached server info, host:" + cachedServer.getHost() + ", port:" + cachedServer.getPort());

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

@@ -6,6 +6,9 @@
 import com.netflix.loadbalancer.NoOpLoadBalancer;
 import com.netflix.loadbalancer.Server;
 
+/**
+ * created by foxdd 2017-12-05
+ */
 public class LcnNoOpLoadBalancerProxy extends NoOpLoadBalancer {
 
 	private Logger logger = LoggerFactory.getLogger(LcnNoOpLoadBalancerProxy.class);

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

@@ -15,6 +15,16 @@
 @Configuration
 public class LcnRibbonConfiguration {
 
+	/**
+	 * 为ribbon的loadbalancer做代理，相比于重写IRULE,重写loadbalancer更有利于用户自选LB算法，而且有默认LB算法可用
+	 * @param config
+	 * @param serverList
+	 * @param serverListFilter
+	 * @param rule
+	 * @param ping
+	 * @param serverListUpdater
+	 * @return
+	 */
 	@Bean
 	public ILoadBalancer ribbonLoadBalancer(IClientConfig config,
 			ServerList<Server> serverList, ServerListFilter<Server> serverListFilter,

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

@@ -12,6 +12,9 @@
 import com.netflix.loadbalancer.ServerListUpdater;
 import com.netflix.loadbalancer.ZoneAwareLoadBalancer;
 
+/**
+ * created by foxdd 2017-12-05
+ */
 public class LcnZoneAwareLoadBalancerProxy<T extends Server> extends ZoneAwareLoadBalancer<T> {
 
 	private Logger logger = LoggerFactory.getLogger(LcnZoneAwareLoadBalancerProxy.class);

tx-client/src/main/java/com/codingapi/tx/aop/bean/TxTransactionLocal.java

@@ -1,9 +1,5 @@
 package com.codingapi.tx.aop.bean;
 
-import java.util.ArrayList;
-import java.util.List;
-
-import org.springframework.transaction.annotation.Transactional;
 import com.alibaba.fastjson.JSONObject;
 import com.codingapi.tx.framework.utils.SocketManager;
 import com.codingapi.tx.model.Request;
@@ -35,6 +31,9 @@ public class TxTransactionLocal {
      */
     private boolean hasIsGroup = false;
 
+    /**
+     * 是否是发起方模块
+     */
     private boolean hasStart = false;
 
     /**
@@ -48,7 +47,6 @@ public class TxTransactionLocal {
     private String type;
 
     private boolean readOnly = false;
-    private List<String> cachedModelList = new ArrayList<String>();
 
     public boolean isHasIsGroup() {
         return hasIsGroup;
@@ -159,12 +157,4 @@ public void setReadOnly(boolean readOnly) {
         this.readOnly = readOnly;
     }
 
-    public List<String> getCachedModelList(){
-    	return cachedModelList;
-    }
-
-    public void setCachedModelList(List<String> cachedModelList){
-    	this.cachedModelList = cachedModelList;
-    }
-
 }

tx-client/src/main/java/com/codingapi/tx/aop/service/impl/TxStartTransactionServerImpl.java

@@ -1,6 +1,5 @@
 package com.codingapi.tx.aop.service.impl;
 
-import com.alibaba.fastjson.JSONObject;
 import com.codingapi.tx.Constants;
 import com.codingapi.tx.aop.bean.TxCompensateLocal;
 import com.codingapi.tx.aop.bean.TxTransactionInfo;
@@ -12,9 +11,6 @@
 import com.codingapi.tx.model.TxGroup;
 import com.codingapi.tx.netty.service.MQTxManagerService;
 import com.lorne.core.framework.exception.ServiceException;
-
-import java.util.List;
-
 import com.lorne.core.framework.utils.KidUtils;
 import com.lorne.core.framework.utils.task.ConditionUtils;
 import com.lorne.core.framework.utils.task.Task;
@@ -74,17 +70,6 @@ public Object execute(ProceedingJoinPoint point,final TxTransactionInfo info) th
             throw e;
         } finally {
 
-            TxTransactionLocal txTransactionLocal = TxTransactionLocal.current();
-
-            List<String> keyList = txTransactionLocal.getCachedModelList();
-
-            System.out.println("delete the complete cached list:" + JSONObject.toJSONString(keyList) + ", groupId:" + groupId);
-
-            for(String key:keyList){
-            	Constants.cacheModelInfo.remove(key);
-            }
-
-            long end = System.currentTimeMillis();
             final int resState = state;
             final String type = txTransactionLocal.getType();
 

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

@@ -1,8 +1,5 @@
 package com.codingapi.tx.datasource.relational;
 
-import com.codingapi.tx.datasource.ICallClose;
-import com.alibaba.fastjson.JSONObject;
-import com.codingapi.tx.Constants;
 import com.codingapi.tx.aop.bean.TxTransactionLocal;
 import com.codingapi.tx.datasource.ICallClose;
 import com.codingapi.tx.datasource.ILCNResource;
@@ -14,7 +11,6 @@
 import org.slf4j.LoggerFactory;
 
 import java.sql.*;
-import java.util.List;
 import java.util.Map;
 import java.util.Properties;
 import java.util.Timer;
@@ -47,20 +43,15 @@ public class LCNDBConnection extends AbstractTransactionThread implements Connec
 
     private TxTask waitTask;
 
-    private List<String> cachedModelList;
-
 
     public LCNDBConnection(Connection connection, DataSourceService dataSourceService, ICallClose<ILCNResource> runnable) {
         logger.info("init lcn connection ! ");
-    public LCNDBConnection(Connection connection, DataSourceService dataSourceService, TxTransactionLocal transactionLocal, ICallClose<LCNDBConnection> runnable) {
-        logger.info("init lcn connection ! ");
         this.connection = connection;
         this.runnable = runnable;
         this.dataSourceService = dataSourceService;
         TxTransactionLocal transactionLocal = TxTransactionLocal.current();
         groupId = transactionLocal.getGroupId();
         maxOutTime = transactionLocal.getMaxTimeOut();
-        cachedModelList = transactionLocal.getCachedModelList();
 
 
         TaskGroup taskGroup = TaskGroupManager.getInstance().createTask(transactionLocal.getKid(),transactionLocal.getType());
@@ -168,12 +159,6 @@ public void run() {
 
         System.out.println("lcn transaction over, res -> groupId:"+getGroupId()+" and  state is "+rs+", about state (1:commit 0:rollback -1:network error -2:network time out)");
 
-        System.out.println("delete the completed cached list:" + JSONObject.toJSONString(cachedModelList) + ", groupId:" + getGroupId());
-
-        for(String key : cachedModelList){
-        	Constants.cacheModelInfo.remove(key);
-        }
-
         if (rs == 1) {
             connection.commit();
         } else {