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

大家可以自行百度下阿里分布式事务,在这里我就不啰嗦了。下面是阿里分布式事务开源框架的一些资料,本文是springboot+dubbo+fescar的集成。

快速开始

https://github.com/alibaba/fescar/wiki/Quick-Start

GIT地址

https://github.com/alibaba/fescar

1、sql

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,并启动

https://github.com/alibaba/fescar/releases

解压

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

win操作系统直接启动

fescar-server.bat

3、下载zookeeper并启动。

4、demo结构

分为库存微服务storage、账号微服务account、订单微服务order和购买下单的消费者purchase。

购买流程如下,先调用storage微服务减库存,然后调用order微服务更新账户余额和生成订单。订单微服务order也作为消费者消费account账号微服务,账号微服务主要用来更新账号余额。

5、demo地址如下

https://github.com/TalkIsCheapGiveMeMoney/springboot-dubbo-fescar.git

6、依次运行storage微服务、account微服务和order微服务、purchase消费者。

我们在创建订单的时候模拟异常,具体类如下

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;
  }
}

在购买下单之前确认下数据库中的数据,以便购买后对比,商品单价200.

我们看到 account_tbl 账号表,用户U100001账户余额为9999,库存表storage_tbl,商品库存是100.订单表order_tbl没有订单数据。

下面我们执行购买下单操作,

执行以下url

http://127.0.0.1:9094/purchase?userId=U100001&commodityCode=C00321&orderCount=4

userId 用户id,commodityCode  商品编号,orderCount 购买数量。

再去,返回数据如下

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

查看上面提到的account_tbl 账号表,用户U100001账户余额为9999,库存表storage_tbl,商品库存是100.订单表order_tbl没有订单数据。说明分布式事务成功。

我们把模拟的异常去掉,再次执行购买操作。

http://127.0.0.1:9094/purchase?userId=U100001&commodityCode=C00321&orderCount=5

我们发现商品库存由100变成了95,用户余额由9999变成了8999,并且生成了一个订单号,前面提到了商品的单价是200,数据正确。

其他的分布式事务框架,比如TCC和byteTcc需要操作幂等性,了解TCC和ByteTcc的应该知道,开发工作量很大而且操作还需要幂等性,而阿里的fescar则完全不需要,而且不需要那么多的开发工作量,希望fescar越来越成熟。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • SpringBoot通过yml和xml文件配置日志输出方法

    SpringBoot中默认使用Logback进行日志输出,可以同时使用SpringBoot框架的配置文件application.yml或是通过logback的配置文件logback.xml进行配置. 通过application.yml配置 <?xml version="1.0" encoding="UTF-8"?> <configuration debug="false"> <!--定义日志文件的存储地址 勿在 Lo

  • 使用ehcache三步搞定springboot缓存的方法示例

    本次内容主要介绍基于Ehcache 3.0来快速实现Spring Boot应用程序的数据缓存功能.在Spring Boot应用程序中,我们可以通过Spring Caching来快速搞定数据缓存.接下来我们将介绍如何在三步之内搞定Spring Boot缓存. 1. 创建一个Spring Boot工程并添加Maven依赖 你所创建的Spring Boot应用程序的maven依赖文件至少应该是下面的样子: <?xml version="1.0" encoding="UTF-8

  • springboot常用注释的讲解

    1:@Qualifier @Qualifier 注释指定注入 Bean 的名称,这样歧义就消除了.所以@Autowired 和@Qualifier 结合使用时,自动注入的策略就从 byType 转变成 byName 了.例子如下: 有一个接口: public interface EmployeeService { public String getEmployeeById(Long id); } 有两个实现类: @Service("service") public class Empl

  • springboot2 生产部署注意事项及示例代码

    注意事项 1. 去除不需要的 jar 开发工具 jar :springs-boot-devtools 2. 监控一定要做好权限制或者去除 控制 jar :spring-boot-starter-actuator 监控 druid 的监控 swagger的接口 3 打包的时候要跳过测试 maven : clean package -Dmaven.test.skip=true 打包脚本示例: #!/bin/sh ## chang here SERVICE_DIR=/roncoo/spring-boo

  • Springboot引用外部配置文件的方法步骤

    现在的项目越来越多的都是打包成jar运行尤其是springboot项目,这时候配置文件如果一直放在项目中,每次进行简单的修改时总会有些不方便,这里我们看下打包成jar之后,从外部配置文件中读取配置信息. 首先想到的是通过java代码读取外边某个路径下的文件,但是开始做之后发现好多问题.后来又找其它解决方案,正好搜到一种简单的解决方式: java -jar demo.jar --Dspring.config.location=myapplication.properties 这样就可以通过@val

  • 详解SpringBoot基础之banner玩法解析

    SpringBoot项目启动时会在控制台打印一个默认的启动图案,这个图案就是我们要讲的banner.看似简单的banner,我们能够对它做些什么呢?本篇文章就带大家深入了解一下banner的使用(版本:SpringBoot2.1.4). 制作自己的banner 第一步:在src/main/resources下面创建banner.txt. 第二步:访问网站 http://patorjk.com/software/taag,在网站"Type Something "处输入想要制作的单词(比如

  • springboot中事务管理@Transactional的注意事项与使用场景

    前言:在service层的方法上使用@Transactional 即可实现处理数据库发生错误时触发事务回滚机制. 注意: Spring 基于注解的声明式事物 @Transactional 默认情况下只会对运行期异常(java.lang.RuntimeException及其子类)和 Error 进行回滚. 数据库引擎要支持事物,使用InnoDB. @Transactional 只能被应用到public方法上, 对于其它非public的方法,如果标记了@Transactional也不会报错,但方法没

  • SpringBoot中并发定时任务的实现、动态定时任务的实现(看这一篇就够了)推荐

    一.在JAVA开发领域,目前可以通过以下几种方式进行定时任务 1.单机部署模式 Timer:jdk中自带的一个定时调度类,可以简单的实现按某一频度进行任务执行.提供的功能比较单一,无法实现复杂的调度任务. ScheduledExecutorService:也是jdk自带的一个基于线程池设计的定时任务类.其每个调度任务都会分配到线程池中的一个线程执行,所以其任务是并发执行的,互不影响. Spring Task:Spring提供的一个任务调度工具,支持注解和配置文件形式,支持Cron表达式,使用简单

  • SpringBoot下Mybatis的缓存的实现步骤

    说起 mybatis,作为 Java 程序员应该是无人不知,它是常用的数据库访问框架.与 Spring 和 Struts 组成了 Java Web 开发的三剑客--- SSM.当然随着 Spring Boot 的发展,现在越来越多的企业采用的是 SpringBoot + mybatis 的模式开发,我们公司也不例外.而 mybatis 对于我也仅仅停留在会用而已,没想过怎么去了解它,更不知道它的缓存机制了,直到那个生死难忘的 BUG.故事的背景比较长,但并不是啰嗦,只是让读者知道这个 BUG 触

  • 详解SpringBoot中异步请求和异步调用(看完这一篇就够了)

    一.SpringBoot中异步请求的使用 1.异步请求与同步请求 特点: 可以先释放容器分配给请求的线程与相关资源,减轻系统负担,释放了容器所分配线程的请求,其响应将被延后,可以在耗时处理完成(例如长时间的运算)时再对客户端进行响应.一句话:增加了服务器对客户端请求的吞吐量(实际生产上我们用的比较少,如果并发请求量很大的情况下,我们会通过nginx把请求负载到集群服务的各个节点上来分摊请求压力,当然还可以通过消息队列来做请求的缓冲). 2.异步请求的实现 方式一:Servlet方式实现异步请求

随机推荐