• MySQL和MongoDB事务同步的一种尝试

MySQL和MongoDB事务同步的一种尝试

2025-05-29 01:37:06 栏目:宝塔面板 28 阅读

现象

最近线上的一条数据状态不对,但是日志又记录上了。 查看了这条数据的更新逻辑

public Boolean autoReject(AutoRejectParam param) {
        
        OperationLog log = createOperationLog(param);

        // 保存操作日志到mysql
        operationLogMapper.insertSelective(log);

        Query query = new Query();
        Criteria criteria = new Criteria();
        criteria.and("requestId").is(param.getRequestId());
        query.addCriteria(criteria);
        Update update = new Update();
        update.set("status", CvBusinessStatusEnum.Rejected.getCode())
                .set("updateTime", new Date())
                .set("taskId", "");
        mongoTemplate.updateFirst(query, update, JSONObject.class, collectionName);

        return true;
    }

从代码可以看出这里分别保存了日志到mysql,然后更新了mongodb中的数据状态。

很明显保存mysql成功了,但是更新mongodb的数据失败了,那为什么保存mongodb的数据失败了呢? 然后根据日志发现,当时服务器和mongodb连接出现了问题,于是就导致了保存mysql成功,保存到mongodb失败了。

如何解决?

问题既然产生了,那么有什么办法能够保证要成功就都成功呢? 第一个想到的是事务,我们需要保证两个数据库操作的事务一致性就可以避免这个问题了。使用单一的事务管理器肯定是不行的,需要使用链式事务。

我们可以使用spring中的ChainedTransactionManager来实现链式调用

@Configuration
public class TransactionConfig {

    @Bean
    public PlatformTransactionManager mongoTransactionManager(MongoTemplate mongoTemplate) {
        return new MongoTransactionManager(mongoTemplate.getMongoDbFactory());
    }

    @Bean
    public PlatformTransactionManager jpaTransactionManager(DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean
    public ChainedTransactionManager chainedTransactionManager(
            PlatformTransactionManager mongoTransactionManager,
            PlatformTransactionManager jpaTransactionManager) {
        return new ChainedTransactionManager(mongoTransactionManager, jpaTransactionManager);
    }
}


@Transactional("chainedTransactionManager")
public Boolean autoReject(AutoRejectParam param) {
        
        //省略其他代码 

        // 保存操作日志到mysql
   operationLogMapper.insertSelective(log);

   // 更新mongodb
        mongoTemplate.updateFirst(query, update, JSONObject.class, collectionName);

        return true;
  }

这种方法使用 ChainedTransactionManager 来管理多个事务管理器。当方法执行时,它会按顺序开启所有事务,如果在执行过程中出现异常,它会按相反的顺序回滚所有事务。

需要注意的是,这种方法并不能保证 100% 的事务一致性,因为它实际上是在应用层面模拟的分布式事务。在某些极端情况下(比如网络故障或服务器崩溃),可能会出现部分提交的情况。

比如我们是现在这样的执行流程

transaction1 begin
  transaction2 begin
  transaction2 commit -> error rollbacks, rollbacks transction1 too
transaction1 commit -> error, only rollbacks transaction1

比如上面这种情况,在最后提交transaction1的时候如果由于网络原因提交失败了,就会导致事务2成功,事务1失败,还是部分提交了。

当然如果业务要求对于这种不一致是可以接受的,或者说我们可以进行手动补偿方式达到最终一致性,那这种方案也是可以接受的。

对于要求更高事务一致性的场景,可能需要考虑使用专门的分布式事务解决方案,如 XA 协议或 TCC (Try-Confirm-Cancel) 模式。 比如JTA就属于XA协议, 我们可以使用开源实现atomikos。

本文地址:https://www.yitenyun.com/249.html

搜索文章

Tags

数据库 API FastAPI Calcite 电商系统 MySQL 数据同步 ACK Web 应用 异步数据库 双主架构 循环复制 Deepseek 宝塔面板 Linux宝塔 Docker 生命周期 序列 核心机制 JumpServer JumpServer安装 堡垒机安装 Linux安装JumpServer esxi esxi6 root密码不对 无法登录 web无法登录 Windows Windows server net3.5 .NET 安装出错 宝塔面板打不开 宝塔面板无法访问 SSL 堡垒机 跳板机 HTTPS 查看硬件 Linux查看硬件 Linux查看CPU Linux查看内存 无法访问宝塔面板 Windows宝塔 Mysql重置密码 HTTPS加密 连接控制 机制 ES 协同 Oracle 处理机制 Serverless 无服务器 语言 OB 单机版 Spring SQL 动态查询 scp Linux的scp怎么用 scp上传 scp下载 scp命令 技术 存储 运维 索引 缓存方案 缓存架构 缓存穿透 Rsync 架构 InnoDB 日志文件 MIXED 3 分页查询 响应模型 修改DNS Centos7如何修改DNS RocketMQ 长轮询 配置 监控 HexHub Redis 电商 系统 Linux 安全 服务器 MySQL 9.3 聚簇 非聚簇 异步化 防火墙 黑客 数据 主库 sftp 服务器 参数 自定义序列化 查询 group by SQLark PostgreSQL 管理口 数据库锁 SQLite-Web SQLite 数据库管理工具 开源 存储引擎 线上 库存 预扣 业务 人工智能 向量数据库 推荐系统 R edis 线程 Doris SeaTunnel MVCC 工具 共享锁 加密 场景 流量 数据备份 信息化 智能运维 PG DBA 网络架构 网络配置 ​Redis 机器学习 推荐模型 B+Tree ID 字段 • 索引 • 数据库 RDB AOF Redis 8.0 AI 助手 Ftp redo log 重做日志 高可用 Canal GreatSQL 连接数 Python 优化 万能公式 缓存 核心架构 订阅机制 同城 双活 网络故障 Postgres OTel Iceberg INSERT COMPACT Hash 字段 云原生 微软 SQL Server AI功能 prometheus Alert 不宕机 自动重启 Web IT运维 大模型 引擎 性能 SVM Embedding 高效统计 今天这篇文章就跟大家 向量库 Milvus Netstat Linux 服务器 端口 分库 分表 虚拟服务器 虚拟机 内存 OAuth2 Token Entity 开发 单点故障 DBMS 管理系统 MongoDB 容器 sqlmock LRU 崖山 新版本 ZODB Undo Log 容器化 窗口 函数 mini-redis INCR指令 JOIN openHalo 数据集成工具 分布式 集中式 悲观锁 乐观锁 磁盘架构 SpringAI 排行榜 排序 Redka 数据脱敏 加密算法 Redisson 锁芯 QPS 高并发 Testcloud 云端自动化 EasyExcel MySQL8 Recursive PostGIS 启动故障 大表 业务场景 分页 数据结构 意向锁 记录锁 分布式架构 分布式锁​ Pottery 聚簇索引 非聚簇索引 数据类型 模型 原子性 StarRocks 数据仓库 AIOPS R2DBC IT Caffeine CP MCP 开放协议 网络 InfluxDB 1 事务 Java SSH Web 接口 dbt 数据转换工具 RAG HelixDB 工具链 发件箱模式 池化技术 连接池 数据分类 部署 filelock 速度 服务器中毒 字典 传统数据库 向量化 对象 读写 Go 数据库迁移 事务隔离 单线程 仪表盘 双引擎 频繁 Codis 分页方案 排版 数据页 优化器 Order LLM 线程安全 Crash 代码 事务同步 List 类型 UUIDv7 主键 订单 日志 Pump Ansible