diff --git a/pom.xml b/pom.xml
index 552e4db6..a0dcba8a 100644
--- a/pom.xml
+++ b/pom.xml
@@ -62,7 +62,7 @@
Alibaba
https://github.com/mercyblitz
-
+
yunzheng
yunzheng1228@gmail.com
@@ -96,7 +96,7 @@
spring-cloud-alibaba-sentinel-zuul
spring-cloud-alibaba-nacos-config
spring-cloud-alibaba-nacos-discovery
- spring-cloud-alibaba-fescar
+ spring-cloud-alibaba-seata
spring-cloud-stream-binder-rocketmq
spring-cloud-alibaba-nacos-config-server
spring-cloud-alibaba-dubbo
diff --git a/spring-cloud-alibaba-coverage/pom.xml b/spring-cloud-alibaba-coverage/pom.xml
index c459d147..f21e056c 100644
--- a/spring-cloud-alibaba-coverage/pom.xml
+++ b/spring-cloud-alibaba-coverage/pom.xml
@@ -63,7 +63,7 @@
org.springframework.cloud
- spring-cloud-alibaba-fescar
+ spring-cloud-alibaba-seata
${spring.cloud.alibaba.version}
diff --git a/spring-cloud-alibaba-dependencies/pom.xml b/spring-cloud-alibaba-dependencies/pom.xml
index 889a1510..d716f57b 100644
--- a/spring-cloud-alibaba-dependencies/pom.xml
+++ b/spring-cloud-alibaba-dependencies/pom.xml
@@ -17,10 +17,10 @@
Spring Cloud Alibaba Dependencies
- 1.4.2
+ 1.5.1
3.1.0
- 0.4.0
- 1.0.0-RC3
+ 0.4.2
+ 1.0.0
0.8.0
1.0.8
1.0.1
@@ -29,8 +29,8 @@
2.16.0
2.0.2
2.1.6
- 2.6.5
- 0.2.1.RELEASE
+ 2.7.1
+ 2.7.1
0.0.2
1.1.0
1.1.8
@@ -167,6 +167,11 @@
sentinel-dubbo-adapter
${sentinel.version}
+
+ com.alibaba.csp
+ sentinel-apache-dubbo-adapter
+ ${sentinel.version}
+
org.springframework.cloud
sentinel-dubbo-api
@@ -194,7 +199,7 @@
- com.alibaba
+ org.apache.dubbo
dubbo
${dubbo.version}
@@ -215,7 +220,7 @@
- com.alibaba.boot
+ org.apache.dubbo
dubbo-spring-boot-starter
${dubbo-spring-boot.version}
@@ -272,7 +277,7 @@
org.springframework.cloud
- spring-cloud-alibaba-fescar
+ spring-cloud-alibaba-seata
${project.version}
@@ -325,7 +330,7 @@
org.springframework.cloud
- spring-cloud-starter-alibaba-fescar
+ spring-cloud-starter-alibaba-seata
${project.version}
diff --git a/spring-cloud-alibaba-dubbo/src/main/java/org/springframework/cloud/alibaba/dubbo/autoconfigure/DubboServiceRegistrationNonWebApplicationAutoConfiguration.java b/spring-cloud-alibaba-dubbo/src/main/java/org/springframework/cloud/alibaba/dubbo/autoconfigure/DubboServiceRegistrationNonWebApplicationAutoConfiguration.java
index 15a5190b..9c6b87cd 100644
--- a/spring-cloud-alibaba-dubbo/src/main/java/org/springframework/cloud/alibaba/dubbo/autoconfigure/DubboServiceRegistrationNonWebApplicationAutoConfiguration.java
+++ b/spring-cloud-alibaba-dubbo/src/main/java/org/springframework/cloud/alibaba/dubbo/autoconfigure/DubboServiceRegistrationNonWebApplicationAutoConfiguration.java
@@ -18,7 +18,6 @@ package org.springframework.cloud.alibaba.dubbo.autoconfigure;
import org.apache.dubbo.common.URL;
import org.apache.dubbo.config.spring.ServiceBean;
-import org.apache.dubbo.config.spring.context.event.ServiceBeanExportedEvent;
import com.ecwid.consul.v1.agent.model.NewService;
import org.aspectj.lang.ProceedingJoinPoint;
@@ -30,6 +29,8 @@ import org.springframework.boot.autoconfigure.AutoConfigureAfter;
import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnNotWebApplication;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.boot.context.event.ApplicationStartedEvent;
+import org.springframework.cloud.alibaba.dubbo.metadata.repository.DubboServiceMetadataRepository;
import org.springframework.cloud.alibaba.dubbo.registry.event.ServiceInstancePreRegisteredEvent;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.serviceregistry.Registration;
@@ -40,7 +41,7 @@ import org.springframework.cloud.zookeeper.serviceregistry.ServiceInstanceRegist
import org.springframework.context.annotation.Configuration;
import org.springframework.context.event.EventListener;
-import java.util.List;
+import java.util.Collection;
import static org.springframework.cloud.alibaba.dubbo.autoconfigure.DubboServiceRegistrationAutoConfiguration.CONSUL_AUTO_CONFIGURATION_CLASS_NAME;
import static org.springframework.cloud.alibaba.dubbo.autoconfigure.DubboServiceRegistrationAutoConfiguration.ZOOKEEPER_AUTO_CONFIGURATION_CLASS_NAME;
@@ -65,18 +66,21 @@ public class DubboServiceRegistrationNonWebApplicationAutoConfiguration {
@Autowired
private Registration registration;
- private volatile Integer webPort = null;
+ private volatile Integer serverPort = null;
private volatile boolean registered = false;
+ @Autowired
+ private DubboServiceMetadataRepository repository;
+
@Around("execution(* org.springframework.cloud.client.serviceregistry.Registration.getPort())")
public Object getPort(ProceedingJoinPoint pjp) throws Throwable {
- return webPort != null ? webPort : pjp.proceed();
+ return serverPort != null ? serverPort : pjp.proceed();
}
- @EventListener(ServiceBeanExportedEvent.class)
- public void onServiceBeanExported(ServiceBeanExportedEvent event) {
- setWebPort(event.getServiceBean());
+ @EventListener(ApplicationStartedEvent.class)
+ public void onApplicationStarted() {
+ setServerPort();
register();
}
@@ -90,18 +94,24 @@ public class DubboServiceRegistrationNonWebApplicationAutoConfiguration {
/**
* Set web port from {@link ServiceBean#getExportedUrls() exported URLs} if "rest" protocol is present.
- *
- * @param serviceBean {@link ServiceBean}
*/
- private void setWebPort(ServiceBean serviceBean) {
- if (webPort == null) {
- List urls = serviceBean.getExportedUrls();
+ private void setServerPort() {
+ if (serverPort == null) {
+ Collection urls = repository.getRegisteredUrls();
urls.stream()
.filter(url -> REST_PROTOCOL.equalsIgnoreCase(url.getProtocol()))
.findFirst()
.ifPresent(url -> {
- webPort = url.getPort();
+ serverPort = url.getPort();
});
+
+ // If REST protocol is not present, use any applied port.
+ if (serverPort == null) {
+ urls.stream()
+ .findAny().ifPresent(url -> {
+ serverPort = url.getPort();
+ });
+ }
}
}
@@ -114,7 +124,7 @@ public class DubboServiceRegistrationNonWebApplicationAutoConfiguration {
@EventListener(ServiceInstancePreRegisteredEvent.class)
public void onServiceInstancePreRegistered(ServiceInstancePreRegisteredEvent event) {
- registration.setPort(webPort);
+ registration.setPort(serverPort);
}
@Override
diff --git a/spring-cloud-alibaba-dubbo/src/main/java/org/springframework/cloud/alibaba/dubbo/metadata/repository/DubboServiceMetadataRepository.java b/spring-cloud-alibaba-dubbo/src/main/java/org/springframework/cloud/alibaba/dubbo/metadata/repository/DubboServiceMetadataRepository.java
index 052dfa63..a1205b58 100644
--- a/spring-cloud-alibaba-dubbo/src/main/java/org/springframework/cloud/alibaba/dubbo/metadata/repository/DubboServiceMetadataRepository.java
+++ b/spring-cloud-alibaba-dubbo/src/main/java/org/springframework/cloud/alibaba/dubbo/metadata/repository/DubboServiceMetadataRepository.java
@@ -37,6 +37,7 @@ import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.http.HttpRequest;
import org.springframework.stereotype.Repository;
import org.springframework.util.CollectionUtils;
+import org.springframework.util.StringUtils;
import javax.annotation.PostConstruct;
import java.util.Collection;
@@ -260,8 +261,10 @@ public class DubboServiceMetadataRepository {
Set metadata = Collections.emptySet();
try {
String serviceRestMetadataJsonConfig = dubboMetadataService.getServiceRestMetadata();
- metadata = objectMapper.readValue(serviceRestMetadataJsonConfig,
- TypeFactory.defaultInstance().constructCollectionType(LinkedHashSet.class, ServiceRestMetadata.class));
+ if(StringUtils.hasText(serviceRestMetadataJsonConfig)) {
+ metadata = objectMapper.readValue(serviceRestMetadataJsonConfig,
+ TypeFactory.defaultInstance().constructCollectionType(LinkedHashSet.class, ServiceRestMetadata.class));
+ }
} catch (Exception e) {
if (logger.isErrorEnabled()) {
logger.error(e.getMessage(), e);
diff --git a/spring-cloud-alibaba-examples/fescar-example/account-service/src/main/resources/registry.conf b/spring-cloud-alibaba-examples/fescar-example/account-service/src/main/resources/registry.conf
deleted file mode 100644
index 8a79c9f2..00000000
--- a/spring-cloud-alibaba-examples/fescar-example/account-service/src/main/resources/registry.conf
+++ /dev/null
@@ -1,35 +0,0 @@
-registry {
- # file 、nacos 、redis
- type = "file"
-
- nacos {
- serverAddr = "localhost"
- namespace = "public"
- cluster = "default"
- }
- redis {
- serverAddr = "localhost:6379"
- db = "0"
- }
- file {
- name = "file.conf"
- }
-}
-
-config {
- # file nacos apollo
- type = "file"
-
- nacos {
- serverAddr = "localhost"
- namespace = "public"
- cluster = "default"
- }
- apollo {
- app.id = "fescar-server"
- apollo.meta = "http://192.168.1.204:8801"
- }
- file {
- name = "file.conf"
- }
-}
\ No newline at end of file
diff --git a/spring-cloud-alibaba-examples/fescar-example/business-service/src/main/resources/registry.conf b/spring-cloud-alibaba-examples/fescar-example/business-service/src/main/resources/registry.conf
deleted file mode 100644
index 8a79c9f2..00000000
--- a/spring-cloud-alibaba-examples/fescar-example/business-service/src/main/resources/registry.conf
+++ /dev/null
@@ -1,35 +0,0 @@
-registry {
- # file 、nacos 、redis
- type = "file"
-
- nacos {
- serverAddr = "localhost"
- namespace = "public"
- cluster = "default"
- }
- redis {
- serverAddr = "localhost:6379"
- db = "0"
- }
- file {
- name = "file.conf"
- }
-}
-
-config {
- # file nacos apollo
- type = "file"
-
- nacos {
- serverAddr = "localhost"
- namespace = "public"
- cluster = "default"
- }
- apollo {
- app.id = "fescar-server"
- apollo.meta = "http://192.168.1.204:8801"
- }
- file {
- name = "file.conf"
- }
-}
\ No newline at end of file
diff --git a/spring-cloud-alibaba-examples/fescar-example/order-service/src/main/resources/registry.conf b/spring-cloud-alibaba-examples/fescar-example/order-service/src/main/resources/registry.conf
deleted file mode 100644
index 8a79c9f2..00000000
--- a/spring-cloud-alibaba-examples/fescar-example/order-service/src/main/resources/registry.conf
+++ /dev/null
@@ -1,35 +0,0 @@
-registry {
- # file 、nacos 、redis
- type = "file"
-
- nacos {
- serverAddr = "localhost"
- namespace = "public"
- cluster = "default"
- }
- redis {
- serverAddr = "localhost:6379"
- db = "0"
- }
- file {
- name = "file.conf"
- }
-}
-
-config {
- # file nacos apollo
- type = "file"
-
- nacos {
- serverAddr = "localhost"
- namespace = "public"
- cluster = "default"
- }
- apollo {
- app.id = "fescar-server"
- apollo.meta = "http://192.168.1.204:8801"
- }
- file {
- name = "file.conf"
- }
-}
\ No newline at end of file
diff --git a/spring-cloud-alibaba-examples/fescar-example/storage-service/src/main/resources/registry.conf b/spring-cloud-alibaba-examples/fescar-example/storage-service/src/main/resources/registry.conf
deleted file mode 100644
index 8a79c9f2..00000000
--- a/spring-cloud-alibaba-examples/fescar-example/storage-service/src/main/resources/registry.conf
+++ /dev/null
@@ -1,35 +0,0 @@
-registry {
- # file 、nacos 、redis
- type = "file"
-
- nacos {
- serverAddr = "localhost"
- namespace = "public"
- cluster = "default"
- }
- redis {
- serverAddr = "localhost:6379"
- db = "0"
- }
- file {
- name = "file.conf"
- }
-}
-
-config {
- # file nacos apollo
- type = "file"
-
- nacos {
- serverAddr = "localhost"
- namespace = "public"
- cluster = "default"
- }
- apollo {
- app.id = "fescar-server"
- apollo.meta = "http://192.168.1.204:8801"
- }
- file {
- name = "file.conf"
- }
-}
\ No newline at end of file
diff --git a/spring-cloud-alibaba-examples/pom.xml b/spring-cloud-alibaba-examples/pom.xml
index c82e51d5..11a8cb3f 100644
--- a/spring-cloud-alibaba-examples/pom.xml
+++ b/spring-cloud-alibaba-examples/pom.xml
@@ -28,10 +28,10 @@
ans-example/ans-consumer-feign-example
ans-example/ans-consumer-ribbon-example
ans-example/ans-provider-example
- fescar-example/business-service
- fescar-example/order-service
- fescar-example/storage-service
- fescar-example/account-service
+ seata-example/business-service
+ seata-example/order-service
+ seata-example/storage-service
+ seata-example/account-service
acm-example/acm-local-example
rocketmq-example/rocketmq-consume-example
rocketmq-example/rocketmq-produce-example
diff --git a/spring-cloud-alibaba-examples/fescar-example/account-service/pom.xml b/spring-cloud-alibaba-examples/seata-example/account-service/pom.xml
similarity index 94%
rename from spring-cloud-alibaba-examples/fescar-example/account-service/pom.xml
rename to spring-cloud-alibaba-examples/seata-example/account-service/pom.xml
index 5ffd2699..574895ce 100644
--- a/spring-cloud-alibaba-examples/fescar-example/account-service/pom.xml
+++ b/spring-cloud-alibaba-examples/seata-example/account-service/pom.xml
@@ -14,7 +14,7 @@
org.springframework.cloud
- spring-cloud-starter-alibaba-fescar
+ spring-cloud-starter-alibaba-seata
org.springframework.boot
diff --git a/spring-cloud-alibaba-examples/fescar-example/account-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/AccountApplication.java b/spring-cloud-alibaba-examples/seata-example/account-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/AccountApplication.java
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/account-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/AccountApplication.java
rename to spring-cloud-alibaba-examples/seata-example/account-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/AccountApplication.java
diff --git a/spring-cloud-alibaba-examples/fescar-example/account-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/AccountController.java b/spring-cloud-alibaba-examples/seata-example/account-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/AccountController.java
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/account-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/AccountController.java
rename to spring-cloud-alibaba-examples/seata-example/account-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/AccountController.java
diff --git a/spring-cloud-alibaba-examples/fescar-example/account-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/DatabaseConfiguration.java b/spring-cloud-alibaba-examples/seata-example/account-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/DatabaseConfiguration.java
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/account-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/DatabaseConfiguration.java
rename to spring-cloud-alibaba-examples/seata-example/account-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/DatabaseConfiguration.java
diff --git a/spring-cloud-alibaba-examples/fescar-example/account-service/src/main/resources/application.properties b/spring-cloud-alibaba-examples/seata-example/account-service/src/main/resources/application.properties
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/account-service/src/main/resources/application.properties
rename to spring-cloud-alibaba-examples/seata-example/account-service/src/main/resources/application.properties
diff --git a/spring-cloud-alibaba-examples/fescar-example/account-service/src/main/resources/file.conf b/spring-cloud-alibaba-examples/seata-example/account-service/src/main/resources/file.conf
similarity index 64%
rename from spring-cloud-alibaba-examples/fescar-example/account-service/src/main/resources/file.conf
rename to spring-cloud-alibaba-examples/seata-example/account-service/src/main/resources/file.conf
index 857b089e..b49739a1 100644
--- a/spring-cloud-alibaba-examples/fescar-example/account-service/src/main/resources/file.conf
+++ b/spring-cloud-alibaba-examples/seata-example/account-service/src/main/resources/file.conf
@@ -20,17 +20,26 @@ transport {
worker-thread-size = 8
}
}
+store {
+ # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions
+ max-branch-session-size = 16384
+ # globe session size , if exceeded throws exceptions
+ max-global-session-size = 512
+ # file buffer size , if exceeded allocate new buffer
+ file-write-buffer-cache-size = 16384
+ # when recover batch read size
+ session.reload.read_size = 100
+}
service {
#vgroup->rgroup
- vgroup_mapping.account-service-fescar-service-group = "localRgroup"
+ vgroup_mapping.account-service-fescar-service-group = "default"
#only support single node
- localRgroup.grouplist = "127.0.0.1:8091"
+ default.grouplist = "127.0.0.1:8091"
#degrade current not support
enableDegrade = false
#disable
disable = false
}
-
client {
async.commit.buffer.limit = 10000
lock {
diff --git a/spring-cloud-alibaba-examples/seata-example/account-service/src/main/resources/registry.conf b/spring-cloud-alibaba-examples/seata-example/account-service/src/main/resources/registry.conf
new file mode 100644
index 00000000..31bcace5
--- /dev/null
+++ b/spring-cloud-alibaba-examples/seata-example/account-service/src/main/resources/registry.conf
@@ -0,0 +1,55 @@
+registry {
+ # file 、nacos 、eureka、redis、zk、consul
+ type = "file"
+
+ nacos {
+ serverAddr = "localhost"
+ namespace = "public"
+ cluster = "default"
+ }
+ eureka {
+ serviceUrl = "http://localhost:1001/eureka"
+ application = "default"
+ weight = "1"
+ }
+ redis {
+ serverAddr = "localhost:6379"
+ db = "0"
+ }
+ zk {
+ cluster = "default"
+ serverAddr = "127.0.0.1:2181"
+ session.timeout = 6000
+ connect.timeout = 2000
+ }
+ consul {
+ cluster = "default"
+ serverAddr = "127.0.0.1:8500"
+ }
+ file {
+ name = "file.conf"
+ }
+}
+
+config {
+ # file、nacos 、apollo、zk
+ type = "file"
+
+ nacos {
+ serverAddr = "localhost"
+ namespace = "public"
+ cluster = "default"
+ }
+ apollo {
+ app.id = "fescar-server"
+ apollo.meta = "http://192.168.1.204:8801"
+ }
+ zk {
+ serverAddr = "127.0.0.1:2181"
+ session.timeout = 6000
+ connect.timeout = 2000
+ }
+ file {
+ name = "file.conf"
+ }
+}
diff --git a/spring-cloud-alibaba-examples/fescar-example/business-service/pom.xml b/spring-cloud-alibaba-examples/seata-example/business-service/pom.xml
similarity index 95%
rename from spring-cloud-alibaba-examples/fescar-example/business-service/pom.xml
rename to spring-cloud-alibaba-examples/seata-example/business-service/pom.xml
index 1758d6ec..f396fdf9 100644
--- a/spring-cloud-alibaba-examples/fescar-example/business-service/pom.xml
+++ b/spring-cloud-alibaba-examples/seata-example/business-service/pom.xml
@@ -14,7 +14,7 @@
org.springframework.cloud
- spring-cloud-starter-alibaba-fescar
+ spring-cloud-starter-alibaba-seata
org.springframework.cloud
diff --git a/spring-cloud-alibaba-examples/fescar-example/business-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/BusinessApplication.java b/spring-cloud-alibaba-examples/seata-example/business-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/BusinessApplication.java
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/business-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/BusinessApplication.java
rename to spring-cloud-alibaba-examples/seata-example/business-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/BusinessApplication.java
diff --git a/spring-cloud-alibaba-examples/fescar-example/business-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/HomeController.java b/spring-cloud-alibaba-examples/seata-example/business-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/HomeController.java
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/business-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/HomeController.java
rename to spring-cloud-alibaba-examples/seata-example/business-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/HomeController.java
diff --git a/spring-cloud-alibaba-examples/fescar-example/business-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/Order.java b/spring-cloud-alibaba-examples/seata-example/business-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/Order.java
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/business-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/Order.java
rename to spring-cloud-alibaba-examples/seata-example/business-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/Order.java
diff --git a/spring-cloud-alibaba-examples/fescar-example/business-service/src/main/resources/application.properties b/spring-cloud-alibaba-examples/seata-example/business-service/src/main/resources/application.properties
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/business-service/src/main/resources/application.properties
rename to spring-cloud-alibaba-examples/seata-example/business-service/src/main/resources/application.properties
diff --git a/spring-cloud-alibaba-examples/fescar-example/storage-service/src/main/resources/file.conf b/spring-cloud-alibaba-examples/seata-example/business-service/src/main/resources/file.conf
similarity index 64%
rename from spring-cloud-alibaba-examples/fescar-example/storage-service/src/main/resources/file.conf
rename to spring-cloud-alibaba-examples/seata-example/business-service/src/main/resources/file.conf
index 29c81842..39beec98 100644
--- a/spring-cloud-alibaba-examples/fescar-example/storage-service/src/main/resources/file.conf
+++ b/spring-cloud-alibaba-examples/seata-example/business-service/src/main/resources/file.conf
@@ -20,17 +20,26 @@ transport {
worker-thread-size = 8
}
}
+store {
+ # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions
+ max-branch-session-size = 16384
+ # globe session size , if exceeded throws exceptions
+ max-global-session-size = 512
+ # file buffer size , if exceeded allocate new buffer
+ file-write-buffer-cache-size = 16384
+ # when recover batch read size
+ session.reload.read_size = 100
+}
service {
#vgroup->rgroup
- vgroup_mapping.storage-service-fescar-service-group = "localRgroup"
+ vgroup_mapping.business-service-fescar-service-group = "default"
#only support single node
- localRgroup.grouplist = "127.0.0.1:8091"
+ default.grouplist = "127.0.0.1:8091"
#degrade current not support
enableDegrade = false
#disable
disable = false
}
-
client {
async.commit.buffer.limit = 10000
lock {
diff --git a/spring-cloud-alibaba-examples/seata-example/business-service/src/main/resources/registry.conf b/spring-cloud-alibaba-examples/seata-example/business-service/src/main/resources/registry.conf
new file mode 100644
index 00000000..31bcace5
--- /dev/null
+++ b/spring-cloud-alibaba-examples/seata-example/business-service/src/main/resources/registry.conf
@@ -0,0 +1,55 @@
+registry {
+ # file 、nacos 、eureka、redis、zk、consul
+ type = "file"
+
+ nacos {
+ serverAddr = "localhost"
+ namespace = "public"
+ cluster = "default"
+ }
+ eureka {
+ serviceUrl = "http://localhost:1001/eureka"
+ application = "default"
+ weight = "1"
+ }
+ redis {
+ serverAddr = "localhost:6379"
+ db = "0"
+ }
+ zk {
+ cluster = "default"
+ serverAddr = "127.0.0.1:2181"
+ session.timeout = 6000
+ connect.timeout = 2000
+ }
+ consul {
+ cluster = "default"
+ serverAddr = "127.0.0.1:8500"
+ }
+ file {
+ name = "file.conf"
+ }
+}
+
+config {
+ # file、nacos 、apollo、zk
+ type = "file"
+
+ nacos {
+ serverAddr = "localhost"
+ namespace = "public"
+ cluster = "default"
+ }
+ apollo {
+ app.id = "fescar-server"
+ apollo.meta = "http://192.168.1.204:8801"
+ }
+ zk {
+ serverAddr = "127.0.0.1:2181"
+ session.timeout = 6000
+ connect.timeout = 2000
+ }
+ file {
+ name = "file.conf"
+ }
+}
diff --git a/spring-cloud-alibaba-examples/fescar-example/order-service/pom.xml b/spring-cloud-alibaba-examples/seata-example/order-service/pom.xml
similarity index 94%
rename from spring-cloud-alibaba-examples/fescar-example/order-service/pom.xml
rename to spring-cloud-alibaba-examples/seata-example/order-service/pom.xml
index d9041e87..53b94a65 100644
--- a/spring-cloud-alibaba-examples/fescar-example/order-service/pom.xml
+++ b/spring-cloud-alibaba-examples/seata-example/order-service/pom.xml
@@ -14,7 +14,7 @@
org.springframework.cloud
- spring-cloud-starter-alibaba-fescar
+ spring-cloud-starter-alibaba-seata
org.springframework.boot
diff --git a/spring-cloud-alibaba-examples/fescar-example/order-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/DatabaseConfiguration.java b/spring-cloud-alibaba-examples/seata-example/order-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/DatabaseConfiguration.java
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/order-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/DatabaseConfiguration.java
rename to spring-cloud-alibaba-examples/seata-example/order-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/DatabaseConfiguration.java
diff --git a/spring-cloud-alibaba-examples/fescar-example/order-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/OderApplication.java b/spring-cloud-alibaba-examples/seata-example/order-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/OderApplication.java
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/order-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/OderApplication.java
rename to spring-cloud-alibaba-examples/seata-example/order-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/OderApplication.java
diff --git a/spring-cloud-alibaba-examples/fescar-example/order-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/Order.java b/spring-cloud-alibaba-examples/seata-example/order-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/Order.java
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/order-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/Order.java
rename to spring-cloud-alibaba-examples/seata-example/order-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/Order.java
diff --git a/spring-cloud-alibaba-examples/fescar-example/order-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/OrderController.java b/spring-cloud-alibaba-examples/seata-example/order-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/OrderController.java
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/order-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/OrderController.java
rename to spring-cloud-alibaba-examples/seata-example/order-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/OrderController.java
diff --git a/spring-cloud-alibaba-examples/fescar-example/order-service/src/main/resources/application.properties b/spring-cloud-alibaba-examples/seata-example/order-service/src/main/resources/application.properties
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/order-service/src/main/resources/application.properties
rename to spring-cloud-alibaba-examples/seata-example/order-service/src/main/resources/application.properties
diff --git a/spring-cloud-alibaba-examples/fescar-example/business-service/src/main/resources/file.conf b/spring-cloud-alibaba-examples/seata-example/order-service/src/main/resources/file.conf
similarity index 64%
rename from spring-cloud-alibaba-examples/fescar-example/business-service/src/main/resources/file.conf
rename to spring-cloud-alibaba-examples/seata-example/order-service/src/main/resources/file.conf
index b087a18c..2ef4f39a 100644
--- a/spring-cloud-alibaba-examples/fescar-example/business-service/src/main/resources/file.conf
+++ b/spring-cloud-alibaba-examples/seata-example/order-service/src/main/resources/file.conf
@@ -20,17 +20,26 @@ transport {
worker-thread-size = 8
}
}
+store {
+ # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions
+ max-branch-session-size = 16384
+ # globe session size , if exceeded throws exceptions
+ max-global-session-size = 512
+ # file buffer size , if exceeded allocate new buffer
+ file-write-buffer-cache-size = 16384
+ # when recover batch read size
+ session.reload.read_size = 100
+}
service {
#vgroup->rgroup
- vgroup_mapping.business-service-fescar-service-group = "localRgroup"
+ vgroup_mapping.order-service-fescar-service-group = "default"
#only support single node
- localRgroup.grouplist = "127.0.0.1:8091"
+ default.grouplist = "127.0.0.1:8091"
#degrade current not support
enableDegrade = false
#disable
disable = false
}
-
client {
async.commit.buffer.limit = 10000
lock {
diff --git a/spring-cloud-alibaba-examples/seata-example/order-service/src/main/resources/registry.conf b/spring-cloud-alibaba-examples/seata-example/order-service/src/main/resources/registry.conf
new file mode 100644
index 00000000..31bcace5
--- /dev/null
+++ b/spring-cloud-alibaba-examples/seata-example/order-service/src/main/resources/registry.conf
@@ -0,0 +1,55 @@
+registry {
+ # file 、nacos 、eureka、redis、zk、consul
+ type = "file"
+
+ nacos {
+ serverAddr = "localhost"
+ namespace = "public"
+ cluster = "default"
+ }
+ eureka {
+ serviceUrl = "http://localhost:1001/eureka"
+ application = "default"
+ weight = "1"
+ }
+ redis {
+ serverAddr = "localhost:6379"
+ db = "0"
+ }
+ zk {
+ cluster = "default"
+ serverAddr = "127.0.0.1:2181"
+ session.timeout = 6000
+ connect.timeout = 2000
+ }
+ consul {
+ cluster = "default"
+ serverAddr = "127.0.0.1:8500"
+ }
+ file {
+ name = "file.conf"
+ }
+}
+
+config {
+ # file、nacos 、apollo、zk
+ type = "file"
+
+ nacos {
+ serverAddr = "localhost"
+ namespace = "public"
+ cluster = "default"
+ }
+ apollo {
+ app.id = "fescar-server"
+ apollo.meta = "http://192.168.1.204:8801"
+ }
+ zk {
+ serverAddr = "127.0.0.1:2181"
+ session.timeout = 6000
+ connect.timeout = 2000
+ }
+ file {
+ name = "file.conf"
+ }
+}
diff --git a/spring-cloud-alibaba-examples/fescar-example/readme-zh.md b/spring-cloud-alibaba-examples/seata-example/readme-zh.md
similarity index 94%
rename from spring-cloud-alibaba-examples/fescar-example/readme-zh.md
rename to spring-cloud-alibaba-examples/seata-example/readme-zh.md
index d10ecbf2..6c1b6747 100644
--- a/spring-cloud-alibaba-examples/fescar-example/readme-zh.md
+++ b/spring-cloud-alibaba-examples/seata-example/readme-zh.md
@@ -1,11 +1,11 @@
-# Fescar Example
+# Seata Example
## 项目说明
-本项目演示如何使用 Fescar Starter 完成 Spring Cloud 应用的分布式事务接入。
+本项目演示如何使用 Seata Starter 完成 Spring Cloud 应用的分布式事务接入。
-[Fescar](https://github.com/alibaba/fescar) 是 阿里巴巴 开源的 分布式事务中间件,以 高效 并且对业务 0 侵入 的方式,解决 微服务 场景下面临的分布式事务问题。
+[Seata](https://github.com/seata/seata) 是 阿里巴巴 开源的 分布式事务中间件,以 高效 并且对业务 0 侵入 的方式,解决 微服务 场景下面临的分布式事务问题。
diff --git a/spring-cloud-alibaba-examples/fescar-example/storage-service/pom.xml b/spring-cloud-alibaba-examples/seata-example/storage-service/pom.xml
similarity index 95%
rename from spring-cloud-alibaba-examples/fescar-example/storage-service/pom.xml
rename to spring-cloud-alibaba-examples/seata-example/storage-service/pom.xml
index 15a8bdde..f5f7ad45 100644
--- a/spring-cloud-alibaba-examples/fescar-example/storage-service/pom.xml
+++ b/spring-cloud-alibaba-examples/seata-example/storage-service/pom.xml
@@ -14,7 +14,7 @@
org.springframework.cloud
- spring-cloud-starter-alibaba-fescar
+ spring-cloud-starter-alibaba-seata
org.springframework.boot
diff --git a/spring-cloud-alibaba-examples/fescar-example/storage-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/DatabaseConfiguration.java b/spring-cloud-alibaba-examples/seata-example/storage-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/DatabaseConfiguration.java
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/storage-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/DatabaseConfiguration.java
rename to spring-cloud-alibaba-examples/seata-example/storage-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/DatabaseConfiguration.java
diff --git a/spring-cloud-alibaba-examples/fescar-example/storage-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/StorageApplication.java b/spring-cloud-alibaba-examples/seata-example/storage-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/StorageApplication.java
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/storage-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/StorageApplication.java
rename to spring-cloud-alibaba-examples/seata-example/storage-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/StorageApplication.java
diff --git a/spring-cloud-alibaba-examples/fescar-example/storage-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/StorageController.java b/spring-cloud-alibaba-examples/seata-example/storage-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/StorageController.java
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/storage-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/StorageController.java
rename to spring-cloud-alibaba-examples/seata-example/storage-service/src/main/java/org/springframework/cloud/alibaba/cloud/examples/StorageController.java
diff --git a/spring-cloud-alibaba-examples/fescar-example/storage-service/src/main/resources/application.properties b/spring-cloud-alibaba-examples/seata-example/storage-service/src/main/resources/application.properties
similarity index 100%
rename from spring-cloud-alibaba-examples/fescar-example/storage-service/src/main/resources/application.properties
rename to spring-cloud-alibaba-examples/seata-example/storage-service/src/main/resources/application.properties
diff --git a/spring-cloud-alibaba-examples/fescar-example/order-service/src/main/resources/file.conf b/spring-cloud-alibaba-examples/seata-example/storage-service/src/main/resources/file.conf
similarity index 64%
rename from spring-cloud-alibaba-examples/fescar-example/order-service/src/main/resources/file.conf
rename to spring-cloud-alibaba-examples/seata-example/storage-service/src/main/resources/file.conf
index 4f893da5..6c1bebbb 100644
--- a/spring-cloud-alibaba-examples/fescar-example/order-service/src/main/resources/file.conf
+++ b/spring-cloud-alibaba-examples/seata-example/storage-service/src/main/resources/file.conf
@@ -20,17 +20,26 @@ transport {
worker-thread-size = 8
}
}
+store {
+ # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions
+ max-branch-session-size = 16384
+ # globe session size , if exceeded throws exceptions
+ max-global-session-size = 512
+ # file buffer size , if exceeded allocate new buffer
+ file-write-buffer-cache-size = 16384
+ # when recover batch read size
+ session.reload.read_size = 100
+}
service {
#vgroup->rgroup
- vgroup_mapping.order-service-fescar-service-group = "localRgroup"
+ vgroup_mapping.storage-service-fescar-service-group = "default"
#only support single node
- localRgroup.grouplist = "127.0.0.1:8091"
+ default.grouplist = "127.0.0.1:8091"
#degrade current not support
enableDegrade = false
#disable
disable = false
}
-
client {
async.commit.buffer.limit = 10000
lock {
diff --git a/spring-cloud-alibaba-examples/seata-example/storage-service/src/main/resources/registry.conf b/spring-cloud-alibaba-examples/seata-example/storage-service/src/main/resources/registry.conf
new file mode 100644
index 00000000..31bcace5
--- /dev/null
+++ b/spring-cloud-alibaba-examples/seata-example/storage-service/src/main/resources/registry.conf
@@ -0,0 +1,55 @@
+registry {
+ # file 、nacos 、eureka、redis、zk、consul
+ type = "file"
+
+ nacos {
+ serverAddr = "localhost"
+ namespace = "public"
+ cluster = "default"
+ }
+ eureka {
+ serviceUrl = "http://localhost:1001/eureka"
+ application = "default"
+ weight = "1"
+ }
+ redis {
+ serverAddr = "localhost:6379"
+ db = "0"
+ }
+ zk {
+ cluster = "default"
+ serverAddr = "127.0.0.1:2181"
+ session.timeout = 6000
+ connect.timeout = 2000
+ }
+ consul {
+ cluster = "default"
+ serverAddr = "127.0.0.1:8500"
+ }
+ file {
+ name = "file.conf"
+ }
+}
+
+config {
+ # file、nacos 、apollo、zk
+ type = "file"
+
+ nacos {
+ serverAddr = "localhost"
+ namespace = "public"
+ cluster = "default"
+ }
+ apollo {
+ app.id = "fescar-server"
+ apollo.meta = "http://192.168.1.204:8801"
+ }
+ zk {
+ serverAddr = "127.0.0.1:2181"
+ session.timeout = 6000
+ connect.timeout = 2000
+ }
+ file {
+ name = "file.conf"
+ }
+}
diff --git a/spring-cloud-alibaba-examples/sentinel-example/sentinel-dubbo-example/sentinel-dubbo-consumer-example/pom.xml b/spring-cloud-alibaba-examples/sentinel-example/sentinel-dubbo-example/sentinel-dubbo-consumer-example/pom.xml
index 88a4c663..a587640d 100644
--- a/spring-cloud-alibaba-examples/sentinel-example/sentinel-dubbo-example/sentinel-dubbo-consumer-example/pom.xml
+++ b/spring-cloud-alibaba-examples/sentinel-example/sentinel-dubbo-example/sentinel-dubbo-consumer-example/pom.xml
@@ -28,12 +28,17 @@
- com.alibaba.boot
+ com.alibaba.csp
+ sentinel-apache-dubbo-adapter
+
+
+
+ org.apache.dubbo
dubbo-spring-boot-starter
- com.alibaba
+ org.apache.dubbo
dubbo
diff --git a/spring-cloud-alibaba-examples/sentinel-example/sentinel-dubbo-example/sentinel-dubbo-consumer-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/FooServiceConsumer.java b/spring-cloud-alibaba-examples/sentinel-example/sentinel-dubbo-example/sentinel-dubbo-consumer-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/FooServiceConsumer.java
index 0caae729..705ddbc5 100644
--- a/spring-cloud-alibaba-examples/sentinel-example/sentinel-dubbo-example/sentinel-dubbo-consumer-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/FooServiceConsumer.java
+++ b/spring-cloud-alibaba-examples/sentinel-example/sentinel-dubbo-example/sentinel-dubbo-consumer-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/FooServiceConsumer.java
@@ -1,14 +1,13 @@
package org.springframework.cloud.alibaba.cloud.examples;
-import com.alibaba.dubbo.config.annotation.Reference;
+import org.apache.dubbo.config.annotation.Reference;
/**
* @author fangjian
*/
public class FooServiceConsumer {
- @Reference(version = "${foo.service.version}", application = "${dubbo.application.id}",
- url = "dubbo://localhost:12345", timeout = 30000)
+ @Reference(version = "${foo.service.version}", application = "${dubbo.application.id}", url = "dubbo://localhost:12345", timeout = 30000)
private FooService fooService;
public String hello(String name) {
diff --git a/spring-cloud-alibaba-examples/sentinel-example/sentinel-dubbo-example/sentinel-dubbo-provider-example/pom.xml b/spring-cloud-alibaba-examples/sentinel-example/sentinel-dubbo-example/sentinel-dubbo-provider-example/pom.xml
index d9c20878..8cce2fdf 100644
--- a/spring-cloud-alibaba-examples/sentinel-example/sentinel-dubbo-example/sentinel-dubbo-provider-example/pom.xml
+++ b/spring-cloud-alibaba-examples/sentinel-example/sentinel-dubbo-example/sentinel-dubbo-provider-example/pom.xml
@@ -21,18 +21,24 @@
org.springframework.cloud
spring-cloud-starter-alibaba-sentinel
+
org.springframework.cloud
sentinel-dubbo-api
- com.alibaba.boot
+ com.alibaba.csp
+ sentinel-apache-dubbo-adapter
+
+
+
+ org.apache.dubbo
dubbo-spring-boot-starter
- com.alibaba
+ org.apache.dubbo
dubbo
diff --git a/spring-cloud-alibaba-examples/sentinel-example/sentinel-dubbo-example/sentinel-dubbo-provider-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/FooServiceImpl.java b/spring-cloud-alibaba-examples/sentinel-example/sentinel-dubbo-example/sentinel-dubbo-provider-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/FooServiceImpl.java
index 11dd2263..857b31bc 100644
--- a/spring-cloud-alibaba-examples/sentinel-example/sentinel-dubbo-example/sentinel-dubbo-provider-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/FooServiceImpl.java
+++ b/spring-cloud-alibaba-examples/sentinel-example/sentinel-dubbo-example/sentinel-dubbo-provider-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/FooServiceImpl.java
@@ -1,20 +1,15 @@
package org.springframework.cloud.alibaba.cloud.examples;
-import com.alibaba.dubbo.config.annotation.Service;
+import org.apache.dubbo.config.annotation.Service;
/**
* @author fangjian
*/
-@Service(
- version = "${foo.service.version}",
- application = "${dubbo.application.id}",
- protocol = "${dubbo.protocol.id}",
- registry = "${dubbo.registry.id}"
-)
+@Service(version = "${foo.service.version}", application = "${dubbo.application.id}", protocol = "${dubbo.protocol.id}", registry = "${dubbo.registry.id}")
public class FooServiceImpl implements FooService {
- @Override
- public String hello(String name) {
- return "hello, " + name;
- }
+ @Override
+ public String hello(String name) {
+ return "hello, " + name;
+ }
}
\ No newline at end of file
diff --git a/spring-cloud-alibaba-examples/spring-cloud-alibaba-dubbo-examples/spring-cloud-dubbo-consumer-sample/src/main/java/org/springframework/cloud/alibaba/dubbo/bootstrap/DubboSpringCloudConsumerBootstrap.java b/spring-cloud-alibaba-examples/spring-cloud-alibaba-dubbo-examples/spring-cloud-dubbo-consumer-sample/src/main/java/org/springframework/cloud/alibaba/dubbo/bootstrap/DubboSpringCloudConsumerBootstrap.java
index 45484000..0fb73298 100644
--- a/spring-cloud-alibaba-examples/spring-cloud-alibaba-dubbo-examples/spring-cloud-dubbo-consumer-sample/src/main/java/org/springframework/cloud/alibaba/dubbo/bootstrap/DubboSpringCloudConsumerBootstrap.java
+++ b/spring-cloud-alibaba-examples/spring-cloud-alibaba-dubbo-examples/spring-cloud-dubbo-consumer-sample/src/main/java/org/springframework/cloud/alibaba/dubbo/bootstrap/DubboSpringCloudConsumerBootstrap.java
@@ -26,6 +26,7 @@ import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.cloud.alibaba.dubbo.annotation.DubboTransported;
import org.springframework.cloud.alibaba.dubbo.service.RestService;
import org.springframework.cloud.alibaba.dubbo.service.User;
+import org.springframework.cloud.alibaba.dubbo.service.UserService;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.openfeign.EnableFeignClients;
@@ -53,6 +54,9 @@ import static org.springframework.http.MediaType.APPLICATION_JSON_UTF8_VALUE;
@EnableFeignClients
public class DubboSpringCloudConsumerBootstrap {
+ @Reference
+ private UserService userService;
+
@Reference(version = "1.0.0", protocol = "dubbo")
private RestService restService;
@@ -119,7 +123,28 @@ public class DubboSpringCloudConsumerBootstrap {
}
@Bean
- public ApplicationRunner paramRunner() {
+ public ApplicationRunner userServiceRunner() {
+ return arguments -> {
+
+ User user = new User();
+ user.setId(1L);
+ user.setName("小马哥");
+ user.setAge(33);
+
+ // save User
+ System.out.printf("UserService.save(%s) : %s\n", user, userService.save(user));
+
+ // find all Users
+ System.out.printf("UserService.findAll() : %s\n", user, userService.findAll());
+
+ // remove User
+ System.out.printf("UserService.remove(%d) : %s\n", user.getId(), userService.remove(user.getId()));
+
+ };
+ }
+
+ @Bean
+ public ApplicationRunner callRunner() {
return arguments -> {
// To call /path-variables
diff --git a/spring-cloud-alibaba-examples/spring-cloud-alibaba-dubbo-examples/spring-cloud-dubbo-provider-sample/src/main/java/org/springframework/cloud/alibaba/dubbo/service/InMemoryUserService.java b/spring-cloud-alibaba-examples/spring-cloud-alibaba-dubbo-examples/spring-cloud-dubbo-provider-sample/src/main/java/org/springframework/cloud/alibaba/dubbo/service/InMemoryUserService.java
new file mode 100644
index 00000000..cd1aa8b3
--- /dev/null
+++ b/spring-cloud-alibaba-examples/spring-cloud-alibaba-dubbo-examples/spring-cloud-dubbo-provider-sample/src/main/java/org/springframework/cloud/alibaba/dubbo/service/InMemoryUserService.java
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.dubbo.service;
+
+import org.apache.dubbo.config.annotation.Service;
+
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * In-Memory {@link UserService} implementation
+ */
+@Service(protocol = "dubbo")
+public class InMemoryUserService implements UserService {
+
+ private Map usersRepository = new HashMap<>();
+
+ @Override
+ public boolean save(User user) {
+ return usersRepository.put(user.getId(), user) == null;
+ }
+
+ @Override
+ public boolean remove(Long userId) {
+ return usersRepository.remove(userId) != null;
+ }
+
+ @Override
+ public Collection findAll() {
+ return usersRepository.values();
+ }
+}
diff --git a/spring-cloud-alibaba-examples/spring-cloud-alibaba-dubbo-examples/spring-cloud-dubbo-provider-web-sample/src/main/java/org/springframework/cloud/alibaba/dubbo/service/InMemoryUserService.java b/spring-cloud-alibaba-examples/spring-cloud-alibaba-dubbo-examples/spring-cloud-dubbo-provider-web-sample/src/main/java/org/springframework/cloud/alibaba/dubbo/service/InMemoryUserService.java
new file mode 100644
index 00000000..cd1aa8b3
--- /dev/null
+++ b/spring-cloud-alibaba-examples/spring-cloud-alibaba-dubbo-examples/spring-cloud-dubbo-provider-web-sample/src/main/java/org/springframework/cloud/alibaba/dubbo/service/InMemoryUserService.java
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.dubbo.service;
+
+import org.apache.dubbo.config.annotation.Service;
+
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * In-Memory {@link UserService} implementation
+ */
+@Service(protocol = "dubbo")
+public class InMemoryUserService implements UserService {
+
+ private Map usersRepository = new HashMap<>();
+
+ @Override
+ public boolean save(User user) {
+ return usersRepository.put(user.getId(), user) == null;
+ }
+
+ @Override
+ public boolean remove(Long userId) {
+ return usersRepository.remove(userId) != null;
+ }
+
+ @Override
+ public Collection findAll() {
+ return usersRepository.values();
+ }
+}
diff --git a/spring-cloud-alibaba-examples/spring-cloud-alibaba-dubbo-examples/spring-cloud-dubbo-sample-api/src/main/java/org/springframework/cloud/alibaba/dubbo/service/UserService.java b/spring-cloud-alibaba-examples/spring-cloud-alibaba-dubbo-examples/spring-cloud-dubbo-sample-api/src/main/java/org/springframework/cloud/alibaba/dubbo/service/UserService.java
new file mode 100644
index 00000000..471f07bf
--- /dev/null
+++ b/spring-cloud-alibaba-examples/spring-cloud-alibaba-dubbo-examples/spring-cloud-dubbo-sample-api/src/main/java/org/springframework/cloud/alibaba/dubbo/service/UserService.java
@@ -0,0 +1,33 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.dubbo.service;
+
+import java.util.Collection;
+
+/**
+ * {@link User} Service
+ *
+ * @author Mercy
+ */
+public interface UserService {
+
+ boolean save(User user);
+
+ boolean remove(Long userId);
+
+ Collection findAll();
+}
diff --git a/spring-cloud-alibaba-fescar/src/main/resources/META-INF/spring.factories b/spring-cloud-alibaba-fescar/src/main/resources/META-INF/spring.factories
deleted file mode 100644
index 3560bcee..00000000
--- a/spring-cloud-alibaba-fescar/src/main/resources/META-INF/spring.factories
+++ /dev/null
@@ -1,7 +0,0 @@
-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
-
diff --git a/spring-cloud-alibaba-nacos-config/src/test/java/org/springframework/cloud/alibaba/nacos/NacosConfigurationExtConfigTests.java b/spring-cloud-alibaba-nacos-config/src/test/java/org/springframework/cloud/alibaba/nacos/NacosConfigurationExtConfigTests.java
index cc7098b1..e0f6d012 100644
--- a/spring-cloud-alibaba-nacos-config/src/test/java/org/springframework/cloud/alibaba/nacos/NacosConfigurationExtConfigTests.java
+++ b/spring-cloud-alibaba-nacos-config/src/test/java/org/springframework/cloud/alibaba/nacos/NacosConfigurationExtConfigTests.java
@@ -57,14 +57,10 @@ import org.springframework.test.context.junit4.SpringRunner;
"spring.cloud.nacos.config.encode=utf-8",
"spring.cloud.nacos.config.timeout=1000",
"spring.cloud.nacos.config.file-extension=properties",
-
"spring.cloud.nacos.config.ext-config[0].data-id=ext-config-common01.properties",
-
"spring.cloud.nacos.config.ext-config[1].data-id=ext-config-common02.properties",
"spring.cloud.nacos.config.ext-config[1].group=GLOBAL_GROUP",
-
"spring.cloud.nacos.config.shared-dataids=common1.properties,common2.properties",
-
"spring.cloud.nacos.config.accessKey=test-accessKey",
"spring.cloud.nacos.config.secretKey=test-secretKey" }, webEnvironment = NONE)
public class NacosConfigurationExtConfigTests {
diff --git a/spring-cloud-alibaba-nacos-config/src/test/java/org/springframework/cloud/alibaba/nacos/NacosConfigurationTests.java b/spring-cloud-alibaba-nacos-config/src/test/java/org/springframework/cloud/alibaba/nacos/NacosConfigurationTests.java
index fc2a3b12..67e98f05 100644
--- a/spring-cloud-alibaba-nacos-config/src/test/java/org/springframework/cloud/alibaba/nacos/NacosConfigurationTests.java
+++ b/spring-cloud-alibaba-nacos-config/src/test/java/org/springframework/cloud/alibaba/nacos/NacosConfigurationTests.java
@@ -22,11 +22,8 @@ import static org.springframework.boot.test.context.SpringBootTest.WebEnvironmen
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
-
import java.util.Map;
-import com.alibaba.nacos.client.config.NacosConfigService;
-
import org.junit.Assert;
import org.junit.Test;
import org.junit.runner.RunWith;
@@ -48,6 +45,8 @@ import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
import org.springframework.test.context.junit4.SpringRunner;
+import com.alibaba.nacos.client.config.NacosConfigService;
+
/**
* @author xiaojing
*/
@@ -59,7 +58,6 @@ import org.springframework.test.context.junit4.SpringRunner;
@SpringBootTest(classes = NacosConfigurationTests.TestConfig.class, properties = {
"spring.application.name=myTestService1", "spring.profiles.active=dev,test",
"spring.cloud.nacos.config.server-addr=127.0.0.1:8848",
- "spring.cloud.nacos.config.endpoint=test-endpoint",
"spring.cloud.nacos.config.namespace=test-namespace",
"spring.cloud.nacos.config.encode=utf-8",
"spring.cloud.nacos.config.timeout=1000",
@@ -68,14 +66,10 @@ import org.springframework.test.context.junit4.SpringRunner;
"spring.cloud.nacos.config.cluster-name=test-cluster",
"spring.cloud.nacos.config.file-extension=properties",
"spring.cloud.nacos.config.contextPath=test-contextpath",
-
"spring.cloud.nacos.config.ext-config[0].data-id=ext-config-common01.properties",
-
"spring.cloud.nacos.config.ext-config[1].data-id=ext-config-common02.properties",
"spring.cloud.nacos.config.ext-config[1].group=GLOBAL_GROUP",
-
"spring.cloud.nacos.config.shared-dataids=common1.properties,common2.properties",
-
"spring.cloud.nacos.config.accessKey=test-accessKey",
"spring.cloud.nacos.config.secretKey=test-secretKey" }, webEnvironment = NONE)
public class NacosConfigurationTests {
@@ -83,8 +77,6 @@ public class NacosConfigurationTests {
static {
try {
- // when(any(ConfigService.class).getConfig(eq("test-name.properties"),
- // eq("test-group"), any())).thenReturn("user.name=hello");
Method method = PowerMockito.method(NacosConfigService.class, "getConfig",
String.class, String.class, long.class);
@@ -152,7 +144,6 @@ public class NacosConfigurationTests {
assertNotNull("NacosConfigProperties was not created", properties);
checkoutNacosConfigServerAddr();
- checkoutNacosConfigEndpoint();
checkoutNacosConfigNamespace();
checkoutNacosConfigClusterName();
checkoutNacosConfigAccessKey();
@@ -172,19 +163,12 @@ public class NacosConfigurationTests {
private void checkoutNacosConfigServerAddr() {
assertEquals("NacosConfigProperties server address is wrong", "127.0.0.1:8848",
properties.getServerAddr());
-
}
- private void checkoutNacosConfigEndpoint() {
- assertEquals("NacosConfigProperties endpoint is wrong", "test-endpoint",
- properties.getEndpoint());
-
- }
private void checkoutNacosConfigNamespace() {
assertEquals("NacosConfigProperties namespace is wrong", "test-namespace",
properties.getNamespace());
-
}
private void checkoutNacosConfigClusterName() {
@@ -234,8 +218,8 @@ public class NacosConfigurationTests {
private void checkoutDataLoad() {
- Assert.assertEquals(environment.getProperty("user.name"), "dev");
- Assert.assertEquals(environment.getProperty("user.age"), "12");
+ Assert.assertEquals("dev", environment.getProperty("user.name"));
+ Assert.assertEquals("12", environment.getProperty("user.age"));
}
private void checkoutEndpoint() throws Exception {
diff --git a/spring-cloud-alibaba-fescar/pom.xml b/spring-cloud-alibaba-seata/pom.xml
similarity index 97%
rename from spring-cloud-alibaba-fescar/pom.xml
rename to spring-cloud-alibaba-seata/pom.xml
index 0b0cd640..72002cca 100644
--- a/spring-cloud-alibaba-fescar/pom.xml
+++ b/spring-cloud-alibaba-seata/pom.xml
@@ -10,8 +10,8 @@
4.0.0
org.springframework.cloud
- spring-cloud-alibaba-fescar
- Spring Cloud Alibaba Fescar
+ spring-cloud-alibaba-seata
+ Spring Cloud Alibaba Seata
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/GlobalTransactionAutoConfiguration.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/GlobalTransactionAutoConfiguration.java
similarity index 82%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/GlobalTransactionAutoConfiguration.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/GlobalTransactionAutoConfiguration.java
index d876ad3b..1c0abc2d 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/GlobalTransactionAutoConfiguration.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/GlobalTransactionAutoConfiguration.java
@@ -14,7 +14,7 @@
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar;
+package org.springframework.cloud.alibaba.seata;
import com.alibaba.fescar.spring.annotation.GlobalTransactionScanner;
@@ -29,17 +29,17 @@ import org.springframework.util.StringUtils;
*/
@Configuration
-@EnableConfigurationProperties(FescarProperties.class)
+@EnableConfigurationProperties(SeataProperties.class)
public class GlobalTransactionAutoConfiguration {
private final ApplicationContext applicationContext;
- private final FescarProperties fescarProperties;
+ private final SeataProperties seataProperties;
public GlobalTransactionAutoConfiguration(ApplicationContext applicationContext,
- FescarProperties fescarProperties) {
+ SeataProperties seataProperties) {
this.applicationContext = applicationContext;
- this.fescarProperties = fescarProperties;
+ this.seataProperties = seataProperties;
}
@Bean
@@ -48,11 +48,11 @@ public class GlobalTransactionAutoConfiguration {
String applicationName = applicationContext.getEnvironment()
.getProperty("spring.application.name");
- String txServiceGroup = fescarProperties.getTxServiceGroup();
+ String txServiceGroup = seataProperties.getTxServiceGroup();
if (StringUtils.isEmpty(txServiceGroup)) {
txServiceGroup = applicationName + "-fescar-service-group";
- fescarProperties.setTxServiceGroup(txServiceGroup);
+ seataProperties.setTxServiceGroup(txServiceGroup);
}
return new GlobalTransactionScanner(applicationName, txServiceGroup);
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/FescarProperties.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/SeataProperties.java
similarity index 81%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/FescarProperties.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/SeataProperties.java
index f7847d96..2aea2745 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/FescarProperties.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/SeataProperties.java
@@ -14,20 +14,20 @@
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar;
+package org.springframework.cloud.alibaba.seata;
import org.springframework.boot.context.properties.ConfigurationProperties;
/**
* @author xiaojing
*/
-@ConfigurationProperties("spring.cloud.alibaba.fescar")
-public class FescarProperties {
+@ConfigurationProperties("spring.cloud.alibaba.seata")
+public class SeataProperties {
// todo support config Fescar server information
/**
- * Fescar tx service group.default is ${spring.application.name}-fescar-service-group.
+ * Seata tx service group.default is ${spring.application.name}-fescar-service-group.
*/
private String txServiceGroup;
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarBeanPostProcessor.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataBeanPostProcessor.java
similarity index 73%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarBeanPostProcessor.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataBeanPostProcessor.java
index 02bd6c32..17bafb7f 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarBeanPostProcessor.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataBeanPostProcessor.java
@@ -14,7 +14,7 @@
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar.feign;
+package org.springframework.cloud.alibaba.seata.feign;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.config.BeanPostProcessor;
@@ -22,18 +22,18 @@ import org.springframework.beans.factory.config.BeanPostProcessor;
/**
* @author xiaojing
*/
-final class FescarBeanPostProcessor implements BeanPostProcessor {
+final class SeataBeanPostProcessor implements BeanPostProcessor {
- private final FescarFeignObjectWrapper fescarFeignObjectWrapper;
+ private final SeataFeignObjectWrapper seataFeignObjectWrapper;
- FescarBeanPostProcessor(FescarFeignObjectWrapper fescarFeignObjectWrapper) {
- this.fescarFeignObjectWrapper = fescarFeignObjectWrapper;
+ SeataBeanPostProcessor(SeataFeignObjectWrapper seataFeignObjectWrapper) {
+ this.seataFeignObjectWrapper = seataFeignObjectWrapper;
}
@Override
public Object postProcessBeforeInitialization(Object bean, String beanName)
throws BeansException {
- return this.fescarFeignObjectWrapper.wrap(bean);
+ return this.seataFeignObjectWrapper.wrap(bean);
}
@Override
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarContextBeanPostProcessor.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataContextBeanPostProcessor.java
similarity index 66%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarContextBeanPostProcessor.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataContextBeanPostProcessor.java
index ffd8e88e..b1eb00ef 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarContextBeanPostProcessor.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataContextBeanPostProcessor.java
@@ -14,7 +14,7 @@
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar.feign;
+package org.springframework.cloud.alibaba.seata.feign;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.BeanFactory;
@@ -24,20 +24,20 @@ import org.springframework.cloud.openfeign.FeignContext;
/**
* @author xiaojing
*/
-public class FescarContextBeanPostProcessor implements BeanPostProcessor {
+public class SeataContextBeanPostProcessor implements BeanPostProcessor {
private final BeanFactory beanFactory;
- private FescarFeignObjectWrapper fescarFeignObjectWrapper;
+ private SeataFeignObjectWrapper seataFeignObjectWrapper;
- FescarContextBeanPostProcessor(BeanFactory beanFactory) {
+ SeataContextBeanPostProcessor(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(getFescarFeignObjectWrapper(),
+ if (bean instanceof FeignContext && !(bean instanceof SeataFeignContext)) {
+ return new SeataFeignContext(getSeataFeignObjectWrapper(),
(FeignContext) bean);
}
return bean;
@@ -49,11 +49,11 @@ public class FescarContextBeanPostProcessor implements BeanPostProcessor {
return bean;
}
- private FescarFeignObjectWrapper getFescarFeignObjectWrapper() {
- if (this.fescarFeignObjectWrapper == null) {
- this.fescarFeignObjectWrapper = this.beanFactory
- .getBean(FescarFeignObjectWrapper.class);
+ private SeataFeignObjectWrapper getSeataFeignObjectWrapper() {
+ if (this.seataFeignObjectWrapper == null) {
+ this.seataFeignObjectWrapper = this.beanFactory
+ .getBean(SeataFeignObjectWrapper.class);
}
- return this.fescarFeignObjectWrapper;
+ return this.seataFeignObjectWrapper;
}
}
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignBuilder.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataFeignBuilder.java
similarity index 80%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignBuilder.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataFeignBuilder.java
index acab33ff..4e312011 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignBuilder.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataFeignBuilder.java
@@ -14,7 +14,7 @@
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar.feign;
+package org.springframework.cloud.alibaba.seata.feign;
import org.springframework.beans.factory.BeanFactory;
@@ -23,12 +23,12 @@ import feign.Feign;
/**
* @author xiaojing
*/
-final class FescarFeignBuilder {
+final class SeataFeignBuilder {
- private FescarFeignBuilder() {
+ private SeataFeignBuilder() {
}
static Feign.Builder builder(BeanFactory beanFactory) {
- return Feign.builder().client(new FescarFeignClient(beanFactory));
+ return Feign.builder().client(new SeataFeignClient(beanFactory));
}
}
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignClient.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataFeignClient.java
similarity index 90%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignClient.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataFeignClient.java
index 9fc9d527..79d305c4 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignClient.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataFeignClient.java
@@ -14,7 +14,7 @@
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar.feign;
+package org.springframework.cloud.alibaba.seata.feign;
import java.io.IOException;
import java.util.ArrayList;
@@ -35,17 +35,17 @@ import org.springframework.util.StringUtils;
/**
* @author xiaojing
*/
-public class FescarFeignClient implements Client {
+public class SeataFeignClient implements Client {
private final Client delegate;
private final BeanFactory beanFactory;
- FescarFeignClient(BeanFactory beanFactory) {
+ SeataFeignClient(BeanFactory beanFactory) {
this.beanFactory = beanFactory;
this.delegate = new Client.Default(null, null);
}
- FescarFeignClient(BeanFactory beanFactory, Client delegate) {
+ SeataFeignClient(BeanFactory beanFactory, Client delegate) {
this.delegate = delegate;
this.beanFactory = beanFactory;
}
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignClientAutoConfiguration.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataFeignClientAutoConfiguration.java
similarity index 75%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignClientAutoConfiguration.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataFeignClientAutoConfiguration.java
index 1cb2c0cb..c3a24f79 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignClientAutoConfiguration.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataFeignClientAutoConfiguration.java
@@ -14,7 +14,7 @@
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar.feign;
+package org.springframework.cloud.alibaba.seata.feign;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.boot.autoconfigure.AutoConfigureBefore;
@@ -36,14 +36,14 @@ import feign.Feign;
@Configuration
@ConditionalOnClass(Client.class)
@AutoConfigureBefore(FeignAutoConfiguration.class)
-public class FescarFeignClientAutoConfiguration {
+public class SeataFeignClientAutoConfiguration {
@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);
+ return SeataHystrixFeignBuilder.builder(beanFactory);
}
@Bean
@@ -51,34 +51,34 @@ public class FescarFeignClientAutoConfiguration {
@ConditionalOnClass(name = "com.alibaba.csp.sentinel.SphU")
@ConditionalOnProperty(name = "feign.sentinel.enabled", havingValue = "true")
Feign.Builder feignSentinelBuilder(BeanFactory beanFactory) {
- return FescarSentinelFeignBuilder.builder(beanFactory);
+ return SeataSentinelFeignBuilder.builder(beanFactory);
}
@Bean
@ConditionalOnMissingBean
@Scope("prototype")
Feign.Builder feignBuilder(BeanFactory beanFactory) {
- return FescarFeignBuilder.builder(beanFactory);
+ return SeataFeignBuilder.builder(beanFactory);
}
@Configuration
protected static class FeignBeanPostProcessorConfiguration {
@Bean
- FescarBeanPostProcessor fescarBeanPostProcessor(
- FescarFeignObjectWrapper fescarFeignObjectWrapper) {
- return new FescarBeanPostProcessor(fescarFeignObjectWrapper);
+ SeataBeanPostProcessor fescarBeanPostProcessor(
+ SeataFeignObjectWrapper seataFeignObjectWrapper) {
+ return new SeataBeanPostProcessor(seataFeignObjectWrapper);
}
@Bean
- FescarContextBeanPostProcessor fescarContextBeanPostProcessor(
+ SeataContextBeanPostProcessor fescarContextBeanPostProcessor(
BeanFactory beanFactory) {
- return new FescarContextBeanPostProcessor(beanFactory);
+ return new SeataContextBeanPostProcessor(beanFactory);
}
@Bean
- FescarFeignObjectWrapper fescarFeignObjectWrapper(BeanFactory beanFactory) {
- return new FescarFeignObjectWrapper(beanFactory);
+ SeataFeignObjectWrapper fescarFeignObjectWrapper(BeanFactory beanFactory) {
+ return new SeataFeignObjectWrapper(beanFactory);
}
}
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignContext.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataFeignContext.java
similarity index 77%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignContext.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataFeignContext.java
index bd8d2251..4b8c16e7 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignContext.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataFeignContext.java
@@ -14,7 +14,7 @@
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar.feign;
+package org.springframework.cloud.alibaba.seata.feign;
import java.util.HashMap;
import java.util.Map;
@@ -26,14 +26,14 @@ import org.springframework.cloud.openfeign.FeignContext;
*
* @author xiaojing
*/
-public class FescarFeignContext extends FeignContext {
+public class SeataFeignContext extends FeignContext {
- private final FescarFeignObjectWrapper fescarFeignObjectWrapper;
+ private final SeataFeignObjectWrapper seataFeignObjectWrapper;
private final FeignContext delegate;
- FescarFeignContext(FescarFeignObjectWrapper fescarFeignObjectWrapper,
- FeignContext delegate) {
- this.fescarFeignObjectWrapper = fescarFeignObjectWrapper;
+ SeataFeignContext(SeataFeignObjectWrapper seataFeignObjectWrapper,
+ FeignContext delegate) {
+ this.seataFeignObjectWrapper = seataFeignObjectWrapper;
this.delegate = delegate;
}
@@ -43,7 +43,7 @@ public class FescarFeignContext extends FeignContext {
if (object instanceof Client) {
return object;
}
- return (T) this.fescarFeignObjectWrapper.wrap(object);
+ return (T) this.seataFeignObjectWrapper.wrap(object);
}
@Override
@@ -59,7 +59,7 @@ public class FescarFeignContext extends FeignContext {
}
else {
convertedInstances.put(entry.getKey(),
- (T) this.fescarFeignObjectWrapper.wrap(entry.getValue()));
+ (T) this.seataFeignObjectWrapper.wrap(entry.getValue()));
}
}
return convertedInstances;
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignObjectWrapper.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataFeignObjectWrapper.java
similarity index 83%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignObjectWrapper.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataFeignObjectWrapper.java
index 9b42b2f9..4c416e24 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarFeignObjectWrapper.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataFeignObjectWrapper.java
@@ -14,7 +14,7 @@
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar.feign;
+package org.springframework.cloud.alibaba.seata.feign;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.cloud.netflix.ribbon.SpringClientFactory;
@@ -26,25 +26,25 @@ import org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient;
/**
* @author xiaojing
*/
-public class FescarFeignObjectWrapper {
+public class SeataFeignObjectWrapper {
private final BeanFactory beanFactory;
private CachingSpringLoadBalancerFactory cachingSpringLoadBalancerFactory;
private SpringClientFactory springClientFactory;
- FescarFeignObjectWrapper(BeanFactory beanFactory) {
+ SeataFeignObjectWrapper(BeanFactory beanFactory) {
this.beanFactory = beanFactory;
}
Object wrap(Object bean) {
- if (bean instanceof Client && !(bean instanceof FescarFeignClient)) {
+ if (bean instanceof Client && !(bean instanceof SeataFeignClient)) {
if (bean instanceof LoadBalancerFeignClient) {
LoadBalancerFeignClient client = ((LoadBalancerFeignClient) bean);
- return new FescarLoadBalancerFeignClient(client.getDelegate(), factory(),
+ return new SeataLoadBalancerFeignClient(client.getDelegate(), factory(),
clientFactory(), this.beanFactory);
}
- return new FescarFeignClient(this.beanFactory, (Client) bean);
+ return new SeataFeignClient(this.beanFactory, (Client) bean);
}
return bean;
}
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarHystrixFeignBuilder.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataHystrixFeignBuilder.java
similarity index 83%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarHystrixFeignBuilder.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataHystrixFeignBuilder.java
index b67a9d84..61a27b84 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarHystrixFeignBuilder.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataHystrixFeignBuilder.java
@@ -14,7 +14,7 @@
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar.feign;
+package org.springframework.cloud.alibaba.seata.feign;
import feign.Retryer;
import feign.hystrix.HystrixFeign;
@@ -25,13 +25,13 @@ import feign.Feign;
/**
* @author xiaojing
*/
-final class FescarHystrixFeignBuilder {
+final class SeataHystrixFeignBuilder {
- private FescarHystrixFeignBuilder() {
+ private SeataHystrixFeignBuilder() {
}
static Feign.Builder builder(BeanFactory beanFactory) {
return HystrixFeign.builder().retryer(Retryer.NEVER_RETRY)
- .client(new FescarFeignClient(beanFactory));
+ .client(new SeataFeignClient(beanFactory));
}
}
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarLoadBalancerFeignClient.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataLoadBalancerFeignClient.java
similarity index 78%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarLoadBalancerFeignClient.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataLoadBalancerFeignClient.java
index 7f00d058..991ee166 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarLoadBalancerFeignClient.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataLoadBalancerFeignClient.java
@@ -14,7 +14,7 @@
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar.feign;
+package org.springframework.cloud.alibaba.seata.feign;
import java.io.IOException;
@@ -30,13 +30,13 @@ import org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient;
/**
* @author xiaojing
*/
-public class FescarLoadBalancerFeignClient extends LoadBalancerFeignClient {
+public class SeataLoadBalancerFeignClient extends LoadBalancerFeignClient {
private final BeanFactory beanFactory;
- FescarLoadBalancerFeignClient(Client delegate,
- CachingSpringLoadBalancerFactory lbClientFactory,
- SpringClientFactory clientFactory, BeanFactory beanFactory) {
+ SeataLoadBalancerFeignClient(Client delegate,
+ CachingSpringLoadBalancerFactory lbClientFactory,
+ SpringClientFactory clientFactory, BeanFactory beanFactory) {
super(wrap(delegate, beanFactory), lbClientFactory, clientFactory);
this.beanFactory = beanFactory;
}
@@ -47,7 +47,7 @@ public class FescarLoadBalancerFeignClient extends LoadBalancerFeignClient {
}
private static Client wrap(Client delegate, BeanFactory beanFactory) {
- return (Client) new FescarFeignObjectWrapper(beanFactory).wrap(delegate);
+ return (Client) new SeataFeignObjectWrapper(beanFactory).wrap(delegate);
}
}
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarSentinelFeignBuilder.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataSentinelFeignBuilder.java
similarity index 75%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarSentinelFeignBuilder.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataSentinelFeignBuilder.java
index 42f63214..166b2788 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/FescarSentinelFeignBuilder.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/SeataSentinelFeignBuilder.java
@@ -14,26 +14,24 @@
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar.feign;
+package org.springframework.cloud.alibaba.seata.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 {
+final class SeataSentinelFeignBuilder {
- private FescarSentinelFeignBuilder() {
+ private SeataSentinelFeignBuilder() {
}
static Feign.Builder builder(BeanFactory beanFactory) {
return SentinelFeign.builder().retryer(Retryer.NEVER_RETRY)
- .client(new FescarFeignClient(beanFactory));
+ .client(new SeataFeignClient(beanFactory));
}
}
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/hystrix/FescarHystrixAutoConfiguration.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/hystrix/SeataHystrixAutoConfiguration.java
similarity index 80%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/hystrix/FescarHystrixAutoConfiguration.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/hystrix/SeataHystrixAutoConfiguration.java
index f7db4b0d..332293d1 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/hystrix/FescarHystrixAutoConfiguration.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/hystrix/SeataHystrixAutoConfiguration.java
@@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar.feign.hystrix;
+package org.springframework.cloud.alibaba.seata.feign.hystrix;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.context.annotation.Bean;
@@ -27,11 +27,11 @@ import com.netflix.hystrix.HystrixCommand;
@Configuration
@ConditionalOnClass(HystrixCommand.class)
-public class FescarHystrixAutoConfiguration {
+public class SeataHystrixAutoConfiguration {
@Bean
- FescarHystrixConcurrencyStrategy fescarHystrixConcurrencyStrategy() {
- return new FescarHystrixConcurrencyStrategy();
+ SeataHystrixConcurrencyStrategy fescarHystrixConcurrencyStrategy() {
+ return new SeataHystrixConcurrencyStrategy();
}
}
\ No newline at end of file
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/hystrix/FescarHystrixConcurrencyStrategy.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/hystrix/SeataHystrixConcurrencyStrategy.java
similarity index 90%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/hystrix/FescarHystrixConcurrencyStrategy.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/hystrix/SeataHystrixConcurrencyStrategy.java
index e21ff168..47bd7071 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/feign/hystrix/FescarHystrixConcurrencyStrategy.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/feign/hystrix/SeataHystrixConcurrencyStrategy.java
@@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar.feign.hystrix;
+package org.springframework.cloud.alibaba.seata.feign.hystrix;
import java.util.concurrent.Callable;
@@ -25,11 +25,11 @@ import com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy;
/**
* @author xiaojing
*/
-public class FescarHystrixConcurrencyStrategy extends HystrixConcurrencyStrategy {
+public class SeataHystrixConcurrencyStrategy extends HystrixConcurrencyStrategy {
private HystrixConcurrencyStrategy delegate;
- public FescarHystrixConcurrencyStrategy() {
+ public SeataHystrixConcurrencyStrategy() {
this.delegate = HystrixPlugins.getInstance().getConcurrencyStrategy();
HystrixPlugins.reset();
HystrixPlugins.getInstance().registerConcurrencyStrategy(this);
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/rest/FescarRestTemplateAutoConfiguration.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/rest/SeataRestTemplateAutoConfiguration.java
similarity index 85%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/rest/FescarRestTemplateAutoConfiguration.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/rest/SeataRestTemplateAutoConfiguration.java
index 11fde4df..9acad5a0 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/rest/FescarRestTemplateAutoConfiguration.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/rest/SeataRestTemplateAutoConfiguration.java
@@ -29,7 +29,7 @@
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar.rest;
+package org.springframework.cloud.alibaba.seata.rest;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
@@ -47,18 +47,18 @@ import java.util.List;
*/
@Configuration
-public class FescarRestTemplateAutoConfiguration {
+public class SeataRestTemplateAutoConfiguration {
@Bean
- public FescarRestTemplateInterceptor fescarRestTemplateInterceptor() {
- return new FescarRestTemplateInterceptor();
+ public SeataRestTemplateInterceptor fescarRestTemplateInterceptor() {
+ return new SeataRestTemplateInterceptor();
}
@Autowired(required = false)
private Collection restTemplates;
@Autowired
- private FescarRestTemplateInterceptor fescarRestTemplateInterceptor;
+ private SeataRestTemplateInterceptor seataRestTemplateInterceptor;
@PostConstruct
public void init() {
@@ -66,7 +66,7 @@ public class FescarRestTemplateAutoConfiguration {
for (RestTemplate restTemplate : restTemplates) {
List interceptors = new ArrayList(
restTemplate.getInterceptors());
- interceptors.add(this.fescarRestTemplateInterceptor);
+ interceptors.add(this.seataRestTemplateInterceptor);
restTemplate.setInterceptors(interceptors);
}
}
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/rest/FescarRestTemplateInterceptor.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/rest/SeataRestTemplateInterceptor.java
similarity index 91%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/rest/FescarRestTemplateInterceptor.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/rest/SeataRestTemplateInterceptor.java
index 5a5b2a10..1f4bb6f8 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/rest/FescarRestTemplateInterceptor.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/rest/SeataRestTemplateInterceptor.java
@@ -14,7 +14,7 @@
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar.rest;
+package org.springframework.cloud.alibaba.seata.rest;
import java.io.IOException;
@@ -30,7 +30,7 @@ import org.springframework.util.StringUtils;
/**
* @author xiaojing
*/
-public class FescarRestTemplateInterceptor implements ClientHttpRequestInterceptor {
+public class SeataRestTemplateInterceptor implements ClientHttpRequestInterceptor {
@Override
public ClientHttpResponse intercept(HttpRequest httpRequest, byte[] bytes,
ClientHttpRequestExecution clientHttpRequestExecution) throws IOException {
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/web/FescarHandlerInterceptor.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/web/SeataHandlerInterceptor.java
similarity index 93%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/web/FescarHandlerInterceptor.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/web/SeataHandlerInterceptor.java
index 84ffee8e..640a5605 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/web/FescarHandlerInterceptor.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/web/SeataHandlerInterceptor.java
@@ -14,7 +14,7 @@
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar.web;
+package org.springframework.cloud.alibaba.seata.web;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
@@ -35,10 +35,10 @@ import org.springframework.web.servlet.HandlerInterceptor;
* 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 {
+public class SeataHandlerInterceptor implements HandlerInterceptor {
private static final Logger log = LoggerFactory
- .getLogger(FescarHandlerInterceptor.class);
+ .getLogger(SeataHandlerInterceptor.class);
@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response,
diff --git a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/web/FescarHandlerInterceptorConfiguration.java b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/web/SeataHandlerInterceptorConfiguration.java
similarity index 80%
rename from spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/web/FescarHandlerInterceptorConfiguration.java
rename to spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/web/SeataHandlerInterceptorConfiguration.java
index c510b1ac..bc0ce563 100644
--- a/spring-cloud-alibaba-fescar/src/main/java/org/springframework/cloud/alibaba/fescar/web/FescarHandlerInterceptorConfiguration.java
+++ b/spring-cloud-alibaba-seata/src/main/java/org/springframework/cloud/alibaba/seata/web/SeataHandlerInterceptorConfiguration.java
@@ -14,7 +14,7 @@
* limitations under the License.
*/
-package org.springframework.cloud.alibaba.fescar.web;
+package org.springframework.cloud.alibaba.seata.web;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
@@ -22,10 +22,10 @@ import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
/**
* @author xiaojing
*/
-public class FescarHandlerInterceptorConfiguration implements WebMvcConfigurer {
+public class SeataHandlerInterceptorConfiguration implements WebMvcConfigurer {
@Override
public void addInterceptors(InterceptorRegistry registry) {
- registry.addInterceptor(new FescarHandlerInterceptor()).addPathPatterns("/**");
+ registry.addInterceptor(new SeataHandlerInterceptor()).addPathPatterns("/**");
}
}
diff --git a/spring-cloud-alibaba-seata/src/main/resources/META-INF/spring.factories b/spring-cloud-alibaba-seata/src/main/resources/META-INF/spring.factories
new file mode 100644
index 00000000..24c7c008
--- /dev/null
+++ b/spring-cloud-alibaba-seata/src/main/resources/META-INF/spring.factories
@@ -0,0 +1,7 @@
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
+org.springframework.cloud.alibaba.seata.rest.SeataRestTemplateAutoConfiguration,\
+org.springframework.cloud.alibaba.seata.web.SeataHandlerInterceptorConfiguration,\
+org.springframework.cloud.alibaba.seata.GlobalTransactionAutoConfiguration,\
+org.springframework.cloud.alibaba.seata.feign.SeataFeignClientAutoConfiguration,\
+org.springframework.cloud.alibaba.seata.feign.hystrix.SeataHystrixAutoConfiguration
+
diff --git a/spring-cloud-alibaba-sentinel/pom.xml b/spring-cloud-alibaba-sentinel/pom.xml
index 1c0d9934..f52c6241 100644
--- a/spring-cloud-alibaba-sentinel/pom.xml
+++ b/spring-cloud-alibaba-sentinel/pom.xml
@@ -33,6 +33,13 @@
com.alibaba.csp
sentinel-dubbo-adapter
+ true
+
+
+
+ com.alibaba.csp
+ sentinel-apache-dubbo-adapter
+ true
diff --git a/spring-cloud-alibaba-sentinel/src/main/java/org/springframework/cloud/alibaba/sentinel/custom/SentinelAutoConfiguration.java b/spring-cloud-alibaba-sentinel/src/main/java/org/springframework/cloud/alibaba/sentinel/custom/SentinelAutoConfiguration.java
index 3deda90f..d2423e00 100644
--- a/spring-cloud-alibaba-sentinel/src/main/java/org/springframework/cloud/alibaba/sentinel/custom/SentinelAutoConfiguration.java
+++ b/spring-cloud-alibaba-sentinel/src/main/java/org/springframework/cloud/alibaba/sentinel/custom/SentinelAutoConfiguration.java
@@ -174,6 +174,7 @@ public class SentinelAutoConfiguration {
return new SentinelDataSourceHandler(beanFactory);
}
+ @ConditionalOnClass(ObjectMapper.class)
protected static class SentinelConverterConfiguration {
private ObjectMapper objectMapper = new ObjectMapper();
diff --git a/spring-cloud-starter-alibaba/pom.xml b/spring-cloud-starter-alibaba/pom.xml
index f510d18f..bac3eafc 100644
--- a/spring-cloud-starter-alibaba/pom.xml
+++ b/spring-cloud-starter-alibaba/pom.xml
@@ -16,7 +16,7 @@
spring-cloud-starter-alibaba-nacos-config-server
spring-cloud-starter-alibaba-nacos-discovery
spring-cloud-starter-alibaba-sentinel
- spring-cloud-starter-alibaba-fescar
+ spring-cloud-starter-alibaba-seata
spring-cloud-starter-stream-rocketmq
spring-cloud-starter-bus-rocketmq
spring-cloud-starter-dubbo
diff --git a/spring-cloud-starter-alibaba/spring-cloud-starter-alibaba-fescar/pom.xml b/spring-cloud-starter-alibaba/spring-cloud-starter-alibaba-seata/pom.xml
similarity index 76%
rename from spring-cloud-starter-alibaba/spring-cloud-starter-alibaba-fescar/pom.xml
rename to spring-cloud-starter-alibaba/spring-cloud-starter-alibaba-seata/pom.xml
index ca3b4b28..a6c5df07 100644
--- a/spring-cloud-starter-alibaba/spring-cloud-starter-alibaba-fescar/pom.xml
+++ b/spring-cloud-starter-alibaba/spring-cloud-starter-alibaba-seata/pom.xml
@@ -7,13 +7,13 @@
spring-cloud-starter-alibaba
2.1.0.BUILD-SNAPSHOT
- spring-cloud-starter-alibaba-fescar
- Spring Cloud Starter Alibaba Fescar
+ spring-cloud-starter-alibaba-seata
+ Spring Cloud Starter Alibaba Seata
org.springframework.cloud
- spring-cloud-alibaba-fescar
+ spring-cloud-alibaba-seata