红酒商城网站建设,四川长昕建设工程有限公司网站,站长工具端口检测,有没有可以直接看的点击上方“Java面试题精选”#xff0c;关注公众号面试刷图#xff0c;查缺补漏号外#xff1a;往期面试题#xff0c;10篇为一个单位归置到本公众号菜单栏-面试题#xff0c;有需要的欢迎翻阅。一、概述随着时间和业务的发展#xff0c;数据库中表的数据量会…点击上方“Java面试题精选”关注公众号面试刷图查缺补漏号外往期面试题10篇为一个单位归置到本公众号菜单栏-面试题有需要的欢迎翻阅。一、概述随着时间和业务的发展数据库中表的数据量会越来越大相应地数据操作增删改查的开销也会越来越大。因此把其中一些大表进行拆分到多个数据库中的多张表中。另一方面在分库分表以后还需要保证分库分表的和主库的事务一致性。这片文章介绍一下https://zhuanlan.zhihu.com/p/25933039本篇文章是基于非事务消息的异步确保的方式来完成分库分表中的事务问题。二、需要解决问题2.1 原有事务由于分库分表之后新表在另外一个数据库中如何保证主库和分库的事务性是必须要解决的问题。解决办法通过在主库中创建一个流水表把操作数据库的逻辑映射为一条流水记录。当整个大事务执行完毕后(流水被插入到流水表),然后通过其他方式来执行这段流水保证最终一致性。2.2 流水所谓流水可以理解为一条事务消息上面通过在数据库中创建一张流水表使用一条流水记录代表一个业务处理逻辑因此一个流水一定是能最终正确执行的.因此当把一段业务代码提取流水中必须要考虑到:流水延迟处理性。流水不是实时处理的而是用过流水执行器来异步执行的。因此如果在原有逻辑中需要特别注意后续流程对该流水是不是有实时依赖性(例如后续业务逻辑中会使用流水结果来做一些计算等)。流水处理无序性。保证即使后生成的流水先执行也不能出现问题。流水最终成功性。对每条插入的流水该条流水一定要保证能执行成功因此提取流水的时候:流水处理越简单越好流失处理依赖越少越好提取的流水在该业务逻辑中无实时性依赖2.3 流水处理器流水处理器即要保证流水处理尽可能处理快又能保证流水最终能执行成功。设想一个场景当出现某一条流水处理失败如果流失执行器要等当前流水执行成功才继续往后执行那么会影响后续流水的执行更严重的是一直卡在当条记录导致整个系统出现问题因此流水执行器中设置2个任务第一个任务,流水处理任务已最快的速度执行流水如果流水处理失败了也不影响后面流水处理第二个任务,流水校验任务这个任务就是顺序检查流水记录保证所有流水都执行成功如果失败进行重试多次重试失败以后发出告警以让人工介入处理。2.4 流水处理完成因为流水表是放在原数据库中而流水处理完成后是操作分库如果分库操作完成去更新老表流水消息那么又是夸库事务如何保证流水状态的更新和分库也是在一个事务的解决办法是在分库中创建一个流水表当流失处理完成以后不是去更新老表状态而是插入分库流水表中、这样做的好处一般会对流水做唯一索引那么如果流水重复多次执行的时候插入分库流水表的时候肯定由于唯一索引检测不通过整个事务就会回滚(当然也可以在处理流水事前应该再做一下幂等性判断)这样通过判断主库流水是否在分库中就能判断一条流水是否执行完毕三、流水处理器基本框架流水处理器其实不包含任何业务相关的处理逻辑核心功能就是通知业务接入方何时处理什么样的流水检验流水执行的成功注流水执行器并不知道该流水表示什么逻辑具体需要业务系统去识别后去执行相对应业务逻辑。3.1 流水执行任务流水处理调度任务就是通过扫描待处理的流水然后通知业务系统该执行哪一条流水。示意图如下3.2 流水校验任务流水校验任务就是要比较主库和分库中的流水记录对执行未成功的流水通知业务系统进行重新处理如果多次重试失败则发出告警。流程示意图四、为什么不用事务消息由于是既有项目进行改造(本人从事互联网金融所以是绝对不容忍有任何消息丢失或者消息处理失败)不使用事务消息有1个原因需要额外引入消息队列增加系统的复杂度而且也需要额外的逻辑保证和消息队列通讯失败的时候处理其实1不算是主要原因而是因为事务消息需要手动的commit和rollback(使用数据库不需要)那么问题来了spring中事务是有传递性的那我们事务消息何时提交又是个大问题例如 A.a()本来就是一个事务 但是另外一个事务B.b()中又调用了A.a() 那事务消息提交是放在A.a()还是B.b()中呢来源www.cnblogs.com/lizo/p/8035036.html最近五期与其在网上拼命找题不如马上关注我们~
