一种基于消息队列的分布式事务处理方法及系统

基本信息

申请号 CN201911404579.7 申请日 -
公开(公告)号 CN111158933A 公开(公告)日 2020-05-15
申请公布号 CN111158933A 申请公布日 2020-05-15
分类号 G06F9/54 分类 计算;推算;计数;
发明人 王海峰 申请(专利权)人 易票联支付有限公司
代理机构 广州嘉权专利商标事务所有限公司 代理人 谭英强;黎扬鹏
地址 510000 广东省广州市海珠区广州大道南368号11楼
法律状态 -

摘要

摘要 本发明公开了一种基于消息队列的分布式事务处理方法及系统,方法包括:对发送的消息进行顺序编号;将发送的消息及其顺序编号写入发送日志;发送消息给服务端,使服务端获取消息的顺序编号并与第一数据库中存储的顺序编号进行比较,当二者的顺序编号不连续则确定缺漏的起始顺序编号和结束顺序编号,当二者的顺序编号连续则将消息发送给消息队列;根据起始顺序编号和结束顺序编号从发送日志中获取缺漏数据,并将缺漏数据发送给服务端。本发明利用了发送日志和在第一数据库这一非关系型数据库中存储的顺序编号来保证消息发送成功,从而确保了消息队列与业务系统的数据一致性,也简化了业务系统的开发过程。本发明可广泛应用于计算机技术领域。