add module Fescar, Polish #303

spring-cloud-alibaba-fescar/pom.xml

@@ -0,0 +1,117 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+
+    <parent>
+        <groupId>org.springframework.cloud</groupId>
+        <artifactId>spring-cloud-alibaba</artifactId>
+        <version>0.2.2.BUILD-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>org.springframework.cloud</groupId>
+    <artifactId>spring-cloud-alibaba-fescar</artifactId>
+    <name>Spring Cloud Alibaba Fescar</name>
+
+    <dependencies>
+
+        <dependency>
+            <groupId>com.alibaba.fescar</groupId>
+            <artifactId>fescar-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba.fescar</groupId>
+            <artifactId>fescar-common</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba.fescar</groupId>
+            <artifactId>fescar-spring</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba.fescar</groupId>
+            <artifactId>fescar-rm-datasource</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-openfeign</artifactId>
+            <scope>provided</scope>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
+            <scope>provided</scope>
+            <optional>true</optional>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-commons</artifactId>
+            <optional>true</optional>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
+            <scope>provided</scope>
+            <optional>true</optional>
+        </dependency>
+
+        <!--spring boot-->
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-aop</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-actuator</artifactId>
+            <scope>provided</scope>
+            <optional>true</optional>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-actuator-autoconfigure</artifactId>
+            <scope>provided</scope>
+            <optional>true</optional>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-configuration-processor</artifactId>
+            <scope>provided</scope>
+            <optional>true</optional>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot</artifactId>
+            <scope>provided</scope>
+            <optional>true</optional>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-autoconfigure</artifactId>
+            <scope>provided</scope>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+            <scope>provided</scope>
+            <optional>true</optional>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+    </dependencies>
+
+</project>

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/FescarProperties.java

@@ -0,0 +1,42 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alibaba.fescar;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+/**
+ * @author xiaojing
+ */
+@ConfigurationProperties("spring.cloud.alibaba.fescar")
+public class FescarProperties {
+
+	// todo support config Fescar server information
+
+	/**
+	 * Fescar tx service group.default is ${spring.application.name}-fescar-service-group.
+	 */
+	private String txServiceGroup;
+
+	public String getTxServiceGroup() {
+		return txServiceGroup;
+	}
+
+	public void setTxServiceGroup(String txServiceGroup) {
+		this.txServiceGroup = txServiceGroup;
+	}
+
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/GlobalTransactionAutoConfiguration.java

@@ -0,0 +1,60 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alibaba.fescar;
+
+import com.alibaba.fescar.spring.annotation.GlobalTransactionScanner;
+
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.util.StringUtils;
+
+/**
+ * @author xiaojing
+ */
+
+@Configuration
+@EnableConfigurationProperties(FescarProperties.class)
+public class GlobalTransactionAutoConfiguration {
+
+	private final ApplicationContext applicationContext;
+
+	private final FescarProperties fescarProperties;
+
+	public GlobalTransactionAutoConfiguration(ApplicationContext applicationContext,
+			FescarProperties fescarProperties) {
+		this.applicationContext = applicationContext;
+		this.fescarProperties = fescarProperties;
+	}
+
+	@Bean
+	public GlobalTransactionScanner globalTransactionScanner() {
+
+		String applicationName = applicationContext.getEnvironment()
+				.getProperty("spring.application.name");
+
+		String txServiceGroup = fescarProperties.getTxServiceGroup();
+
+		if (StringUtils.isEmpty(txServiceGroup)) {
+			txServiceGroup = applicationName + "-fescar-service-group";
+			fescarProperties.setTxServiceGroup(txServiceGroup);
+		}
+
+		return new GlobalTransactionScanner(applicationName, txServiceGroup);
+	}
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarBeanPostProcessor.java

@@ -0,0 +1,44 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alibaba.fescar.feign;
+
+import org.springframework.beans.BeansException;
+import org.springframework.beans.factory.config.BeanPostProcessor;
+
+/**
+ * @author xiaojing
+ */
+final class FescarBeanPostProcessor implements BeanPostProcessor {
+
+	private final FescarFeignObjectWrapper eagleEyeFeignObjectWrapper;
+
+	FescarBeanPostProcessor(FescarFeignObjectWrapper eagleEyeFeignObjectWrapper) {
+		this.eagleEyeFeignObjectWrapper = eagleEyeFeignObjectWrapper;
+	}
+
+	@Override
+	public Object postProcessBeforeInitialization(Object bean, String beanName)
+			throws BeansException {
+		return this.eagleEyeFeignObjectWrapper.wrap(bean);
+	}
+
+	@Override
+	public Object postProcessAfterInitialization(Object bean, String beanName)
+			throws BeansException {
+		return bean;
+	}
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarContextBeanPostProcessor.java

@@ -0,0 +1,59 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alibaba.fescar.feign;
+
+import org.springframework.beans.BeansException;
+import org.springframework.beans.factory.BeanFactory;
+import org.springframework.beans.factory.config.BeanPostProcessor;
+import org.springframework.cloud.openfeign.FeignContext;
+
+/**
+ * @author xiaojing
+ */
+public class FescarContextBeanPostProcessor implements BeanPostProcessor {
+
+	private final BeanFactory beanFactory;
+	private FescarFeignObjectWrapper eagleEyeFeignObjectWrapper;
+
+	FescarContextBeanPostProcessor(BeanFactory beanFactory) {
+		this.beanFactory = beanFactory;
+	}
+
+	@Override
+	public Object postProcessBeforeInitialization(Object bean, String beanName)
+			throws BeansException {
+		if (bean instanceof FeignContext && !(bean instanceof FescarFeignContext)) {
+			return new FescarFeignContext(getEagleEyeFeignObjectWrapper(),
+					(FeignContext) bean);
+		}
+		return bean;
+	}
+
+	@Override
+	public Object postProcessAfterInitialization(Object bean, String beanName)
+			throws BeansException {
+		return bean;
+	}
+
+	private FescarFeignObjectWrapper getEagleEyeFeignObjectWrapper() {
+		if (this.eagleEyeFeignObjectWrapper == null) {
+			this.eagleEyeFeignObjectWrapper = this.beanFactory
+					.getBean(FescarFeignObjectWrapper.class);
+		}
+		return this.eagleEyeFeignObjectWrapper;
+	}
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignBuilder.java

@@ -0,0 +1,34 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alibaba.fescar.feign;
+
+import org.springframework.beans.factory.BeanFactory;
+
+import feign.Feign;
+
+/**
+ * @author xiaojing
+ */
+final class FescarFeignBuilder {
+
+	private FescarFeignBuilder() {
+	}
+
+	static Feign.Builder builder(BeanFactory beanFactory) {
+		return Feign.builder().client(new FescarFeignClient(beanFactory));
+	}
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignClient.java

@@ -0,0 +1,85 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alibaba.fescar.feign;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import com.alibaba.fescar.core.context.RootContext;
+
+import org.springframework.beans.factory.BeanFactory;
+
+import feign.Client;
+import feign.Request;
+import feign.Response;
+import org.springframework.util.StringUtils;
+
+/**
+ * @author xiaojing
+ */
+public class FescarFeignClient implements Client {
+
+	private final Client delegate;
+	private final BeanFactory beanFactory;
+
+	FescarFeignClient(BeanFactory beanFactory) {
+		this.beanFactory = beanFactory;
+		this.delegate = new Client.Default(null, null);
+	}
+
+	FescarFeignClient(BeanFactory beanFactory, Client delegate) {
+		this.delegate = delegate;
+		this.beanFactory = beanFactory;
+	}
+
+	@Override
+	public Response execute(Request request, Request.Options options) throws IOException {
+
+		Request modifiedRequest = getModifyRequest(request);
+
+		try {
+			return this.delegate.execute(modifiedRequest, options);
+		}
+		finally {
+
+		}
+	}
+
+	private Request getModifyRequest(Request request) {
+
+		String xid = RootContext.getXID();
+
+		if (StringUtils.isEmpty(xid)) {
+			return request;
+		}
+
+		Map<String, Collection<String>> headers = new HashMap<>();
+		headers.putAll(request.headers());
+
+		List<String> fescarXid = new ArrayList<>();
+		fescarXid.add(xid);
+		headers.put(RootContext.KEY_XID, fescarXid);
+
+		return Request.create(request.method(), request.url(), headers, request.body(),
+				request.charset());
+	}
+
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignClientAutoConfiguration.java

@@ -0,0 +1,85 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alibaba.fescar.feign;
+
+import org.springframework.beans.factory.BeanFactory;
+import org.springframework.boot.autoconfigure.AutoConfigureBefore;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.cloud.openfeign.FeignAutoConfiguration;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Scope;
+
+import feign.Client;
+import feign.Feign;
+
+/**
+ * @author xiaojing
+ */
+
+@Configuration
+@ConditionalOnClass(Client.class)
+@AutoConfigureBefore(FeignAutoConfiguration.class)
+public class FescarFeignClientAutoConfiguration {
+
+	@Bean
+	@Scope("prototype")
+	@ConditionalOnClass(name = "com.netflix.hystrix.HystrixCommand")
+	@ConditionalOnProperty(name = "feign.hystrix.enabled", havingValue = "true")
+	Feign.Builder feignHystrixBuilder(BeanFactory beanFactory) {
+		return FescarHystrixFeignBuilder.builder(beanFactory);
+	}
+
+	@Bean
+	@Scope("prototype")
+	@ConditionalOnClass(name = "com.alibaba.csp.sentinel.SphU")
+	@ConditionalOnProperty(name = "feign.sentinel.enabled", havingValue = "true")
+	Feign.Builder feignSentinelBuilder(BeanFactory beanFactory) {
+		return FescarSentinelFeignBuilder.builder(beanFactory);
+	}
+
+	@Bean
+	@ConditionalOnMissingBean
+	@Scope("prototype")
+	Feign.Builder feignBuilder(BeanFactory beanFactory) {
+		return FescarFeignBuilder.builder(beanFactory);
+	}
+
+	@Configuration
+	protected static class FeignBeanPostProcessorConfiguration {
+
+		@Bean
+		FescarBeanPostProcessor eagleEyeBeanPostProcessor(
+				FescarFeignObjectWrapper eagleEyeFeignObjectWrapper) {
+			return new FescarBeanPostProcessor(eagleEyeFeignObjectWrapper);
+		}
+
+		@Bean
+		FescarContextBeanPostProcessor eagleEyeContextBeanPostProcessor(
+				BeanFactory beanFactory) {
+			return new FescarContextBeanPostProcessor(beanFactory);
+		}
+
+		@Bean
+		FescarFeignObjectWrapper eagleEyeFeignObjectWrapper(BeanFactory beanFactory) {
+			return new FescarFeignObjectWrapper(beanFactory);
+		}
+	}
+
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignContext.java

@@ -0,0 +1,67 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alibaba.fescar.feign;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import feign.Client;
+import org.springframework.cloud.openfeign.FeignContext;
+
+/**
+ *
+ * @author xiaojing
+ */
+public class FescarFeignContext extends FeignContext {
+
+	private final FescarFeignObjectWrapper fescarFeignObjectWrapper;
+	private final FeignContext delegate;
+
+	FescarFeignContext(FescarFeignObjectWrapper eagleEyeFeignObjectWrapper,
+			FeignContext delegate) {
+		this.fescarFeignObjectWrapper = eagleEyeFeignObjectWrapper;
+		this.delegate = delegate;
+	}
+
+	@Override
+	public <T> T getInstance(String name, Class<T> type) {
+		T object = this.delegate.getInstance(name, type);
+		if (object instanceof Client) {
+			return object;
+		}
+		return (T) this.fescarFeignObjectWrapper.wrap(object);
+	}
+
+	@Override
+	public <T> Map<String, T> getInstances(String name, Class<T> type) {
+		Map<String, T> instances = this.delegate.getInstances(name, type);
+		if (instances == null) {
+			return null;
+		}
+		Map<String, T> convertedInstances = new HashMap<>();
+		for (Map.Entry<String, T> entry : instances.entrySet()) {
+			if (entry.getValue() instanceof Client) {
+				convertedInstances.put(entry.getKey(), entry.getValue());
+			}
+			else {
+				convertedInstances.put(entry.getKey(),
+						(T) this.fescarFeignObjectWrapper.wrap(entry.getValue()));
+			}
+		}
+		return convertedInstances;
+	}
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignObjectWrapper.java

@@ -0,0 +1,67 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alibaba.fescar.feign;
+
+import org.springframework.beans.factory.BeanFactory;
+import org.springframework.cloud.netflix.ribbon.SpringClientFactory;
+
+import feign.Client;
+import org.springframework.cloud.openfeign.ribbon.CachingSpringLoadBalancerFactory;
+import org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient;
+
+/**
+ * @author xiaojing
+ */
+public class FescarFeignObjectWrapper {
+
+	private final BeanFactory beanFactory;
+
+	private CachingSpringLoadBalancerFactory cachingSpringLoadBalancerFactory;
+	private SpringClientFactory springClientFactory;
+
+	FescarFeignObjectWrapper(BeanFactory beanFactory) {
+		this.beanFactory = beanFactory;
+	}
+
+	Object wrap(Object bean) {
+		if (bean instanceof Client && !(bean instanceof FescarFeignClient)) {
+			if (bean instanceof LoadBalancerFeignClient) {
+				LoadBalancerFeignClient client = ((LoadBalancerFeignClient) bean);
+				return new FescarLoadBalancerFeignClient(client.getDelegate(), factory(),
+						clientFactory(), this.beanFactory);
+			}
+			return new FescarFeignClient(this.beanFactory, (Client) bean);
+		}
+		return bean;
+	}
+
+	CachingSpringLoadBalancerFactory factory() {
+		if (this.cachingSpringLoadBalancerFactory == null) {
+			this.cachingSpringLoadBalancerFactory = this.beanFactory
+					.getBean(CachingSpringLoadBalancerFactory.class);
+		}
+		return this.cachingSpringLoadBalancerFactory;
+	}
+
+	SpringClientFactory clientFactory() {
+		if (this.springClientFactory == null) {
+			this.springClientFactory = this.beanFactory
+					.getBean(SpringClientFactory.class);
+		}
+		return this.springClientFactory;
+	}
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarHystrixFeignBuilder.java

@@ -0,0 +1,37 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alibaba.fescar.feign;
+
+import feign.Retryer;
+import feign.hystrix.HystrixFeign;
+import org.springframework.beans.factory.BeanFactory;
+
+import feign.Feign;
+
+/**
+ * @author xiaojing
+ */
+final class FescarHystrixFeignBuilder {
+
+	private FescarHystrixFeignBuilder() {
+	}
+
+	static Feign.Builder builder(BeanFactory beanFactory) {
+		return HystrixFeign.builder().retryer(Retryer.NEVER_RETRY)
+				.client(new FescarFeignClient(beanFactory));
+	}
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarLoadBalancerFeignClient.java

@@ -0,0 +1,53 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alibaba.fescar.feign;
+
+import java.io.IOException;
+
+import org.springframework.beans.factory.BeanFactory;
+import org.springframework.cloud.netflix.ribbon.SpringClientFactory;
+
+import feign.Client;
+import feign.Request;
+import feign.Response;
+import org.springframework.cloud.openfeign.ribbon.CachingSpringLoadBalancerFactory;
+import org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient;
+
+/**
+ * @author xiaojing
+ */
+public class FescarLoadBalancerFeignClient extends LoadBalancerFeignClient {
+
+	private final BeanFactory beanFactory;
+
+	FescarLoadBalancerFeignClient(Client delegate,
+			CachingSpringLoadBalancerFactory lbClientFactory,
+			SpringClientFactory clientFactory, BeanFactory beanFactory) {
+		super(wrap(delegate, beanFactory), lbClientFactory, clientFactory);
+		this.beanFactory = beanFactory;
+	}
+
+	@Override
+	public Response execute(Request request, Request.Options options) throws IOException {
+		return super.execute(request, options);
+	}
+
+	private static Client wrap(Client delegate, BeanFactory beanFactory) {
+		return (Client) new FescarFeignObjectWrapper(beanFactory).wrap(delegate);
+	}
+
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarSentinelFeignBuilder.java

@@ -0,0 +1,39 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alibaba.fescar.feign;
+
+import org.springframework.beans.factory.BeanFactory;
+
+import feign.Feign;
+import feign.Retryer;
+import feign.hystrix.HystrixFeign;
+import org.springframework.boot.autoconfigure.data.redis.RedisProperties.Sentinel;
+import org.springframework.cloud.alibaba.sentinel.feign.SentinelFeign;
+
+/**
+ * @author xiaojing
+ */
+final class FescarSentinelFeignBuilder {
+
+	private FescarSentinelFeignBuilder() {
+	}
+
+	static Feign.Builder builder(BeanFactory beanFactory) {
+		return SentinelFeign.builder().retryer(Retryer.NEVER_RETRY)
+				.client(new FescarFeignClient(beanFactory));
+	}
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/hystrix/FescarHystrixAutoConfiguration.java

@@ -0,0 +1,37 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.cloud.alibaba.fescar.feign.hystrix;
+
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import com.netflix.hystrix.HystrixCommand;
+
+/**
+ * @author xiaojing
+ */
+
+@Configuration
+@ConditionalOnClass(HystrixCommand.class)
+public class FescarHystrixAutoConfiguration {
+
+	@Bean
+	FescarHystrixConcurrencyStrategy fescarHystrixConcurrencyStrategy() {
+		return new FescarHystrixConcurrencyStrategy();
+	}
+
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/hystrix/FescarHystrixConcurrencyStrategy.java

@@ -0,0 +1,80 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.cloud.alibaba.fescar.feign.hystrix;
+
+import java.util.concurrent.Callable;
+
+import com.alibaba.fescar.core.context.RootContext;
+
+import com.netflix.hystrix.strategy.HystrixPlugins;
+import com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy;
+
+/**
+ * @author xiaojing
+ */
+public class FescarHystrixConcurrencyStrategy extends HystrixConcurrencyStrategy {
+
+	private HystrixConcurrencyStrategy delegate;
+
+	public FescarHystrixConcurrencyStrategy() {
+		this.delegate = HystrixPlugins.getInstance().getConcurrencyStrategy();
+		HystrixPlugins.reset();
+		HystrixPlugins.getInstance().registerConcurrencyStrategy(this);
+	}
+
+	@Override
+	public <K> Callable<K> wrapCallable(Callable<K> c) {
+		if (c instanceof FescarContextCallable) {
+			return c;
+		}
+
+		Callable<K> wrappedCallable;
+		if (this.delegate != null) {
+			wrappedCallable = this.delegate.wrapCallable(c);
+		}
+		else {
+			wrappedCallable = c;
+		}
+		if (wrappedCallable instanceof FescarContextCallable) {
+			return wrappedCallable;
+		}
+
+		return new FescarContextCallable<>(wrappedCallable);
+	}
+
+	private static class FescarContextCallable<K> implements Callable<K> {
+
+		private final Callable<K> actual;
+		private final String xid;
+
+		FescarContextCallable(Callable<K> actual) {
+			this.actual = actual;
+			this.xid = RootContext.getXID();
+		}
+
+		@Override
+		public K call() throws Exception {
+			try {
+				RootContext.bind(xid);
+				return actual.call();
+			}
+			finally {
+				RootContext.unbind();
+			}
+		}
+
+	}
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/rest/FescarRestTemplateAutoConfiguration.java

@@ -0,0 +1,76 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alibaba.fescar.rest;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+
+import javax.annotation.PostConstruct;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.http.client.ClientHttpRequestInterceptor;
+import org.springframework.web.client.RestTemplate;
+
+/**
+ * @author xiaojing
+ */
+
+@Configuration
+public class FescarRestTemplateAutoConfiguration {
+
+	@Bean
+	public FescarRestTemplateInterceptor fescarRestTemplateInterceptor() {
+		return new FescarRestTemplateInterceptor();
+	}
+
+	@Autowired(required = false)
+	private Collection<RestTemplate> restTemplates;
+
+	@Autowired
+	private FescarRestTemplateInterceptor fescarRestTemplateInterceptor;
+
+	@PostConstruct
+	public void init() {
+		if (this.restTemplates != null) {
+			for (RestTemplate restTemplate : restTemplates) {
+				List<ClientHttpRequestInterceptor> interceptors = new ArrayList<ClientHttpRequestInterceptor>(
+						restTemplate.getInterceptors());
+				interceptors.add(this.fescarRestTemplateInterceptor);
+				restTemplate.setInterceptors(interceptors);
+			}
+		}
+	}
+
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/rest/FescarRestTemplateInterceptor.java

@@ -0,0 +1,46 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alibaba.fescar.rest;
+
+import java.io.IOException;
+
+import com.alibaba.fescar.core.context.RootContext;
+
+import org.springframework.http.HttpRequest;
+import org.springframework.http.client.ClientHttpRequestExecution;
+import org.springframework.http.client.ClientHttpRequestInterceptor;
+import org.springframework.http.client.ClientHttpResponse;
+import org.springframework.http.client.support.HttpRequestWrapper;
+import org.springframework.util.StringUtils;
+
+/**
+ * @author xiaojing
+ */
+public class FescarRestTemplateInterceptor implements ClientHttpRequestInterceptor {
+	@Override
+	public ClientHttpResponse intercept(HttpRequest httpRequest, byte[] bytes,
+			ClientHttpRequestExecution clientHttpRequestExecution) throws IOException {
+		HttpRequestWrapper requestWrapper = new HttpRequestWrapper(httpRequest);
+
+		String xid = RootContext.getXID();
+
+		if (!StringUtils.isEmpty(xid)) {
+			requestWrapper.getHeaders().add(RootContext.KEY_XID, xid);
+		}
+		return clientHttpRequestExecution.execute(requestWrapper, bytes);
+	}
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/web/FescarHandlerInterceptor.java

@@ -0,0 +1,85 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alibaba.fescar.web;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+import com.alibaba.fescar.core.context.RootContext;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.util.StringUtils;
+import org.springframework.web.servlet.HandlerInterceptor;
+
+/**
+ * @author xiaojing
+ *
+ * Fescar HandlerInterceptor, Convert Fescar information into
+ * @see com.alibaba.fescar.core.context.RootContext from http request's header in
+ * {@link org.springframework.web.servlet.HandlerInterceptor#preHandle(HttpServletRequest , HttpServletResponse , Object )},
+ * And clean up Fescar information after servlet method invocation in
+ * {@link org.springframework.web.servlet.HandlerInterceptor#afterCompletion(HttpServletRequest, HttpServletResponse, Object, Exception)}
+ */
+public class FescarHandlerInterceptor implements HandlerInterceptor {
+
+	private static final Logger log = LoggerFactory
+			.getLogger(FescarHandlerInterceptor.class);
+
+	@Override
+	public boolean preHandle(HttpServletRequest request, HttpServletResponse response,
+			Object handler) throws Exception {
+
+		String xid = RootContext.getXID();
+		String rpcXid = request.getHeader(RootContext.KEY_XID);
+		if (log.isDebugEnabled()) {
+			log.debug("xid in RootContext {} xid in RpcContext {}", xid, rpcXid);
+		}
+
+		if (xid == null && rpcXid != null) {
+			RootContext.bind(rpcXid);
+			if (log.isDebugEnabled()) {
+				log.debug("bind {} to RootContext", rpcXid);
+			}
+		}
+		return true;
+	}
+
+	@Override
+	public void afterCompletion(HttpServletRequest request, HttpServletResponse response,
+			Object handler, Exception e) throws Exception {
+
+		String rpcXid = request.getHeader(RootContext.KEY_XID);
+
+		if (StringUtils.isEmpty(rpcXid)) {
+			return;
+		}
+
+		String unbindXid = RootContext.unbind();
+		if (log.isDebugEnabled()) {
+			log.debug("unbind {} from RootContext", unbindXid);
+		}
+		if (!rpcXid.equalsIgnoreCase(unbindXid)) {
+			log.warn("xid in change during RPC from {} to {}", rpcXid, unbindXid);
+			if (unbindXid != null) {
+				RootContext.bind(unbindXid);
+				log.warn("bind {} back to RootContext", unbindXid);
+			}
+		}
+	}
+
+}

spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/web/FescarHandlerInterceptorConfiguration.java

@@ -0,0 +1,31 @@
+/*
+ * Copyright (C) 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alibaba.fescar.web;
+
+import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
+import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
+
+/**
+ * @author xiaojing
+ */
+public class FescarHandlerInterceptorConfiguration implements WebMvcConfigurer {
+
+	@Override
+	public void addInterceptors(InterceptorRegistry registry) {
+		registry.addInterceptor(new FescarHandlerInterceptor()).addPathPatterns("/**");
+	}
+}

spring-cloud-alibaba-fescar/src/main/resources/META-INF/spring.factories

@@ -0,0 +1,7 @@
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
+org.springframework.cloud.alibaba.fescar.rest.FescarRestTemplateAutoConfiguration,\
+org.springframework.cloud.alibaba.fescar.web.FescarHandlerInterceptorConfiguration,\
+org.springframework.cloud.alibaba.fescar.GlobalTransactionAutoConfiguration,\
+org.springframework.cloud.alibaba.fescar.feign.FescarFeignClientAutoConfiguration,\
+org.springframework.cloud.alibaba.fescar.feign.hystrix.FescarHystrixAutoConfiguration
+