Merge pull request #557 from boylong12/dev6.0

dubbo rpc 拦截器

txlcn-tc/pom.xml

@@ -33,6 +33,12 @@
       <scope>provided</scope>
     </dependency>
 
+    <dependency>
+      <groupId>com.alibaba</groupId>
+      <artifactId>dubbo</artifactId>
+      <scope>provided</scope>
+    </dependency>
+
     <dependency>
       <groupId>com.codingapi.txlcn</groupId>
       <artifactId>txlcn-p6spy</artifactId>
@@ -82,7 +88,6 @@
       <artifactId>mysql-connector-java</artifactId>
       <scope>test</scope>
     </dependency>
-
   </dependencies>
 
 

txlcn-tc/src/main/java/com/codingapi/txlcn/tc/rpc/DubboConsumerRpcTransactionInterceptor.java

+package com.codingapi.txlcn.tc.rpc;
+
+import com.alibaba.dubbo.common.Constants;
+import com.alibaba.dubbo.common.extension.Activate;
+import com.alibaba.dubbo.rpc.*;
+
+/**
+ * @author zhanghonglong
+ * @date 2020/10/28 11:01
+ */
+@Activate(group = Constants.CONSUMER)
+public class DubboConsumerRpcTransactionInterceptor implements Filter {
+    @Override
+    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
+        RpcTransactionContext.getInstance().build(invocation.getAttachments()::put);
+        return invoker.invoke(invocation);
+    }
+}

txlcn-tc/src/main/java/com/codingapi/txlcn/tc/rpc/DubboProviderRpcTransactionInterceptor.java

+package com.codingapi.txlcn.tc.rpc;
+
+import com.alibaba.dubbo.common.Constants;
+import com.alibaba.dubbo.common.extension.Activate;
+import com.alibaba.dubbo.rpc.*;
+
+/**
+ * @author zhanghonglong
+ * @date 2020/10/28 11:01
+ */
+@Activate(group = Constants.PROVIDER)
+public class DubboProviderRpcTransactionInterceptor implements Filter {
+    @Override
+    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
+        RpcTransactionContext.getInstance().invoke(invocation.getAttachments()::get);
+        return invoker.invoke(invocation);
+    }
+}

txlcn-tc/src/main/java/com/codingapi/txlcn/tc/rpc/RpcTransactionConfiguration.java

@@ -49,7 +49,4 @@ public class RpcTransactionConfiguration {
         }
 
     }
-
-
-
 }

txlcn-tc/src/main/resources/META-INF/dubbo/com.alibaba.dubbo.rpc.Filter

+DubboConsumerTransactionFilter=com.codingapi.txlcn.tc.rpc.DubboConsumerRpcTransactionInterceptor
+DubboProviderTransactionFilter=com.codingapi.txlcn.tc.rpc.DubboProviderRpcTransactionInterceptor
\ No newline at end of file