添加打印对tx-group传递参数的日志

Author: xlorne

transaction-dubbo/src/main/java/com/codingapi/tx/dubbo/filter/TransactionFilter.java

@@ -2,19 +2,34 @@
 
 import com.alibaba.dubbo.rpc.*;
 import com.codingapi.tx.aop.bean.TxTransactionLocal;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * Created by lorne on 2017/6/30.
  */
 public class TransactionFilter implements Filter {
 
+
+    private Logger logger = LoggerFactory.getLogger(TransactionFilter.class);
+
     @Override
     public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
         TxTransactionLocal txTransactionLocal = TxTransactionLocal.current();
+
+
         if(txTransactionLocal!=null){
-            RpcContext.getContext().setAttachment("tx-group",txTransactionLocal.getGroupId());
-            RpcContext.getContext().setAttachment("tx-maxTimeOut",String.valueOf(txTransactionLocal.getMaxTimeOut()));
+            String groupId = txTransactionLocal.getGroupId();
+            int maxTimeOut = txTransactionLocal.getMaxTimeOut();
+
+            RpcContext.getContext().setAttachment("tx-group",groupId);
+            RpcContext.getContext().setAttachment("tx-maxTimeOut",String.valueOf(maxTimeOut));
+
+            logger.info("LCN-dubbo TxGroup info -> groupId:"+groupId+",maxTimeOut:"+maxTimeOut);
+        }else{
+            logger.info("LCN-dubbo TxGroup info -> groupId:null,maxTimeOut:null");
         }
+
         return invoker.invoke(invocation);
     }
 }

transaction-springcloud/src/main/java/com/codingapi/tx/springcloud/feign/TransactionRestTemplateInterceptor.java

@@ -4,18 +4,25 @@
 //import CompensateServiceImpl;
 import feign.RequestInterceptor;
 import feign.RequestTemplate;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * Created by lorne on 2017/6/26.
  */
 public class TransactionRestTemplateInterceptor implements RequestInterceptor {
 
 
+    private Logger logger = LoggerFactory.getLogger(TransactionRestTemplateInterceptor.class);
+
     @Override
     public void apply(RequestTemplate requestTemplate) {
         TxTransactionLocal txTransactionLocal = TxTransactionLocal.current();
         String groupId = txTransactionLocal == null ? null : txTransactionLocal.getGroupId();
         int maxTimeOut = txTransactionLocal == null ? 0 : txTransactionLocal.getMaxTimeOut();
+
+        logger.info("LCN-SpringCloud TxGroup info -> groupId:"+groupId+",maxTimeOut:"+maxTimeOut);
+
         if (txTransactionLocal != null) {
             requestTemplate.header("tx-group", groupId);
             requestTemplate.header("tx-maxTimeOut", String.valueOf(maxTimeOut));

transaction-springcloud/src/main/java/com/codingapi/tx/springcloud/http/TransactionHttpRequestInterceptor.java

@@ -1,6 +1,8 @@
 package com.codingapi.tx.springcloud.http;
 
 import com.codingapi.tx.aop.bean.TxTransactionLocal;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.http.HttpRequest;
 import org.springframework.http.client.ClientHttpRequestExecution;
 import org.springframework.http.client.ClientHttpRequestInterceptor;
@@ -13,11 +15,18 @@
  */
 public class TransactionHttpRequestInterceptor implements ClientHttpRequestInterceptor {
 
+
+    private Logger logger = LoggerFactory.getLogger(TransactionHttpRequestInterceptor.class);
+
     @Override
     public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException {
+
         TxTransactionLocal txTransactionLocal = TxTransactionLocal.current();
         String groupId = txTransactionLocal==null?null:txTransactionLocal.getGroupId();
         int maxTimeOut = txTransactionLocal == null ? 0 : txTransactionLocal.getMaxTimeOut();
+
+        logger.info("LCN-SpringCloud TxGroup info -> groupId:"+groupId+",maxTimeOut:"+maxTimeOut);
+
         request.getHeaders().add("tx-group",groupId);
         request.getHeaders().add("tx-maxTimeOut", String.valueOf(maxTimeOut));
         return execution.execute(request,body);