通过AOP动态管理Seata分布式事务

本文作者：FUNKYE(陈健斌),杭州某互联网公司主程。

前言

通过GA大会上滴滴出行的高级研发工程陈鹏志的在滴滴两轮车业务中的实践,发现动态降级的必要性是非常的高,所以这边简单利用spring boot aop来简单的处理降级相关的处理,这边非常感谢陈鹏志的分享!

可利用次demo项目地址

Seata分布式事务大并发下容易出现timeout的情况优化使用

本文作者：FUNKYE(陈健斌),杭州某互联网公司主程。

前言

Seata 是一款开源的分布式事务解决方案，致力于在微服务架构下提供高性能和简单易用的分布式事务服务。

Seata AT 模式:

一阶段：业务数据和回滚日志记录在同一个本地事务中提交，释放本地锁和连接资源。

二阶段：提交异步化，非常快速地完成。回滚通过一阶段的回滚日志进行反向补偿

Seata 官网使用介绍:

修改Mybatis-Plus源码利用反射支持Seata代理数据源

准备工作

1.拉取mybatisplus项目源码

Docker部署Seata与Nacos整合

运行所使用的demo项目地址

本文作者：FUNKYE(陈健斌),杭州某互联网公司主程。

前言

直连方式的Seata配置博客

Seata整合Nacos配置博客

我们接着前几篇篇的基础上去配置nacos做配置中心跟dubbo注册中心.

透过源码解决SeataAT模式整合Mybatis-Plus失去MP特性的问题

项目地址：https://gitee.com/itCjb/springboot-dubbo-mybatisplus-seata

本文作者：FUNKYE(陈健斌),杭州某互联网公司主程。

介绍

Mybatis-Plus：MyBatis-Plus（简称 MP）是一个 MyBatis 的增强工具，在 MyBatis 的基础上只做增强不做改变，为简化开发、提高效率而生。

MP配置：

1
2
3

<bean id="sqlSessionFactory" class="com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean">
    <property name="dataSource" ref="dataSource"/>
</bean>

Seata：Seata 是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA 事务模式，为用户打造一站式的分布式解决方案。

AT模式机制：

• 一阶段：业务数据和回滚日志记录在同一个本地事务中提交，释放本地锁和连接资源。

• 二阶段：

  • 提交异步化，非常快速地完成。
  • 回滚通过一阶段的回滚日志进行反向补偿。
  more >>

SpringBoot+Dubbo+MybatisPlus整合Seata分布式事务

项目地址

本文作者：FUNKYE(陈健斌),杭州某互联网公司主程。

前言

​ 事务：事务是由一组操作构成的可靠的独立的工作单元，事务具备ACID的特性，即原子性、一致性、隔离性和持久性。
​ 分布式事务:当一个操作牵涉到多个服务,多台数据库协力完成时(比如分表分库后,业务拆分),多个服务中，本地的Transaction已经无法应对这个情况了,为了保证数据一致性，就需要用到分布式事务。
​ Seata ：是一款开源的分布式事务解决方案，致力于在微服务架构下提供高性能和简单易用的分布式事务服务。
​ 本文目的：现如今微服务越来越流行，而市面上的分布式事务的方案可谓不少，参差不齐，比较流行的以MQ代表的保证的是消息最终一致性的解决方案（消费确认，消息回查，消息补偿机制等），以及TX-LCN的LCN模式协调本地事务来保证事务统一提交或回滚（已经停止更新，对Dubbo2.7不兼容）。而MQ的分布式事务太过复杂，TX-LCN断更，这时候需要一个高效可靠及易上手的分布式事务解决方案，Seata脱颖而出，本文要介绍的就是如何快速搭建一个整合Seata的Demo项目，一起来吧！

分布式事务tx-lcn下lcn模式时spring手动事务回滚失效的解决方案

本文作者：FUNKYE(陈健斌),杭州某互联网公司主程。

起因

先上错误demo

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

@LcnTransaction
@Transactional(rollbackFor = {Exception.class})
public boolean test() {
    B_file b = new B_file();
    b.setUrl("515645646");
    b.setCategory("0");
    // 发出sql
    save(b);
    try {
        int i = 1 / 0;// 异常
        return true;
    } catch (Exception e) {
        // 事务回滚
        System.out.println("事务回滚");
        // 其实这个模式下,下面这句会失效,导致数据库被正常插入
        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();// 关键
        return false;
    }
}

可以运行类似代码,会发现这时候并没有事务回滚,上面的save对象会被插入到数据库.

解决方案

解决方法有2种:

1.改用 @TccTransaction来替换lcn模式

2.使用DTXUserControls.rollbackCurrentGroup();来替换TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();

引入依赖

首先在你的java项目中引入

1
2
3
4
5

<dependency>
	<groupId>redis.clients</groupId>
	<artifactId>jedis</artifactId>
	<version>2.9.2</version>
</dependency>

java多线程理解总结：

进程等于在运行的java程序
而线程是进程下的一个子任务，与进程共享内存空间，文件句柄等
线程是进程的组件，是java代码的最小单位
线程分为守护线程与用户线程

Docker部署mysql5.6读写分离

本文作者：FUNKYE(陈健斌),杭州某互联网公司主程。

首先说下为什么要使用docker,因为在你没有资金买更多的服务器的时候,docker就可以让你实现一台机子进行装无数相同的程序.所以就可以在一台服务器上轻松装2个mysql,然后进行主从配置.

docker安装文章可以直接百度,https://www.cnblogs.com/rookie404/p/5965518.html