study/Spring-Cloud-Alibaba
1
0
Fork 0
mirror of https://gitee.com/mirrors/Spring-Cloud-Alibaba.git synced 2021-06-26 13:25:11 +08:00
Code Issues Releases Wiki Activity

seata feignloadbalancer enhance

Browse Source
This commit is contained in:
yuhuangbin 2020-01-15 22:08:52 +08:00
parent 648944df09
commit ab06f3232c
2 changed files with 1 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-alibaba-examples/seata-example/business-service/pom.xml
View File

@ -20,10 +20,6 @@
<groupId>org.springframework.cloud</groupId> <groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId> <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency> </dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>
<dependency> <dependency>
<groupId>org.springframework.cloud</groupId> <groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>

11
spring-cloud-alibaba-seata/src/main/java/com/alibaba/cloud/seata/feign/SeataFeignObjectWrapper.java
View File

@ -41,8 +41,6 @@ public class SeataFeignObjectWrapper {
private SpringClientFactory springClientFactory; private SpringClientFactory springClientFactory;
private BlockingLoadBalancerClient loadBalancerClient;
SeataFeignObjectWrapper(BeanFactory beanFactory) { SeataFeignObjectWrapper(BeanFactory beanFactory) {
this.beanFactory = beanFactory; this.beanFactory = beanFactory;
} }
@ -57,7 +55,7 @@ public class SeataFeignObjectWrapper {
if (bean.getClass().getName().equals( if (bean.getClass().getName().equals(
"org.springframework.cloud.openfeign.loadbalancer.FeignBlockingLoadBalancerClient")) { "org.springframework.cloud.openfeign.loadbalancer.FeignBlockingLoadBalancerClient")) {
return new SeataFeignBlockingLoadBalancerClient(getClient(bean), return new SeataFeignBlockingLoadBalancerClient(getClient(bean),
loadBalancerClient()); beanFactory.getBean(BlockingLoadBalancerClient.class));
} }
return new SeataFeignClient(this.beanFactory, (Client) bean); return new SeataFeignClient(this.beanFactory, (Client) bean);
} }
@ -82,13 +80,6 @@ public class SeataFeignObjectWrapper {
return null; return null;
} }
private BlockingLoadBalancerClient loadBalancerClient() {
if (this.loadBalancerClient != null) {
return this.loadBalancerClient;
}
return beanFactory.getBean(BlockingLoadBalancerClient.class);
}
CachingSpringLoadBalancerFactory factory() { CachingSpringLoadBalancerFactory factory() {
if (this.cachingSpringLoadBalancerFactory == null) { if (this.cachingSpringLoadBalancerFactory == null) {
this.cachingSpringLoadBalancerFactory = this.beanFactory this.cachingSpringLoadBalancerFactory = this.beanFactory