支付宝分布式事务介绍.pptx

支付宝分布式事务介绍,2009年7月27日核心开发组红雪,21:45,1,What-分布事务快速浏览Why-为什么要引入分布事务How-如何实现分布事务Warning-注意点,21:45,2,大纲,21:45,3,事务,复习,操作时间,资源位置,A1,1,2,3,4,5,A,B,C,C2,B3,C4,A5,事务1,事务2,事务3,事务:由一组操作构成的可靠、独立的工作单元ACID:Atomicity(原子性)Consistency(一致性)Isolation(隔离性)Durability(持久性)难点:高度并发资源分布大时间跨度,21:45,4,本地事务,本地事务事务由资源管理器（如DBMS）本地管理优点支持严格的ACID属性可靠高效状态可以只在资源管理器中维护应用编程模型简单(在框架或平台的支持)局限不具备分布事务处理能力隔离的最小单位由资源管理器决定，如数据库中的一条记录,应用/应用服务器/应用框架AP,资源管理器RM,开始会话,开始事务,操作1,操作n,提交/回滚事务,完成会话,锁,日志,复习,21:45,5,全局事务(DTP模型),复习,5,资源管理器RM2,应用/应用框架/应用服务器AP,资源管理器RM1,3.操作1.n,6.提交事务,事务管理器TM,1.开始全局事务,2.注册资源1,4.注册资源2,5.操作1.n,7.准备,8.准备,9.提交,10.提交,全局事务事务由全局事务管理器全局管理事务管理器管理全局事务状态与参与的资源，协同资源的一致提交/回滚TX协议应用或应用服务器与事务管理器的接口XA协议全局事务管理器与资源管理器的接口,21:45,6,两阶段提交(TwoPhaseCommit),复习,准备操作与ACIDA:准备后，仍可提交与回滚C:准备时，一致性检查必须OKI:准备后，事务结果仍然只在事务内可见D:准备后，事务结果已经持久局限协议成本(准备操作是一定必须的吗）准备阶段的持久成本全局事务状态的持久成本潜在故障点多带来的脆弱性准备后，提交前的故障引发一系列隔离与恢复难题,事务管理器TM,资源管理器RM1,1.准备,OK,3.提交,OK,资源管理器RM2,2.准备,OK,4.提交,OK,事务管理器TM,资源管理器RM1,1.准备,OK,3.回滚,OK,资源管理器RM2,2.准备,NO,4.回滚,OK,6,21:45,7,网关未独立前：一条龙,回顾,7,账务处理逻辑,iwallet,交易处理逻辑,主库,网银处理逻辑,持久操作1,持久操作2,持久操作4,提交/回滚本地事务,持久操作3,21:45,8,网关独立部署,回顾,账务处理逻辑,iwallet,交易处理逻辑,主库,网银处理逻辑,持久操作1,持久操作2,持久操作3,bankgw,账务处理逻辑,通知,持久操作4,提交/回滚本地事务,提交/回滚本地事务,21:45,9,交易服务化进程,回顾,账务处理逻辑,trade,交易处理逻辑,主库,网银处理逻辑,持久操作1,持久操作2,持久操作4,bankgw,通知,持久操作4,提交/回滚本地事务,提交/回滚本地事务,账务处理逻辑,iwallet,持久操作3,提交/回滚本地事务,21:45,10,账务服务化,回顾,主库,持久操作4,bankgw,账务库,trade,acctrans,持久操作1,持久操作2,持久操作3,确保通知,提交/回滚分布事务,提交/回滚分布事务,21:45,11,双峰插云,回顾,主库,持久操作1,mipgw,账务库,paycore,acctrans,持久操作3,持久操作2,提交/回滚嵌套分布事务,支付库,21:45,12,基本原则,集成,适用场景业务活动中包括账务参与者的只要操作账务，必须使用分布式事务，支付宝系统特有账务是作为默认参与者存在的多个业务活动参与者之间必须保持语义状态一致性的可选，对于非实时类业务，可使用高可靠的ESB消息完成一致性遵守必须在本地事务块中开启分布式事务；必须使用全局唯一的主事务号,21:45,13,工作原理及步骤,集成,业务系统开启本地事务块；启动一个业务活动；事务同步器持久化此业务活动记录至DB，并将主事务号存放至本地线程变量中；业务系统开始调用账务服务：账务的服务接口参数列表的txId主事务号是无需设置的，事务同步器会用本地线程变量内的主事务号替换之；账务前置进行账务处理后同步响应处理结果；业务系统分析账务处理结果，如正常则提交本地事务块；事务同步器调用账务交易结束器完成账务提交，如账务提交失败则后续等待分布式事务恢复查询继续尝试提交，直至账务提交完成为止；若本地事务回滚，同步器则调用账务交易结束器完成账务回滚，如账务回滚失败则后续等待分布式事务恢复程序继续尝试回滚，直至账务回滚成功为止。,21:45,14,示例代码,集成,publicAccountTransResultfoo()return(AccountTransResult)transactionTemplate.execute(newTransactionCallback()/确保在本地事务块中publicObjectdoInTransaction(TransactionStatusstatus)AccountTransResulttransResult=null;trybusinessActivityControlService.start(.);/启动业务活动transResult=accountTransFacade.freezeAccountBalance(null,.);/请求账务交易处理/判断账务前置处理结果if(transResult.isSuccess()localBizHandle();/本地业务逻辑处理localDBHandle();/本地数据持久处理elselogger.error(.);、status.setRollbackOnly();/显式回滚catch(Exceptione)logger.error(.);status.setRollbackOnly();/显式回滚returntransResult;);,21:45,15,本地事务模板,集成,transactionTemplate使用主库dataSource：在本地事务提交/回滚发生时，主事务记录(处于主库)的提交/回滚状态可做到确保一致；当事务同步器无法顺利提交/回滚账务操作，则分布式任务恢复程序在进行恢复时无需回查业务当前状态使用非主库dataSource：在本地事务提交/回滚发生时，主事务记录(处于主库)的提交/回滚状态无法做到确保一致；当事务同步器无法顺利提交/回滚账务操作，则分布式任务恢复程序在进行恢复时需要回查业务当前状态,21:45,16,回查实现示例代码,集成,/*(non-Javadoc)*seecom.alipay.sofa.platform.xts.bacs.spi.BusinessActivityStateResolver#isDone(java.lang.String,java.lang.String)*/publicintisDone(StringbusinessType,StringbusinessId)if(StringUtil.isBlank(businessType)|StringUtil.isBlank(businessId)logger.error(严重异常：参数不全；尝试解释业务活动状态businessType=+businessType+;businessId=+businessId+时。);returnBusinessActivityStateResolver.UNKNOWN;return(Integer)transactionTemplate.execute(newTransactionCallback()publicObjectdoInTransaction(TransactionStatusstatus)if(StringUtil.equals(WithdrawBusinessType.BALANCE,businessType)tryWithdrawInstructionDOdata=withdrawInstructionDAO.lock(businessId);if(data=null)logger.error(严重异常：支付指令数据不存在；尝试解释业务活动状态businessType=+businessType+;businessId=+businessId+时。);returnBusinessActivityStateResolver.UNKNOWN;elseif(StringUtil.equals(InstructionStatusEnum.PRE_ACCREDITED.getCode(),data.getStatus()logger.warn(成功解释业务活动状态businessType=+businessType+;businessId=+businessId+:未执行。);returnBusinessActivityStateResolver.NOT_DONE;elseif(StringUtil.equals(InstructionStatusEnum.SUBMIT_SETTLED.getCode(),data.getStatus()logger.warn(成功解释业务活动状态businessType=+businessType+;businessId=+businessId+:已执行。);returnBusinessActivityStateResolver.DONE;elselogger.error(严重异常：支付指令数据状态不正常,当前状态：+data.getStatus()+；尝试解释业务活动状态businessType=+businessType+;businessId=+businessId+时。);returnBusinessActivityStateResolver.UNKNOWN;catch(Exceptione)logger.warn(警告：数据库异常；尝试解释业务活动状态businessType=+businessType+;businessId=+businessId+时。,e);returnBusinessActivityStateResolver.UNKNOWN;elselogger.error(严重异常：无需进行业务活动解释的类型；尝试解释业务活动状态businessType=+businessType+;businessId=+businessId+时。);returnBusinessActivityStateResolver.UNKNOWN;);,21:45,17,启动业务活动,集成,businessActivityControlService.start(.);,业务活动的启动有两种方式：带参数：businessType+businessIdbusinessType：业务活动类别，每个类别的前三位对应到某个业务类型，后三位是对此业务类型的具体操作；如002代表提现，而002001代表提现申请中的冻结部分businessId：业务数据的ID或可以唯一定位到业务数据的key无参数：系统自动分配业务活动ID（全局唯一）推荐使用以businessType+businessId方式启动业务活动：根据businessType可准确定位至业务及操作，便利了对故障的分析、排查、以及出错系统的快速定位利用businessType的前三位，分布式任务恢复程序可以找到正确的回查实现者通过businessId，可以迅速的定位到具体的业务数据、日志信息等,21:45,18,分布任务恢复回查配置,集成,、,21:45,19,配置,集成,accountTransActionInterceptor,21:45,20,配置,集成,com.alipay.acctrans.service.facade.AccountTransFacadeaccountTransFacadeMulePort$acctrans_service_url/services/accountTransFacade$acctrans_service_url/services/accountTransFacade?wsdl20000,21:45,21,配置,集成,com.alipay.sofa.platform.xts.bacs.spi.AccountTransFinalizeraccountTransFinalizerMulePort$acctrans_service_url/services/accountTransFinalizer$acctrans_service_url/services/accountTransFinalizer?wsdl20000,21:45,22,配置,集成,businessActivityDAObusinessActionDAO,21:45,23,配置,集成,mand.result.ResultCmon.enums.MessageEnumcom.alipay.acctrans.core.module.enums.FreezeBalanceTypeEnumcom.alipay.acctrans.core.module.enums.AccountMemoEnumcom.alipay.acctrans.core.module.enums.TransResultEnumcom.alipay.acctrans.core.module.enums.TransCodeEnumcom.alipay.acctrans.core.module.enums.SubTransCodeEnumcom.alipay.acctrans.core.module.enums.TerminalEnumcom.alipay.acctrans.core.module.enums.ChannelEnumcom.alipay.acctrans.core.module.enums.AccountTypeEnumcom.alipay.acctrans.core.module.enums.AccountEnableStatusEnumcom.alipay.acctrans.core.module.enums.FreezeModelEnumcom.alipay.acctrans.core.module.en