大家可以自行百度下阿里分布式事務(wù)，在這里我就不啰嗦了。下面是阿里分布式事務(wù)開源框架的一些資料，本文是springboot+dubbo+fescar的集成。
快速開始
https://github.com/alibaba/fescar/wiki/quick-start
git地址
https://github.com/alibaba/fescar
1、sql
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
create table `undo_log` ( `id` bigint(20) not null auto_increment, `branch_id` bigint(20) not null, `xid` varchar(100) 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`), key `idx_unionkey` (`xid`,`branch_id`)) engine=innodb auto_increment=159 default charset=utf8； 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; insert into `storage_tbl` values ('1', 'c00321', '100'); insert into `account_tbl` values ('1', 'u100001', '9999'); |
2、下載fescar-server，并啟動(dòng)
https://github.com/alibaba/fescar/releases
解壓
|
1
|
sh fescar-server.sh 8091 /home/admin/fescar/data/ |
win操作系統(tǒng)直接啟動(dòng)
|
1
|
fescar-server.bat |
3、下載zookeeper并啟動(dòng)。
4、demo結(jié)構(gòu)
分為庫(kù)存微服務(wù)storage、賬號(hào)微服務(wù)account、訂單微服務(wù)order和購(gòu)買下單的消費(fèi)者purchase。
購(gòu)買流程如下，先調(diào)用storage微服務(wù)減庫(kù)存，然后調(diào)用order微服務(wù)更新賬戶余額和生成訂單。訂單微服務(wù)order也作為消費(fèi)者消費(fèi)account賬號(hào)微服務(wù)，賬號(hào)微服務(wù)主要用來更新賬號(hào)余額。
5、demo地址如下
https://github.com/talkischeapgivememoney/springboot-dubbo-fescar.git
6、依次運(yùn)行storage微服務(wù)、account微服務(wù)和order微服務(wù)、purchase消費(fèi)者。
我們?cè)趧?chuàng)建訂單的時(shí)候模擬異常，具體類如下
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
|
package com.hcsoc.order.service; import com.alibaba.fescar.core.context.rootcontext;import com.hcsoc.account.api.accountservice;import com.hcsoc.order.api.orderservice;import com.hcsoc.order.api.bean.order;import lombok.setter;import org.slf4j.logger;import org.slf4j.loggerfactory;import org.springframework.beans.factory.annotation.autowired;import org.springframework.jdbc.core.jdbctemplate;import org.springframework.jdbc.core.preparedstatementcreator;import org.springframework.jdbc.support.generatedkeyholder;import org.springframework.jdbc.support.keyholder; import java.sql.connection;import java.sql.preparedstatement;import java.sql.sqlexception; @setterpublic class orderserviceimpl implements orderservice{ private static final logger logger = loggerfactory.getlogger(orderservice.class); @autowired private accountservice accountservice; @autowired private jdbctemplate jdbctemplate; public order create(string userid, string commoditycode, int ordercount) { logger.info("order service begin ... xid: " + rootcontext.getxid()); // 計(jì)算訂單金額 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; //模擬異常 integer.parseint("2u"); keyholder keyholder = new generatedkeyholder(); jdbctemplate.update(new preparedstatementcreator() { public preparedstatement createpreparedstatement(connection con) throws sqlexception { 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(); logger.info("order service end ... created " + order); return order; } private int calculate(string commodityid, int ordercount) { return 200 * ordercount; }} |
在購(gòu)買下單之前確認(rèn)下數(shù)據(jù)庫(kù)中的數(shù)據(jù)，以便購(gòu)買后對(duì)比，商品單價(jià)200.
我們看到 account_tbl 賬號(hào)表，用戶u100001賬戶余額為9999，庫(kù)存表storage_tbl，商品庫(kù)存是100.訂單表order_tbl沒有訂單數(shù)據(jù)。
下面我們執(zhí)行購(gòu)買下單操作，
執(zhí)行以下url
http://127.0.0.1:9094/purchase?userid=u100001&commoditycode=c00321&ordercount=4
userid 用戶id，commoditycode 商品編號(hào)，ordercount 購(gòu)買數(shù)量。
再去，返回?cái)?shù)據(jù)如下
|
1
2
3
4
5
6
7
|
{ "timestamp": "2019-02-01t02:54:27.422+0000", "status": 500, "error": "internal server error", "message": "for input string: \"2u\"", "path": "/purchase"} |
查看上面提到的account_tbl 賬號(hào)表，用戶u100001賬戶余額為9999，庫(kù)存表storage_tbl，商品庫(kù)存是100.訂單表order_tbl沒有訂單數(shù)據(jù)。說明分布式事務(wù)成功。
我們把模擬的異常去掉，再次執(zhí)行購(gòu)買操作。
http://127.0.0.1:9094/purchase?userid=u100001&commoditycode=c00321&ordercount=5
我們發(fā)現(xiàn)商品庫(kù)存由100變成了95，用戶余額由9999變成了8999，并且生成了一個(gè)訂單號(hào)，前面提到了商品的單價(jià)是200，數(shù)據(jù)正確。
其他的分布式事務(wù)框架，比如tcc和bytetcc需要操作冪等性，了解tcc和bytetcc的應(yīng)該知道，開發(fā)工作量很大而且操作還需要冪等性，而阿里的fescar則完全不需要，而且不需要那么多的開發(fā)工作量，希望fescar越來越成熟。
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持服務(wù)器之家。
原文鏈接：https://blog.csdn.net/zsj777/article/details/86702338
