add xa samples

apache · Feb 3, 2024 · 857c5c4 · 857c5c4
1 parent 0be3924
commit 857c5c4
Show file tree

Hide file tree

Showing 42 changed files with 2,503 additions and 5 deletions.
diff --git a/...n/java/org/apache/seata/api/Business.java → ...org/apache/seata/api/BusinessService.java b/...n/java/org/apache/seata/api/Business.java → ...org/apache/seata/api/BusinessService.java
@@ -38,14 +38,15 @@
  * @author jimin.jm @alibaba-inc.com
  * @date 2019 /08/21 使用api 构建 单体应用多数据源分布式事务 非spring环境
  */
-public class Business {
+public class BusinessService {
 
     /**
      * The entry point of application.
      *
      * @param args the input arguments
      * @throws SQLException         the sql exception
      * @throws TransactionException the transaction exception
+     * @throws InterruptedException the interrupted exception
      */
     public static void main(String[] args) throws SQLException, TransactionException, InterruptedException {
         // init tm client and rm client, only once

diff --git a/readme.md b/readme.md
@@ -1,13 +1,34 @@
+# samples code specification
 
-# 事务模型
-https://seata.io/zh-cn/docs/user/quickstart
+##  Directory Structure
 
-# 启动顺序
+The first and second levels are more of a directory
+
+Top level: seata-samples
+
+Second layer: at-sample, tcc-sample, saga-sample, xa-sample
+
+Third floor, The third layer is the specific sample and the naming convention is as follows:
+
+## naming
+
+naming with framework: spring-nacos-seata, springboot-naocs-zk-seata ...
+
+## dependency
+
+pom: The dependencies of each sample should be independent and should not depend on the dependencies of the parent pom of seata samples.
+
+
+
+# samples transaction model
+https://seata.apache.org/docs/user/quickstart/
+
+## start sequence
 
 1、account
 
 2、storage
 
 3、order
 
-4、business
+4、business
diff --git a/xa-sample/springboot-feign-seata-xa/pom.xml b/xa-sample/springboot-feign-seata-xa/pom.xml
@@ -0,0 +1,48 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+    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.
+
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.7.0</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+    <groupId>org.apache.seata</groupId>
+    <artifactId>springboot-feign-seata-xa</artifactId>
+    <version>2.0.0</version>
+    <name>springboot-feign-seata-xa</name>
+    <description>springboot-feign-seata-xa</description>
+    <packaging>pom</packaging>
+
+    <modules>
+		<module>springboot-feign-seata-storage</module>
+		<module>springboot-feign-seata-account</module>
+		<module>springboot-feign-seata-order</module>
+		<module>springboot-feign-seata-business</module>
+    </modules>
+
+    <properties>
+        <java.version>8</java.version>
+        <maven.compiler.source>1.8</maven.compiler.source>
+        <maven.compiler.target>1.8</maven.compiler.target>
+    </properties>
+</project>
diff --git a/xa-sample/springboot-feign-seata-xa/springboot-feign-seata-account/pom.xml b/xa-sample/springboot-feign-seata-xa/springboot-feign-seata-account/pom.xml
@@ -0,0 +1,111 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+    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.
+
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.apache.seata</groupId>
+        <artifactId>springboot-feign-seata-xa</artifactId>
+        <version>2.0.0</version>
+    </parent>
+    <artifactId>springboot-feign-seata-account</artifactId>
+    <version>2.0.0</version>
+    <name>springboot-feign-seata-account</name>
+    <description>springboot-feign-seata-account</description>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+            <version>1.7.36</version>
+        </dependency>
+
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-classic</artifactId>
+            <version>1.2.9</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>jcl-over-slf4j</artifactId>
+            <version>1.7.36</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>log4j-over-slf4j</artifactId>
+            <version>1.7.36</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-jdbc</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+            <version>5.1.42</version>
+        </dependency>
+
+        <dependency>
+            <groupId>io.seata</groupId>
+            <artifactId>seata-spring-boot-starter</artifactId>
+            <version>2.0.0</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-openfeign</artifactId>
+            <version>3.1.5</version>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>
diff --git a/...-seata-account/src/main/java/org/apache/seata/SpringbootFeignSeataAccountApplication.java b/...-seata-account/src/main/java/org/apache/seata/SpringbootFeignSeataAccountApplication.java
@@ -0,0 +1,31 @@
+/*
+ * 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.apache.seata;
+
+import io.seata.spring.annotation.datasource.EnableAutoDataSourceProxy;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+@EnableAutoDataSourceProxy(dataSourceProxyMode = "XA")
+public class SpringbootFeignSeataAccountApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(SpringbootFeignSeataAccountApplication.class, args);
+	}
+
+}
diff --git a/...boot-feign-seata-account/src/main/java/org/apache/seata/controller/AccountController.java b/...boot-feign-seata-account/src/main/java/org/apache/seata/controller/AccountController.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.apache.seata.controller;
+
+import org.apache.seata.service.AccountService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+
+
+@RestController
+public class AccountController {
+
+    public static final Logger LOGGER = LoggerFactory.getLogger(AccountController.class);
+
+    @Resource
+    private AccountService accountService;
+
+    @RequestMapping(value = "/debit", method = RequestMethod.GET, produces = "application/json")
+    public String debit(String userId, int money) {
+        try {
+            accountService.debit(userId, money);
+        } catch (Exception ex) {
+            LOGGER.error("debit err,", ex);
+            return "FAIL";
+        }
+        return "SUCCESS";
+    }
+}
diff --git a/...springboot-feign-seata-account/src/main/java/org/apache/seata/service/AccountService.java b/...springboot-feign-seata-account/src/main/java/org/apache/seata/service/AccountService.java
@@ -0,0 +1,23 @@
+/*
+ * 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.apache.seata.service;
+
+public interface AccountService {
+
+
+     void debit(String userId, int money);
+}
diff --git a/...t-feign-seata-account/src/main/java/org/apache/seata/service/impl/AccountServiceImpl.java b/...t-feign-seata-account/src/main/java/org/apache/seata/service/impl/AccountServiceImpl.java
@@ -0,0 +1,48 @@
+/*
+ * 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.apache.seata.service.impl;
+
+import io.seata.core.context.RootContext;
+import org.apache.seata.service.AccountService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+
+@Service
+public class AccountServiceImpl implements AccountService {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(AccountService.class);
+
+    @Resource
+    private JdbcTemplate jdbcTemplate;
+
+    @Override
+    @Transactional
+    public void debit(String userId, int money) {
+        LOGGER.info("Account Service ... xid: " + RootContext.getXID());
+        LOGGER.info("Deducting balance SQL: update account_tbl set money = money - {} where user_id = {}", money,
+                userId);
+
+        jdbcTemplate.update("update account_tbl set money = money - ? where user_id = ?", money, userId);
+        LOGGER.info("Account Service End ... ");
+    }
+
+}