pbteach/pbdtx

本项目由攀博课堂(www.pbteach.com)传智燕青老师研发测试，用于研究测试SpringCloud分布式事务控制解决方案，包括2PC、TCC、可靠消息最终一致性，最大努力通知，所用技术包括：Seata，Hmily，RocketMQ等

pbdtx

用于研究测试SpringCloud分布式事务控制解决方案，包括2PC、TCC、可靠消息最终一致性，最大努力通知，所用技术包括：Seata，Hmily，RocketMQ等

1 基础概念

什么是分布式事务：https://blog.csdn.net/weixin_44062339/article/details/99044718

CAP原理：https://blog.csdn.net/weixin_44062339/article/details/99710968

BASE理论：https://blog.csdn.net/weixin_44062339/article/details/99711052

1 seata实现2PC事务控制

代码实现步骤：https://blog.csdn.net/weixin_44062339/article/details/100179885

2 Hmily实现TCC事务控制

代码实现步骤：https://blog.csdn.net/weixin_44062339/article/details/100180025

3 RocketMQ事务消息方案

代码实现步骤：https://blog.csdn.net/weixin_44062339/article/details/100180487

4 课程视频

分布式事务课程视频：http://www.pbteach.com/post/java_video/subject_dtx/

5 系列讲义

http://www.pbteach.com/post/java_distribut/subject_dtx-01/

http://www.pbteach.com/post/java_distribut/subject_dtx-02/

http://www.pbteach.com/post/java_distribut/subject_dtx-03/

http://www.pbteach.com/post/java_distribut/subject_dtx-04/

http://www.pbteach.com/post/java_distribut/subject_dtx-05/

http://www.pbteach.com/post/java_distribut/subject_dtx-06/

pbdtx's Issues

RocketMQ实现最大努力通知案例有问题

@Transactional
@Override
public AccountPay insertAccountPay(AccountPay accountPay) {
    int result = accountPayDao.insertAccountPay(accountPay.getId(), accountPay.getAccountNo(), accountPay.getPayAmount(), "success");
    if(result>0){
       **//消息已送达mq，但是当前事务还未提交或者此时奔溃，会出现不一致情况**
        rocketMQTemplate.convertAndSend("topic_notifymsg",accountPay);
        return accountPay;
    }
    return null;
}