(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211245219.9 (22)申请日 2022.10.12 (71)申请人 青岛民航凯亚系统集成有限公司 地址 266000 山东省青岛市城阳区棘洪滩 街道春阳路西端动车小镇科技馆230 室 (72)发明人 王晓辉　房暾　张建翔　张道钰　 刘晓疆　陈晓　刘青　战嘉馨　 张新华　薛玲祥　 (74)专利代理 机构 青岛海知誉知识产权代理事 务所(普通 合伙) 37290 专利代理师 高凤全 (51)Int.Cl. G06F 9/48(2006.01) G06F 9/54(2006.01)G06F 11/14(2006.01) G06Q 40/04(2012.01) G06Q 50/34(2012.01) (54)发明名称 高并发的彩票交易场景 下数据一致性方法 (57)摘要 本发明涉及一种高并发的彩票交易场景下 数据一致性方法， 属于计算机技术领域。 包括以 下步骤： （1） 将状态机客户端绑定至各服务节点， 负责将各服务节点的执行状态 通知状态机引擎， 并接收状态机引擎的调度命令； 在一致性流程中 的各环节分别设置回滚 方法， 由状态机客户端根 据状态机引擎的执行状态进行调度； （2） 状态机 引擎接收状态机客户端的执行状态， 负责流程管 理以及状态处理。 本发明的优点是： 实现数据的 最终状态 一致。 在保证 彩票交易流程高效运转的 前提下， 通过合理的任务调度， 实现交易数据的 一致。 权利要求书2页 说明书5页 附图3页 CN 115309536 A 2022.11.08 CN 115309536 A 1.高并发的彩票交易场景 下数据一致性方法， 其特 征在于， 包括以下步骤： （1） 将状态机客户端绑定至各服务节点， 负责将各服务节点的执行状态通知状态机引 擎， 并接收状态机引擎的调 度命令； 在一致性流程中的各环节分别设置回滚方法， 由状态机 客户端根据状态机引擎的执 行状态进行调度； （2） 状态机引擎接收状态机客户端的执 行状态， 负责流 程管理以及状态处 理。 2.根据权利要求1所述的高并发的彩票交易场景下数据一致性方法， 其特征在于， 所述 的状态机客户端包括状态监听步骤和失败回调步骤， 所述的状态监听的步骤具体为： 针对 流程起始方法， 在执行前向状态机引擎注册全局流程， 获取全局流程ID， 作为当前 交易流程 的唯一标识保存至业务数据中， 该标识同时作为异常回滚时的识别标识； 针对结束环节， 执 行成功后向状态机引擎发送完成通知， 表示流程成功结束； 执行状态将通过消息机制通知 到状态机引擎， 由状态机引擎 根据结果进行后续的调度。 3.根据权利要求2所述的高并发的彩票交易场景下数据一致性方法， 其特征在于， 所述 的失败回调的具体步骤为： 当交易流程中某一环节执行异常， 状态机引擎将对所有已执行 环节发起回滚调 度， 失败回调模块监听到回滚命令后， 提取全局流程ID， 调用当前模块的回 滚方法， 回滚方法中对已执 行的业务按照指定 逻辑进行恢复。 4.根据权利要求2或3所述的高并发的彩票交易场景下数据一致性方法， 其特征在于， 所述的状态机引擎包括流程管理的步骤以及进程控制的步骤， 所述的流程管理的步骤包 括： 对一致性流程进 行定义及配置， 对于 当前交易场景来说， 流程包含创建订单、 扣减额度、 处理风控和出票四个环节， 通过状态图配置服务调用流程， 根据场景需求配置各个环节的 补偿节点及 补偿路径， 当流 程环节执行异常时将按配置的方案进行流 程回滚。 5.根据权利要求4所述的高并发的彩票交易场景下数据一致性方法， 其特征在于， 所述 的进程控制的步骤具体包括： 针对流程开始、 执行成功、 执行失败、 流程完成的状态提供处 理方法， 流程开始由入口方法触发， 该入口方法即业务控制层接 收到交易请求后路由到的 下单接口， 控制器生成全局 流程数据， 状态标为执行中； 执行成功由状态客户端反馈， 控制 器获取流程及子服务信息， 生成子服务执行成功记录； 执行失败由状态机客户端反馈， 控制 器获取流程及子服务信息， 根据流程配置判断是否需要回滚流程和回滚路径， 流程状态标 为待回滚， 分别向需要回滚的服务发送 回退通知， 通过状态机客户端的失败回退调度回滚 方法进行业务回滚， 各子服务回滚成功后反馈， 全部成功后流程状态标为已回滚； 流程完成 由入口方法触发， 将流 程状态标为已完成， 代 表流程正常终结。 6.根据权利要求4所述的高并发的彩票交易场景下数据一致性方法， 其特征在于， 当风 控环节异常时， 回滚机制具体为： （1） 业务控制层接收到下单请求， 将请求路由至下单接口， 在下单接口执行之前调用状 态机引擎注册流程， 状态机引擎生成流程记录， 将状态标为执行中， 将记录标识返回业务控 制层； （2） 业务控制层执 行生成订单的业 务逻辑， 执 行成功， 发送生成订单成功消息； （3） 状态机引擎接收到生成订单成功消息， 由成功处理接口进行处理， 记录生成订单成 功日志； （4） 业务控制层继续执 行扣减额度的业 务逻辑， 执 行成功， 发送扣减额度成功消息； （5） 状态机引擎接收到扣减额度成功消息， 由成功处理接口进行处理， 记录扣减额度成权　利　要　求　书 1/2 页 2 CN 115309536 A 2功日志； （6） 业务控制层继续执 行处理风控的业 务逻辑， 执 行失败， 发送风控失败消息； （7） 状态机引擎接收到风控失败消息， 由失败处理接口进行处理， 查询流  程配置， 得知 当前节点异常需回滚的环 节为扣减额度， 发送扣减额度回滚消息； （8） 扣减额度服务接收到回滚额度消息， 调度回滚方法， 执行成功后发送回滚成功消 息； （9） 状态机引擎接收到回滚成功消息， 修改扣减额度成功日志状态为已回滚， 查询当前 流程所有需回滚的操作记录， 全部已回滚完成， 将流 程记录标记为已回滚。 7.根据权利要求5所述的高并发的彩票交易场景下数据一致性方法， 其特征在于， 所述 的流程状态包括执行中、 待回滚、 已回滚和已完成状态， 其中， 已回滚和已完成的状态为终 态， 代表流程异常 并已回滚为一致状态或正常结束； 对于长时间处于非终态的流程， 说明业 务流程执行或与状态机引擎的交互出现问题， 当出现上述问题 时， 采用定时轮询的方式筛 查异常流 程， 并进行重试操作。权　利　要　求　书 2/2 页 3 CN 115309536 A 3