提交 116da9ff 编写于 作者: 龍的传人's avatar 龍的传人

dubbo filter SPI

Change-Id: I17bc566118457029168edbf8abc3c72c9a0f1523
上级 c185e20b
......@@ -34,9 +34,8 @@
</dependency>
<dependency>
<groupId>org.apache.dubbo</groupId>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.7.8</version>
<scope>provided</scope>
</dependency>
......
package com.codingapi.txlcn.tc.rpc;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.common.constants.CommonConstants;
import org.apache.dubbo.common.extension.Activate;
import org.apache.dubbo.rpc.*;
/**
* @author zhanghonglong
* @date 2020/10/28 11:01
*/
@Activate(group = CommonConstants.CONSUMER)
@Slf4j
public class ApacheDubboRpcTransactionInterceptor implements Filter {
@Override
public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
RpcTransactionContext.getInstance().build(invocation.getAttachments()::put);
return invoker.invoke(invocation);
}
}
......@@ -3,15 +3,13 @@ package com.codingapi.txlcn.tc.rpc;
import com.alibaba.dubbo.common.Constants;
import com.alibaba.dubbo.common.extension.Activate;
import com.alibaba.dubbo.rpc.*;
import lombok.extern.slf4j.Slf4j;
/**
* @author zhanghonglong
* @date 2020/10/28 11:01
*/
@Activate(group = Constants.CONSUMER)
@Slf4j
public class AlibabaDubboRpcTransactionInterceptor implements Filter {
public class DubboRpcTransactionInterceptor implements Filter {
@Override
public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
RpcTransactionContext.getInstance().build(invocation.getAttachments()::put);
......
......@@ -3,7 +3,6 @@ package com.codingapi.txlcn.tc.rpc;
import feign.Feign;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingClass;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;
......@@ -50,17 +49,4 @@ public class RpcTransactionConfiguration {
}
}
@Bean
@ConditionalOnClass(org.apache.dubbo.rpc.Filter.class)
public ApacheDubboRpcTransactionInterceptor apacheDubboRpcTransactionInterceptor(){
return new ApacheDubboRpcTransactionInterceptor();
}
@Bean
@ConditionalOnClass(com.alibaba.dubbo.rpc.Filter.class)
@ConditionalOnMissingClass("org.apache.dubbo.rpc.Filter")
public AlibabaDubboRpcTransactionInterceptor alibabaDubboRpcTransactionInterceptor(){
return new AlibabaDubboRpcTransactionInterceptor();
}
}
ApacheDubboTransactionFilter=com.codingapi.txlcn.tc.rpc.ApacheDubboRpcTransactionInterceptor
AlibabaDubboTransactionFilter=com.codingapi.txlcn.tc.rpc.AlibabaDubboRpcTransactionInterceptor
\ No newline at end of file
DubboTransactionFilter=com.codingapi.txlcn.tc.rpc.DubboRpcTransactionInterceptor
\ No newline at end of file
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册