CN119415180A 一种工作流实例的启动方法、装置、设备及服务系统 （苏州元脑智能科技有限公司）

并按照工作流实例执行其中各个节点的审批操作。本方法使得审批流程的启动更加精准和高2根据预设关联关系在所述消息队列中，实时监听工作流服务反馈的述预设关联关系包括每种类型的业务与一个主题之间的对应根据所述目标响应消息中的内容，确定所述审批业务请求对应的工作流实例启动成建立至少一个业务服务的至少一个关联关系，每个所述关联关解析所述目标响应消息，得到审批流程的所述工作流实例所要关联的业务所述根据所述目标响应消息中的内容，确定所述审批业务请求对应的如果解析所述目标响应消息后，得到的内容包含所述启将所述工作流实例的唯一标识更新到所述数据表中ID值为第一取值在所述消息队列中接收所述工作流服务执行当前节点审批后的根据所述通知消息，在指示字段为通过审批的情况下，基于所述监听第一业务服务通过消息队列发送的审批业务请求，所述审批业务3解析所述审批业务请求，根据所述审批业务请求中的内容创建工作流根据预设关联关系将所述目标响应消息发送至消息队列，以使所述根据所述工作流实例所要关联的业务ID、业务关联的实例关键字、调用工作流服务中定义的通用审批入口，对所述工作将所述通知消息添加到所述消息队列中，以使对应的业务服务在所使用Activiti作为流程执行框架，基于至少一个业务服务端第一发送模块，用于向消息队列发送审批业务请求，所述且所述审批流程至少与第二业务服务的审批第一监听模块，用于根据预设关联关系在所述消息队列中，解析模块，用于当监听到所述审批业务请求对应的目标响应消息时，解确定模块，用于根据所述目标响应消息中的内容，确定第二监听模块，用于监听第一业务服务通过消息队列发送处理模块，用于解析所述审批业务请求，根据所述审批业务请求中4第二发送模块，用于根据预设关联关系将所述目标响应消息述第一业务服务在所述消息队列中监听和获得所述目标响应消息，所述预设关联关系包所述存储器中存储有计算机指令，所述处理器通过执行所述计算机指所述消息队列，用于收发每个业务服务端和所述工作流服务端之间所述工作流服务端，用于执行如权利要求5至8中任一项所述的工作流实例的启动方5[0002]随着计算机技术发展，越来越多的业务审批流程被转移到公司管理系统中实[0004]在工作流中涉及多个服务，比如服务A为部署的工作流服务，使用Java语言的6[0024]监听第一业务服务通过消息队列发送的审批业务请服务与该第一业务服务要监听的主题之间的对应7[0032]调用工作流服务中定义的通用审批入口，对所述工作流实例中各个节点进行审反馈的响应消息，其中所述预设关联关系包括每种类型的业务与一个主题之间的对应关述第一方面或第二方面对应的任一实施方式所述的工作流实8算机执行上述第一方面或第二方面对应的任一实施方式所述的工[0059]图5是根据本发明实施例的一种工作流服务与实际业务服务的数据流转的信令[0060]图6是根据本发明实施例的一种工作流服务与实际业务服务的数据流转的示意9[0067]下面所描述的本发明不同实施方式中所涉及的技术特征只要彼此之间未构成冲[0070]微服务，是指在单个应用中包含众多松散耦合且可单独部署的小型组件或服[0074]工作流实例(WorkflowInstance)是计算机科学技术名词，具体指的是按工作流[0084]Kafka是一个开源的[0086]数据流处理功能是指：Kafka支持实时数据处理和分析，通过KafkaStreams和式使用前端接口不统一，并在前端提交审批方案后通知其关联的实际业务执行本业务工[0094]RPC虽然可以实现微服务之间的跨编程语言通信，但是它需要为不同编程语言编用Http的调用方式要求服务A的执行时间不宜过长，否则可能导致服务B等待服务A执行结点的工作流审批流程和相关节点的业务代码执行流程)只需要单独处理实际业务的代码，D业务中使用了相同的工作流模型时，可以通过工作流审批的统一入口实现工作流节点的[0101]本公开的技术方案以微服务作为架构基础，使用消息队列进行服务间通信和调流服务所有与本业务关联的响应都将发送到指定的T[0132]④当前业务关联的实例关键字(businessKey)，用于后期接收反馈信息后要去哪到审批流程的工作流实例所要关联的业务ID(businessId)、业务关联的实例关键字[0145]工作流解析引擎进行解析并记录相关数据：工作流解析ID和其他相关信息发送给具体的业务服务。这些信息会被发送到业务服务监听的主题得不同的服务可以独立地进行开发和部署，同时通过消息队列进行有效的协作和数据交[0155]工作流服务A通过消息队列中预设的关联关系，即步骤S100_1服务A与topic_a之[0158]根据工作流实例所要关联的业务ID(businessId)、业务关联的实例关键字[0159]在实例启动成功后将工作流实例ID和其他相关信息反馈给具体业务服务。具体[0164]本实施例中，在工作流服务端，比如服务A一侧的功能或方法，还包括：使用[0169]如图6所示，审批流程的类型名称是CommonAuditProcess，该审批流程包括“申每个业务在每个审批节点完成后又需要单独[0177]其中，Kafka软件是根据预先建立的topic_a与服务A中的唯一业务之间关系确定[0179]可选的，Kafka软件对业务内部的相关数据进行处理(如特殊字段修改)得到相关[0194]工作流解析引擎，将关联数据记录到数据库中，如包括instanceId(10001)、的解析引擎将启动成功的信息反馈回去给业务服务B，通过上面关联关系发现要将反馈数后解析到成功(code为200表示启动成功)，并发现其instanceNodbusinessKey中查找到BusinessB实例关联的数据表，并将工作流实例ID(10001)更新到表务B对topic_b中监听到的通知消息或信息进行解析后，确定下一个要执行的节点为务反馈的响应消息，其中所述预设关联关系包括每种类型的业务与一个主题(Topic)之间以使所述第一业务服务在所述消息队列中监听和获得目标响应消息，预设关联关系包括：个处理器10执行实现上述实施例示出的工作流实至少一个功能所需要的应用程序；存储数据区可存储根据电子设备的使用所创建的数据[0257]本实施例提供的服务系统，在业务服务端启动并向消息存储在远程存储介质或非暂时机器可读存储介质中并将被存储在本地存储介质中的计算以以一种或多种程序设计语言的任意组合来编写用于执行本公开实施例操作的程序代码