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;

@setter

public 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"

}