This is an automated email from the ASF dual-hosted git repository.
albumenj pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-website.git
The following commit(s) were added to refs/heads/master by this push:
new 0b76a361c2 Add seata quick start (#1347)
0b76a361c2 is described below
commit 0b76a361c28da814e89bd9c813af5742f5b5bd20
Author: Albumen Kevin <[email protected]>
AuthorDate: Mon Aug 8 14:55:30 2022 +0800
Add seata quick start (#1347)
---
.../java-sdk/quick-start/eco-system/_index.md | 8 +
.../java-sdk/quick-start/eco-system/transaction.md | 308 +++++++++++++++++++++
.../imgs/docs3-v2/java-sdk/seata/transaction-1.png | Bin 0 -> 68513 bytes
.../imgs/docs3-v2/java-sdk/seata/transaction-2.png | Bin 0 -> 263774 bytes
4 files changed, 316 insertions(+)
diff --git a/content/zh/docs3-v2/java-sdk/quick-start/eco-system/_index.md
b/content/zh/docs3-v2/java-sdk/quick-start/eco-system/_index.md
new file mode 100755
index 0000000000..f7aac6354d
--- /dev/null
+++ b/content/zh/docs3-v2/java-sdk/quick-start/eco-system/_index.md
@@ -0,0 +1,8 @@
+
+---
+type: docs
+title: "周边生态接入"
+linkTitle: "周边生态接入"
+weight: 1000
+description: ""
+---
diff --git a/content/zh/docs3-v2/java-sdk/quick-start/eco-system/transaction.md
b/content/zh/docs3-v2/java-sdk/quick-start/eco-system/transaction.md
new file mode 100644
index 0000000000..53efe245f5
--- /dev/null
+++ b/content/zh/docs3-v2/java-sdk/quick-start/eco-system/transaction.md
@@ -0,0 +1,308 @@
+---
+type: docs
+title: "一致性事务"
+linkTitle: "一致性事务"
+weight: 1
+description: "快速玩转 Dubbo 生态之一致性事务篇（Seata）"
+---
+
+## Seata 是什么
+Seata 是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA
事务模式，为用户打造一站式的分布式解决方案。
+
+## 一、示例架构说明
+用户采购商品业务，整个业务包含3个微服务:
+
+- 库存服务: 扣减给定商品的库存数量。
+- 订单服务: 根据采购请求生成订单。
+- 账户服务: 用户账户金额扣减。
+
+
+
+### StorageService
+
+```java
+public interface StorageService {
+
+ /**
+ * 扣除存储数量
+ */
+ void deduct(String commodityCode, int count);
+}
+```
+
+### OrderService
+
+```java
+public interface OrderService {
+
+ /**
+ * 创建订单
+ */
+ Order create(String userId, String commodityCode, int orderCount);
+}
+```
+
+### AccountService
+
+```java
+public interface AccountService {
+
+ /**
+ * 从用户账户中借出
+ */
+ void debit(String userId, int money);
+}
+```
+
+## 二、主要的业务逻辑
+
+### BusinessService
+
+```java
+public class BusinessServiceImpl implements BusinessService {
+
+ private StorageService storageService;
+
+ private OrderService orderService;
+
+ /**
+ * 采购
+ */
+ public void purchase(String userId, String commodityCode, int orderCount) {
+ // 扣除存储数量
+ storageService.deduct(commodityCode, orderCount);
+ // 创建订单
+ orderService.create(userId, commodityCode, orderCount);
+ }
+}
+```
+
+### StorageService
+
+```java
+public class StorageServiceImpl implements StorageService {
+
+ private JdbcTemplate jdbcTemplate;
+
+ @Override
+ public void deduct(String commodityCode, int count) {
+ // 修改数据库：扣减存储数量
+ jdbcTemplate.update("update storage_tbl set count = count - ? where
commodity_code = ?",
+ new Object[]{count, commodityCode});
+ }
+}
+```
+
+### OrderService
+
+```java
+public class OrderServiceImpl implements OrderService {
+
+ private AccountService accountService;
+
+ private JdbcTemplate jdbcTemplate;
+
+ public Order create(String userId, String commodityCode, int orderCount) {
+ // 计算金额
+ int orderMoney = calculate(commodityCode, orderCount);
+
+ // 用户账户中扣减金额
+ accountService.debit(userId, orderMoney);
+
+ // 修改数据库：新建订单
+ final Order order = new Order();
+ order.userId = userId;
+ order.commodityCode = commodityCode;
+ order.count = orderCount;
+ order.money = orderMoney;
+ KeyHolder keyHolder = new GeneratedKeyHolder();
+ jdbcTemplate.update(con -> {
+ PreparedStatement pst = con.prepareStatement(
+ "insert into order_tbl (user_id, commodity_code, count,
money) values (?, ?, ?, ?)",
+ PreparedStatement.RETURN_GENERATED_KEYS);
+ pst.setObject(1, order.userId);
+ pst.setObject(2, order.commodityCode);
+ pst.setObject(3, order.count);
+ pst.setObject(4, order.money);
+ return pst;
+ }, keyHolder);
+ order.id = keyHolder.getKey().longValue();
+ return order;
+ }
+}
+```
+
+### AccountService
+
+
+```java
+public class AccountServiceImpl implements AccountService {
+
+ private JdbcTemplate jdbcTemplate;
+
+ @Override
+ public void debit(String userId, int money) {
+ // 修改数据库：用户账户中扣减金额
+ jdbcTemplate.update("update account_tbl set money = money - ? where
user_id = ?", new Object[]{money, userId});
+ }
+}
+```
+
+## 三、快速启动示例
+
+### Step 1: 下载源码
+
+```shell script
+git clone -b master https://github.com/apache/dubbo-samples.git
+cd ./dubbo-samples-transaction/
+```
+
+### Step 2: 通过 docker-compose 启动 Seata-Server 和 MySQL 等
+
+在此示例中，我们使用 docker-compose 快速拉起 seata-server 和 mysql 等服务。
+
+```bash
+cd src/main/resources/docker
+docker-compose up
+```
+
+### Step 3: 构建用例
+
+执行 maven 命令，打包 demo 工程
+
+```bash
+mvn clean package
+```
+
+### Step 4: 启动 AccountService
+
+```java
+java -classpath ./target/dubbo-samples-transaction-1.0-SNAPSHOT.jar
org.apache.dubbo.samples.starter.DubboAccountServiceStarter
+```
+
+### Step 5: 启动 OrderService
+
+```java
+java -classpath ./target/dubbo-samples-transaction-1.0-SNAPSHOT.jar
org.apache.dubbo.samples.starter.DubboOrderServiceStarter
+```
+### Step 6: 启动 StorageService
+
+```java
+java -classpath ./target/dubbo-samples-transaction-1.0-SNAPSHOT.jar
org.apache.dubbo.samples.starter.DubboStorageServiceStarter
+```
+
+### Step 7: 启动 BusinessService
+```java
+java -classpath ./target/dubbo-samples-transaction-1.0-SNAPSHOT.jar
org.apache.dubbo.samples.starter.DubboBusinessTester
+```
+
+## 四、示例核心流程
+
+
+
+### Step 1: 修改业务代码
+此处仅仅需要一行注解 `@GlobalTransactional` 写在业务发起方的方法上:
+
+```java
+ @GlobalTransactional
+ public void purchase(String userId, String commodityCode, int orderCount) {
+ ......
+ }
+```
+
+### Step 2: 安装数据库
+
+- 要求: MySQL (InnoDB 存储引擎)。
+
+**提示:** 事实上例子中3个微服务需要3个独立的数据库，但为了方便我们使用同一物理库并配置3个逻辑连接串。
+
+更改以下xml文件中的数据库url、username和password
+
+dubbo-account-service.xml
+dubbo-order-service.xml
+dubbo-storage-service.xml
+
+```xml
+ <property name="url" value="jdbc:mysql://x.x.x.x:3306/xxx" />
+ <property name="username" value="xxx" />
+ <property name="password" value="xxx" />
+```
+
+### Step 3: 为 Seata 创建 undo_log 表
+
+`UNDO_LOG` 此表用于 Seata 的AT模式。
+
+```sql
+-- 注意当 Seata 版本升级至 0.3.0+ 将由之前的普通索引变更为唯一索引。
+CREATE TABLE `undo_log` (
+ `id` bigint(20) NOT NULL AUTO_INCREMENT,
+ `branch_id` bigint(20) NOT NULL,
+ `xid` varchar(100) NOT NULL,
+ `context` varchar(128) NOT NULL,
+ `rollback_info` longblob NOT NULL,
+ `log_status` int(11) NOT NULL,
+ `log_created` datetime NOT NULL,
+ `log_modified` datetime NOT NULL,
+ `ext` varchar(100) DEFAULT NULL,
+ PRIMARY KEY (`id`),
+ UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
+) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
+```
+
+### Step 4: 创建相关业务表
+
+```sql
+
+DROP TABLE IF EXISTS `storage_tbl`;
+CREATE TABLE `storage_tbl` (
+ `id` int(11) NOT NULL AUTO_INCREMENT,
+ `commodity_code` varchar(255) DEFAULT NULL,
+ `count` int(11) DEFAULT 0,
+ PRIMARY KEY (`id`),
+ UNIQUE KEY (`commodity_code`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8;
+
+
+DROP TABLE IF EXISTS `order_tbl`;
+CREATE TABLE `order_tbl` (
+ `id` int(11) NOT NULL AUTO_INCREMENT,
+ `user_id` varchar(255) DEFAULT NULL,
+ `commodity_code` varchar(255) DEFAULT NULL,
+ `count` int(11) DEFAULT 0,
+ `money` int(11) DEFAULT 0,
+ PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8;
+
+
+DROP TABLE IF EXISTS `account_tbl`;
+CREATE TABLE `account_tbl` (
+ `id` int(11) NOT NULL AUTO_INCREMENT,
+ `user_id` varchar(255) DEFAULT NULL,
+ `money` int(11) DEFAULT 0,
+ PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8;
+```
+
+### Step 5: 启动 Seata-Server 服务
+
+- 下载[服务器软件包](https://github.com/seata/seata/releases)，将其解压缩。
+
+```shell
+Usage: sh seata-server.sh(for linux and mac) or cmd seata-server.bat(for
windows) [options]
+ Options:
+ --host, -h
+ The host to bind.
+ Default: 0.0.0.0
+ --port, -p
+ The port to listen.
+ Default: 8091
+ --storeMode, -m
+ log store mode : file、db
+ Default: file
+ --help
+
+e.g.
+
+sh seata-server.sh -p 8091 -h 127.0.0.1 -m file
+```
+
diff --git a/static/imgs/docs3-v2/java-sdk/seata/transaction-1.png
b/static/imgs/docs3-v2/java-sdk/seata/transaction-1.png
new file mode 100644
index 0000000000..00b79f592b
Binary files /dev/null and
b/static/imgs/docs3-v2/java-sdk/seata/transaction-1.png differ
diff --git a/static/imgs/docs3-v2/java-sdk/seata/transaction-2.png
b/static/imgs/docs3-v2/java-sdk/seata/transaction-2.png
new file mode 100644
index 0000000000..595f26dbbc
Binary files /dev/null and
b/static/imgs/docs3-v2/java-sdk/seata/transaction-2.png differ
