-
公开(公告)号:CN115269161A
公开(公告)日:2022-11-01
申请号:CN202211213027.X
申请日:2022-09-30
Applicant: 浙江省公众信息产业有限公司无线运营分公司
Abstract: 本发明涉及一种异常流程逆向回滚方法,包括kafka平台接收conductor服务执行主流程处理完成后生成的流程执行数据;回滚服务端监听kafka平台并消费监听到的流程执行数据,并根据主流程结果数据,判断主流程是否需要回滚;回滚服务端判断主流程需要回滚时,获取流程执行数据,并根据任务节点数据获取主流程中已执行完成的任务节点,将所有已执行完成的任务节点放入回滚链表中,利用回滚链表、主流程结果数据和任务节点数据,进行主流程的回滚。本发明还涉及异常流程逆向回滚系统。本发明实现了无需通过发送指令进行触发回滚,回滚前不需要备份数据,回滚过程中不需要查询日志信息,提高了异常流程的回滚效率。
-
公开(公告)号:CN115269161B
公开(公告)日:2022-12-20
申请号:CN202211213027.X
申请日:2022-09-30
Applicant: 浙江省公众信息产业有限公司无线运营分公司
Abstract: 本发明涉及一种异常流程逆向回滚方法,包括kafka平台接收conductor服务执行主流程处理完成后生成的流程执行数据;回滚服务端监听kafka平台并消费监听到的流程执行数据,并根据主流程结果数据,判断主流程是否需要回滚;回滚服务端判断主流程需要回滚时,获取流程执行数据,并根据任务节点数据获取主流程中已执行完成的任务节点,将所有已执行完成的任务节点放入回滚链表中,利用回滚链表、主流程结果数据和任务节点数据,进行主流程的回滚。本发明还涉及异常流程逆向回滚系统。本发明实现了无需通过发送指令进行触发回滚,回滚前不需要备份数据,回滚过程中不需要查询日志信息,提高了异常流程的回滚效率。
-