diff --git a/pom.xml b/pom.xml index 755f9a3d..b4cea51e 100644 --- a/pom.xml +++ b/pom.xml @@ -89,7 +89,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-examples spring-cloud-alibaba-test diff --git a/spring-cloud-alibaba-dependencies/pom.xml b/spring-cloud-alibaba-dependencies/pom.xml index ffb9a38a..822eb72a 100644 --- a/spring-cloud-alibaba-dependencies/pom.xml +++ b/spring-cloud-alibaba-dependencies/pom.xml @@ -18,8 +18,8 @@ 1.5.1 3.1.0 - 1.0.0-RC2 - 0.4.0 + 1.0.0 + 0.4.2 1.0.8 1.0.1 4.0.1 @@ -212,7 +212,7 @@ org.springframework.cloud - spring-cloud-alibaba-fescar + spring-cloud-alibaba-seata ${project.version} @@ -265,7 +265,7 @@ org.springframework.cloud - spring-cloud-starter-alibaba-fescar + spring-cloud-starter-alibaba-seata ${project.version} diff --git a/spring-cloud-alibaba-examples/ans-example/ans-consumer-ribbon-example/pom.xml b/spring-cloud-alibaba-examples/ans-example/ans-consumer-ribbon-example/pom.xml index 4615c510..9f4d5a92 100644 --- a/spring-cloud-alibaba-examples/ans-example/ans-consumer-ribbon-example/pom.xml +++ b/spring-cloud-alibaba-examples/ans-example/ans-consumer-ribbon-example/pom.xml @@ -25,4 +25,13 @@ spring-boot-starter-actuator + + + + + org.springframework.boot + spring-boot-maven-plugin + + + \ No newline at end of file diff --git a/spring-cloud-alibaba-examples/ans-example/ans-provider-example/pom.xml b/spring-cloud-alibaba-examples/ans-example/ans-provider-example/pom.xml index 6a304a45..310de2c4 100644 --- a/spring-cloud-alibaba-examples/ans-example/ans-provider-example/pom.xml +++ b/spring-cloud-alibaba-examples/ans-example/ans-provider-example/pom.xml @@ -25,4 +25,14 @@ spring-boot-starter-actuator + + + + + org.springframework.boot + spring-boot-maven-plugin + + + + \ No newline at end of file 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 a9367792..09ed18df 100644 --- a/spring-cloud-alibaba-examples/pom.xml +++ b/spring-cloud-alibaba-examples/pom.xml @@ -26,10 +26,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 86c4ea78..875efb3f 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 96% 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 index a92239e9..b9e97e72 100644 --- 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 @@ -16,6 +16,7 @@ package org.springframework.cloud.alibaba.cloud.examples; import java.sql.SQLException; +import java.util.Random; import org.springframework.context.ApplicationContext; import org.springframework.context.annotation.Bean; @@ -53,7 +54,8 @@ public class DatabaseConfiguration { String password = environment.getProperty("mysql.user.password"); DruidDataSource druidDataSource = new DruidDataSource(); - druidDataSource.setUrl("jdbc:mysql://" + ip + ":" + port + "/" + dbName + "?serverTimezone=UTC"); + druidDataSource.setUrl( + "jdbc:mysql://" + ip + ":" + port + "/" + dbName + "?serverTimezone=UTC"); druidDataSource.setUsername(userName); druidDataSource.setPassword(password); druidDataSource.setDriverClassName("com.mysql.jdbc.Driver"); 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..587f8bcb --- /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" + } +} \ No newline at end of file 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 09909bfe..464c4377 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..587f8bcb --- /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" + } +} \ No newline at end of file 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 02d480cb..ffc01608 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..587f8bcb --- /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" + } +} \ No newline at end of file diff --git a/spring-cloud-alibaba-examples/fescar-example/readme-zh.md b/spring-cloud-alibaba-examples/seata-example/readme-zh.md similarity index 89% rename from spring-cloud-alibaba-examples/fescar-example/readme-zh.md rename to spring-cloud-alibaba-examples/seata-example/readme-zh.md index e93f6866..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 侵入 的方式，解决 微服务 场景下面临的分布式事务问题。 @@ -40,11 +40,12 @@ mysql.user.password=your mysql server password ``` -### 创建 UNDO_LOG 表 +### 创建 undo_log 表 -[Fescar AT 模式]() 需要使用到 UNDO_LOG 表。 +[Fescar AT 模式]() 需要使用到 undo_log 表。 ``` $sql +-- 注意此处0.3.0+ 增加唯一索引 ux_undo_log CREATE TABLE `undo_log` ( `id` bigint(20) NOT NULL AUTO_INCREMENT, `branch_id` bigint(20) NOT NULL, @@ -55,8 +56,8 @@ CREATE TABLE `undo_log` ( `log_modified` datetime NOT NULL, `ext` varchar(100) DEFAULT NULL, PRIMARY KEY (`id`), - KEY `idx_unionkey` (`xid`,`branch_id`) -) ENGINE=InnoDB AUTO_INCREMENT=159 DEFAULT CHARSET=utf8 + UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`) +) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8; ``` ### 创建 示例中 业务所需要的数据库表 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 ca1b1cd2..93f2b43b 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..587f8bcb --- /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" + } +} \ No newline at end of file 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-nacos-discovery/src/main/java/org/springframework/cloud/alibaba/nacos/NacosDiscoveryAutoConfiguration.java b/spring-cloud-alibaba-nacos-discovery/src/main/java/org/springframework/cloud/alibaba/nacos/NacosDiscoveryAutoConfiguration.java index 65a8e8d8..0b2b8956 100644 --- a/spring-cloud-alibaba-nacos-discovery/src/main/java/org/springframework/cloud/alibaba/nacos/NacosDiscoveryAutoConfiguration.java +++ b/spring-cloud-alibaba-nacos-discovery/src/main/java/org/springframework/cloud/alibaba/nacos/NacosDiscoveryAutoConfiguration.java @@ -73,31 +73,4 @@ public class NacosDiscoveryAutoConfiguration { return new NacosAutoServiceRegistration(registry, autoServiceRegistrationProperties, registration); } - - @Bean - @ConditionalOnBean(NacosAutoServiceRegistration.class) // NacosAutoServiceRegistration - // should be present - @ConditionalOnNotWebApplication // Not Web Application - public ApplicationRunner applicationRunner( - final NacosAutoServiceRegistration nacosAutoServiceRegistration) { - - return new ApplicationRunner() { - @Override - public void run(ApplicationArguments args) throws Exception { - if (!nacosAutoServiceRegistration.isRunning()) { // If it's not running, - // let - // it start. - // FIXME: Please make sure "spring.cloud.nacos.discovery.port" must be - // configured on an available port, - // or the startup or Nacos health check will be failed. - nacosAutoServiceRegistration.start(); - // NacosAutoServiceRegistration will be stopped after its destroy() - // method - // is invoked. - // @PreDestroy destroy() -> stop() - } - } - }; - } - } \ No newline at end of file diff --git a/spring-cloud-alibaba-nacos-discovery/src/main/java/org/springframework/cloud/alibaba/nacos/NacosDiscoveryProperties.java b/spring-cloud-alibaba-nacos-discovery/src/main/java/org/springframework/cloud/alibaba/nacos/NacosDiscoveryProperties.java index 05ec95c3..0dadefc4 100644 --- a/spring-cloud-alibaba-nacos-discovery/src/main/java/org/springframework/cloud/alibaba/nacos/NacosDiscoveryProperties.java +++ b/spring-cloud-alibaba-nacos-discovery/src/main/java/org/springframework/cloud/alibaba/nacos/NacosDiscoveryProperties.java @@ -18,6 +18,7 @@ package org.springframework.cloud.alibaba.nacos; import com.alibaba.nacos.api.NacosFactory; import com.alibaba.nacos.api.naming.NamingService; +import com.alibaba.nacos.api.naming.PreservedMetadataKeys; import com.alibaba.nacos.client.naming.utils.UtilAndComs; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -67,7 +68,7 @@ public class NacosDiscoveryProperties { /** * watch delay,duration to pull new service from nacos server. */ - private long watchDelay = 5000; + private long watchDelay = 30000; /** * nacos naming log file name @@ -149,6 +150,7 @@ public class NacosDiscoveryProperties { @PostConstruct public void init() throws SocketException { + metadata.put(PreservedMetadataKeys.REGISTER_SOURCE, "SPRING_CLOUD"); if (secure) { metadata.put("secure", "true"); } diff --git a/spring-cloud-alibaba-fescar/pom.xml b/spring-cloud-alibaba-seata/pom.xml similarity index 96% rename from spring-cloud-alibaba-fescar/pom.xml rename to spring-cloud-alibaba-seata/pom.xml index f603c9e7..a1305d45 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 88% 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..dea0559e 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,15 +14,15 @@ * 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 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 e71b495e..3a1e60a0 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.netflix.feign.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 89a84409..bc565a60 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 7a269e8b..239b1a48 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.netflix.feign.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 38a3a4ff..bc99e8bb 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.netflix.feign.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 89f98580..8f44e280 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.netflix.feign.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 83% 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 0a5f7892..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,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; @@ -25,13 +25,13 @@ 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 91191ed0..78d1b3fa 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 java.util.ArrayList; import java.util.Collection; @@ -48,18 +48,18 @@ import org.springframework.web.client.RestTemplate; */ @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() { @@ -67,7 +67,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 94% 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 50883c4e..83ad3802 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; @@ -36,10 +36,10 @@ import org.springframework.web.servlet.ModelAndView; * 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 75% 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 d6b94acc..d28708bb 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,20 +14,19 @@ * 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; import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter; /** * @author xiaojing */ -public class FescarHandlerInterceptorConfiguration extends WebMvcConfigurerAdapter { +public class SeataHandlerInterceptorConfiguration extends WebMvcConfigurerAdapter { @Override public void addInterceptors(InterceptorRegistry registry) { - registry.addInterceptor(new FescarHandlerInterceptor()).addPathPatterns("/**"); + registry.addInterceptor(new SeataHandlerInterceptor()).addPathPatterns("/**"); super.addInterceptors(registry); } } 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-starter-alibaba/pom.xml b/spring-cloud-starter-alibaba/pom.xml index 0755c8e9..7b54cb3d 100644 --- a/spring-cloud-starter-alibaba/pom.xml +++ b/spring-cloud-starter-alibaba/pom.xml @@ -17,7 +17,7 @@ spring-cloud-starter-alibaba-nacos-config 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 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 daeb3459..9211e62e 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 1.5.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