Springboot-dubbo-fescar 阿里分布式事务的实现方法

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');

sh fescar-server.sh 8091 /home/admin/fescar/data/

fescar-server.bat

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());     // 计算订单金额    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;  }}

{  "timestamp": "2019-02-01T02:54:27.422+0000",  "status": 500,  "error": "Internal Server Error",  "message": "For input string: /"2u/"",  "path": "/purchase"}