[go: up one dir, main page]

CN117389528A - Service-oriented configurable workflow engine working method and device - Google Patents

Service-oriented configurable workflow engine working method and device Download PDF

Info

Publication number
CN117389528A
CN117389528A CN202311489814.1A CN202311489814A CN117389528A CN 117389528 A CN117389528 A CN 117389528A CN 202311489814 A CN202311489814 A CN 202311489814A CN 117389528 A CN117389528 A CN 117389528A
Authority
CN
China
Prior art keywords
workflow engine
node
service
workflow
task
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Pending
Application number
CN202311489814.1A
Other languages
Chinese (zh)
Inventor
陈海量
杨付全
张鸿杰
张文
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Fujian Boss Software Co ltd
Original Assignee
Fujian Boss Software Co ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Fujian Boss Software Co ltd filed Critical Fujian Boss Software Co ltd
Priority to CN202311489814.1A priority Critical patent/CN117389528A/en
Publication of CN117389528A publication Critical patent/CN117389528A/en
Pending legal-status Critical Current

Links

Classifications

    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F8/00Arrangements for software engineering
    • G06F8/20Software design

Landscapes

  • Engineering & Computer Science (AREA)
  • Software Systems (AREA)
  • General Engineering & Computer Science (AREA)
  • Theoretical Computer Science (AREA)
  • Physics & Mathematics (AREA)
  • General Physics & Mathematics (AREA)
  • Management, Administration, Business Operations System, And Electronic Commerce (AREA)

Abstract

本发明涉及面向服务的可配置型工作流引擎工作方法及设备,包括:创建工作流程;工作流引擎执行所述工作流程;在执行过程中,工作流引擎按流程节点配置的接口信息,调用外部业务系统并接收调用结果;异常处理器获取各流程节点的执行状态信息并进行异常处理。

The invention relates to a service-oriented configurable workflow engine working method and equipment, which includes: creating a workflow; the workflow engine executes the workflow; during the execution process, the workflow engine calls external interface information according to the interface information configured by the process node. The business system receives the call results; the exception handler obtains the execution status information of each process node and handles exceptions.

Description

面向服务的可配置型工作流引擎工作方法及设备Service-oriented configurable workflow engine working method and equipment

技术领域Technical field

本发明涉及面向服务的可配置型工作流引擎工作方法及设备,属于工作流领域。The invention relates to a service-oriented configurable workflow engine working method and equipment, and belongs to the field of workflow.

背景技术Background technique

工作流(Workflow),是对工作流程及其各操作步骤之间业务规则的抽象、概括描述。工作流建模,即将工作流程中的工作如何前后组织在一起的逻辑和规则,在计算机中以恰当的模型表達并对其实施计算。工作流要解决的主要问题是:为实现某个业务目标,利用计算机在多个参与者之间按某种预定规则自动传递文档、信息或者任务。Workflow is an abstract and general description of the workflow and the business rules between each operation step. Workflow modeling refers to expressing the logic and rules of how the work in the workflow is organized together in an appropriate model in the computer and implementing calculations on it. The main problem to be solved by workflow is to use computers to automatically transfer documents, information or tasks between multiple participants according to certain predetermined rules in order to achieve a certain business goal.

在处理大规模或高频任务时,现有工作流引擎可能面临性能瓶颈,导致任务处理速度下降,这对于需要高吞吐量的应用程序是一个不容忽视的问题。因此,需要一种能适应高并发环境的工作流引擎。When processing large-scale or high-frequency tasks, existing workflow engines may face performance bottlenecks, resulting in a slowdown in task processing, which is a problem that cannot be ignored for applications that require high throughput. Therefore, a workflow engine that can adapt to high concurrency environments is needed.

发明内容Contents of the invention

为了克服现有技术中存在的问题,本发明设计了面向服务的可配置型工作流引擎工作方法及设备。In order to overcome the problems existing in the prior art, the present invention designs a service-oriented configurable workflow engine working method and equipment.

为了实现上述目的,本发明采用如下技术方案:In order to achieve the above objects, the present invention adopts the following technical solutions:

技术方案一Technical solution one

面向服务的可配置型工作流引擎工作方法,包括以下步骤:The working method of the service-oriented configurable workflow engine includes the following steps:

创建工作流程;Create workflow;

工作流引擎执行所述工作流程;在执行过程中,工作流引擎按流程节点配置的接口信息,调用外部服务并接收调用结果;The workflow engine executes the workflow; during the execution process, the workflow engine calls external services according to the interface information configured by the process node and receives the call results;

异常处理器获取各流程节点的执行状态信息并进行异常处理。The exception handler obtains the execution status information of each process node and handles exceptions.

进一步地,还包括:创建表单,绑定表单和流程节点。Furthermore, it also includes: creating forms, binding forms and process nodes.

进一步地,所述创建工作流程,包括:Further, the creation workflow includes:

设计开始节点、申请节点、流程节点、流程变量、网关、触发器以及结束节点;Design start nodes, application nodes, process nodes, process variables, gateways, triggers and end nodes;

将开始节点与发起表单绑定,并选择候选人;Bind the start node to the initiation form and select candidates;

为审批节点配置审批表单并选择候选人;Configure the approval form for the approval node and select candidates;

将网关与流程变量进行绑定;Bind the gateway to process variables;

对流程节点配置触发器或外部服务。Configure triggers or external services on process nodes.

进一步地,工作流引擎执行节点任务时,每调用一次外部服务就相应新建一存有任务状态信息的任务表单;外部服务提供者和工作流引擎通过任务表单同步任务信息。Furthermore, when the workflow engine executes a node task, a new task form containing task status information is created every time an external service is called; the external service provider and the workflow engine synchronize task information through the task form.

进一步地,异常处理器从任务表单获取外部服务的执行状态,以实现补偿机制、重试和映射异常等功能。Further, the exception handler obtains the execution status of the external service from the task form to implement functions such as compensation mechanism, retry, and mapping exceptions.

技术方案二Technical solution two

面向服务的可配置型工作流引擎工作设备,包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序,所述处理器执行所述程序时实现如技术方案一所述步骤。The service-oriented configurable workflow engine working equipment includes a memory, a processor, and a computer program stored in the memory and executable on the processor. When the processor executes the program, it implements the steps described in the first technical solution. .

与现有技术相比本发明有以下特点和有益效果:Compared with the prior art, the present invention has the following characteristics and beneficial effects:

本发明提供一套完整的配置机制通过S10步骤和S20步骤来实现表单创建和流程创建,每个业务流程分解为一系列可单独执行的服务,通过S20步骤,使得用户可以根据实际需求灵活地组合和调整这些服务,从而形成满足特定业务场景的工作流程。此外,本发明还提供了一套完善的服务管理和调度机制,通过步骤S2050、步骤S40、步骤S50,能够确保各个服务之间能够按照预定的顺序和规则进行交互,支持分布式事务。同时,可以保存整个流程执行的健壮性和易维护性。通过步骤S10、步骤S20流程与业务服务的分离,解决了业务并发量大的问题。The present invention provides a complete set of configuration mechanisms to realize form creation and process creation through steps S10 and S20. Each business process is decomposed into a series of services that can be executed independently. Through step S20, users can flexibly combine according to actual needs. and adjust these services to form workflows that meet specific business scenarios. In addition, the present invention also provides a complete set of service management and scheduling mechanisms. Through steps S2050, S40, and S50, it can ensure that various services can interact according to predetermined order and rules and support distributed transactions. At the same time, the robustness and maintainability of the entire process execution can be preserved. Through the separation of the process and business services in steps S10 and S20, the problem of large business concurrency is solved.

附图说明Description of the drawings

图1是本发明示意图。Figure 1 is a schematic diagram of the present invention.

具体实施方式Detailed ways

下面结合实施例对本发明进行更详细的描述。The present invention will be described in more detail below with reference to examples.

实施例一Embodiment 1

如图1所示,一种面向服务的可配置型工作流系统,包括:As shown in Figure 1, a service-oriented configurable workflow system includes:

表单设计器,用于创建表单,如发起表单、审批表单等;Form designer, used to create forms, such as initiation forms, approval forms, etc.;

流程设计器,用于创建工作流程,工作流程包括若干流程节点并配置流程节点之间的关系。特别地,在创建工作流程时,对流程节点配置触发器或调用外部服务;Process designer is used to create workflows. The workflow includes several process nodes and configures the relationships between process nodes. In particular, when creating a workflow, configure triggers on process nodes or call external services;

流程管理平台,用于发布流程,使其实例化;Process management platform, used to publish processes and instantiate them;

异常处理器,用于跟踪和监控工作流状态,了解已完成的任务和即将执行的操作等信息。同时记录执行过程中出错的信息以便于分析和恢复。Exception handler, used to track and monitor workflow status, understand completed tasks and upcoming operations, etc. At the same time, error information during execution is recorded to facilitate analysis and recovery.

工作流引擎,根据预设的顺序或条件控制工作流向下一个节点移动,并自动或手动执行各个节点任务以完成整个过程调度。在工作流程执行过程中,工作流引擎按流程节点配置的接口信息,调用外部业务系统并接收调用结果。The workflow engine controls the workflow to move to the next node according to a preset sequence or conditions, and automatically or manually executes each node task to complete the entire process scheduling. During the execution of the workflow, the workflow engine calls the external business system according to the interface information configured by the process node and receives the call results.

实施例二Embodiment 2

如图1所示,面向服务的可配置型工作流引擎工作方法,包括以下步骤:As shown in Figure 1, the working method of the service-oriented configurable workflow engine includes the following steps:

S10:设计表单,如发起表单、审批表单,通过使用表单设计器完成;S10: Design forms, such as initiation forms and approval forms, by using the form designer;

S20:利用流程设计器来创建流程:S20: Use process designer to create processes:

S2010:设计开始节点、申请节点、流程节点、流程变量、网关、触发器以及结束节点;S2010: Design start node, application node, process node, process variable, gateway, trigger and end node;

S2020:将开始节点与发起表单绑定,并选择候选人;S2020: Bind the start node to the initiation form and select candidates;

S2030:为审批节点配置审批表单并选择候选人;S2030: Configure the approval form for the approval node and select candidates;

S2040:将网关与流程变量进行绑定;S2040: Bind the gateway to the process variables;

S2050:流程节点可配置触发器或调用外部服务,这一步通常与业务系统联动以完成服务管理;S2050: The process node can configure triggers or call external services. This step is usually linked with the business system to complete service management;

S2060:保存已完成的流程设计;S2060: Save the completed process design;

S30:在流程管理平台上发布相应的流程,使其实例化;S30: Publish the corresponding process on the process management platform and instantiate it;

S40:候选人填写相关内容在流程发起表单上,并点击提交申请,从而触发工作流。此时,工作流引擎会根据预设的顺序或条件控制工作流向下一个节点移动,并自动或手动执行各个节点任务以完成整个过程调度。S40: The candidate fills in the relevant content on the process initiation form and clicks to submit the application, thereby triggering the workflow. At this time, the workflow engine will control the workflow to move to the next node according to the preset sequence or conditions, and automatically or manually execute each node task to complete the entire process scheduling.

S50:异常处理器跟踪和监控工作流状态,了解已完成的任务和即将执行的操作等信息。同时记录执行过程中出错的信息以便于分析和恢复,如进行补偿、轮询、重试等操作。S50: The exception handler tracks and monitors the workflow status to understand information such as completed tasks and upcoming operations. At the same time, error information during execution is recorded to facilitate analysis and recovery, such as compensation, polling, retry and other operations.

S60:当所有任务都已正确完成后,该工作流实例则结束。S60: When all tasks have been completed correctly, the workflow instance ends.

实施例三Embodiment 3

进一步地,工作流引擎执行节点任务时,每调用一次外部服务就相应新建一任务表单,任务表单存有任务状态信息,包括:外部服务提供者标识、调用时间等。外部服务提供者和工作流引擎通过任务表单同步任务信息;异常处理器从任务表单获取外部服务的执行状态,以实现补偿机制、重试和映射异常等功能。Furthermore, when the workflow engine executes a node task, a new task form is created every time an external service is called. The task form stores task status information, including: external service provider identification, call time, etc. The external service provider and the workflow engine synchronize task information through the task form; the exception handler obtains the execution status of the external service from the task form to implement functions such as compensation mechanism, retry, and mapping exceptions.

需要说明的是,在本发明各个实施例中的各功能单元/模块可以集成在一个处理单元/模块中,也可以是各个单元/模块单独物理存在,也可以是两个或两个以上单元/模块集成在一个单元/模块中。上述集成的单元/模块既可以采用硬件的形式实现,也可以采用软件功能单元/模块的形式实现。It should be noted that each functional unit/module in various embodiments of the present invention can be integrated into one processing unit/module, or each unit/module can exist physically alone, or it can be two or more units/modules. Modules are integrated in one unit/module. The above integrated units/modules can be implemented in the form of hardware or software functional units/modules.

通过以上的实施方式的描述,所属领域的技术人员可以清楚地了解应当理解,可以以硬件、软件、固件、中间件、代码或其任何恰当组合来实现这里描述的实施例。对于硬件实现,处理器可以在一个或多个下列单元中实现:专用集成电路(ASIC)、数字信号处理器(DSP)、数字信号处理设备(DSPD)、可编程逻辑器件(PLD)、现场可编程门阵列(FPGA)、处理器、控制器、微控制器、微处理器、设计用于实现这里所描述功能的其他电子单元或其组合。对于软件实现,实施例的部分或全部流程可以通过计算机程序来指令相关的硬件来完成。实现时,可以将上述程序存储在计算机可读介质中或作为计算机可读介质上的一个或多个指令或代码进行传输。计算机可读介质包括计算机存储介质和通信介质,其中通信介质包括便于从一个地方向另一个地方传送计算机程序的任何介质。存储介质可以是计算机能够存取的任何可用介质。计算机可读介质可以包括但不限于RAM、ROM、EEPROM、CD-ROM或其他光盘存储、磁盘存储介质或者其他磁存储设备、或者能够用于携带或存储具有指令或数据结构形式的期望的程序代码并能够由计算机存取的任何其他介质。Through the above description of the embodiments, those skilled in the art can clearly understand that the embodiments described herein can be implemented in hardware, software, firmware, middleware, code, or any appropriate combination thereof. For hardware implementation, the processor may be implemented in one or more of the following units: Application Specific Integrated Circuit (ASIC), Digital Signal Processor (DSP), Digital Signal Processing Device (DSPD), Programmable Logic Device (PLD), Field Programmable Programmable gate array (FPGA), processor, controller, microcontroller, microprocessor, other electronic unit designed to perform the functions described herein, or combinations thereof. For software implementation, part or all of the processes of the embodiments can be completed by instructing relevant hardware through a computer program. When implemented, the above-mentioned program may be stored in a computer-readable medium or transmitted as one or more instructions or codes on a computer-readable medium. Computer-readable media includes computer storage media and communication media including any medium that facilitates transfer of a computer program from one place to another. Storage media can be any available media that can be accessed by the computer. Computer-readable media may include, but are not limited to, RAM, ROM, EEPROM, CD-ROM or other optical disk storage, magnetic disk storage media or other magnetic storage devices, or may be used to carry or store desired program code in the form of instructions or data structures and any other media that can be accessed by a computer.

最后应当说明的是,以上实施例仅用以说明本发明的技术方案,而非对本发明保护范围的限制,尽管参照较佳实施例对本发明作了详细地说明,本领域的普通技术人员应当分析,可以对本发明的技术方案进行修改或者等同替换,而不脱离本发明技术方案的实质和范围。Finally, it should be noted that the above embodiments are only used to illustrate the technical solutions of the present invention, and are not intended to limit the protection scope of the present invention. Although the present invention has been described in detail with reference to the preferred embodiments, those of ordinary skill in the art should analyze , the technical solution of the present invention may be modified or equivalently substituted without departing from the essence and scope of the technical solution of the present invention.

Claims (10)

1. A service-oriented configurable workflow engine operating method, comprising the steps of:
creating a workflow;
a workflow engine executing the workflow; in the execution process, the workflow engine calls external services according to interface information configured by the flow nodes and receives call results;
the exception handler obtains the execution state information of each flow node and carries on the exception handling.
2. The service-oriented configurable workflow engine operating method of claim 1, further comprising: creating a form, binding the form and the flow node.
3. The service-oriented configurable workflow engine operating method of claim 1, wherein the creating workflow comprises:
designing a starting node, an application node, a flow variable, a gateway, a trigger and an ending node;
binding the starting node with the initiating form and selecting a candidate;
configuring an approval form for the approval node and selecting a candidate;
binding the gateway and the flow variable;
the flow node configures the trigger or external service.
4. The service-oriented configurable workflow engine working method of claim 1, wherein when the workflow engine executes node tasks, a task form with task state information is correspondingly created every time an external service is called; the external service provider and the workflow engine synchronize task information via a task form.
5. The service-oriented configurable workflow engine operating method of claim 4, wherein the exception handler obtains the execution status of the external service from the task form to implement a compensation mechanism, retry and map exceptions.
6. A service-oriented configurable workflow engine work device comprising a memory, a processor and a computer program stored on the memory and executable on the processor, characterized in that the processor implements the following steps when executing the program:
creating a workflow;
a workflow engine executing the workflow; in the execution process, the workflow engine calls external services according to interface information configured by the flow nodes and receives call results;
the exception handler obtains the execution state information of each flow node and carries on the exception handling.
7. The service-oriented configurable workflow engine work device of claim 6, further comprising: creating a form, binding the form and the flow node.
8. The service-oriented configurable workflow engine work device of claim 6, wherein the creation workflow comprises:
designing a starting node, an application node, a flow variable, a gateway, a trigger and an ending node;
binding the starting node with the initiating form and selecting a candidate;
configuring an approval form for the approval node and selecting a candidate;
binding the gateway and the flow variable;
the flow node configures the trigger or external service.
9. The service-oriented configurable workflow engine work apparatus of claim 6, wherein when the workflow engine performs a node task, a task form with task state information is created correspondingly every time an external service is called; the external service provider and the workflow engine synchronize task information via a task form.
10. The service-oriented configurable workflow engine work device of claim 9 wherein the exception handler obtains the execution status of the external service from the task form to implement a compensation mechanism, retry and map exceptions.
CN202311489814.1A 2023-11-09 2023-11-09 Service-oriented configurable workflow engine working method and device Pending CN117389528A (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202311489814.1A CN117389528A (en) 2023-11-09 2023-11-09 Service-oriented configurable workflow engine working method and device

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202311489814.1A CN117389528A (en) 2023-11-09 2023-11-09 Service-oriented configurable workflow engine working method and device

Publications (1)

Publication Number Publication Date
CN117389528A true CN117389528A (en) 2024-01-12

Family

ID=89437270

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202311489814.1A Pending CN117389528A (en) 2023-11-09 2023-11-09 Service-oriented configurable workflow engine working method and device

Country Status (1)

Country Link
CN (1) CN117389528A (en)

Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20040078373A1 (en) * 1998-08-24 2004-04-22 Adel Ghoneimy Workflow system and method
CN104102949A (en) * 2014-06-27 2014-10-15 北京奇艺世纪科技有限公司 Distributed workflow device and method for processing workflow by distributed workflow device
CN114663063A (en) * 2022-03-30 2022-06-24 中信百信银行股份有限公司 Method, device and equipment for realizing workflow engine and storage medium
CN115292022A (en) * 2022-09-29 2022-11-04 泰豪软件股份有限公司 Workflow engine system, implementation method, storage medium and computer equipment
CN115907683A (en) * 2022-12-19 2023-04-04 国泰君安证券股份有限公司 Implementation system and method of workflow engine based on financial product management

Patent Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20040078373A1 (en) * 1998-08-24 2004-04-22 Adel Ghoneimy Workflow system and method
CN104102949A (en) * 2014-06-27 2014-10-15 北京奇艺世纪科技有限公司 Distributed workflow device and method for processing workflow by distributed workflow device
CN114663063A (en) * 2022-03-30 2022-06-24 中信百信银行股份有限公司 Method, device and equipment for realizing workflow engine and storage medium
CN115292022A (en) * 2022-09-29 2022-11-04 泰豪软件股份有限公司 Workflow engine system, implementation method, storage medium and computer equipment
CN115907683A (en) * 2022-12-19 2023-04-04 国泰君安证券股份有限公司 Implementation system and method of workflow engine based on financial product management

Similar Documents

Publication Publication Date Title
CN109684057B (en) Task processing method, device and storage medium
Mitschele-Thiel Systems Engineering with SDL: Developing Performance-Critical Communication
CN112230904A (en) Code generation method and device based on interface document, storage medium and server
US7131080B2 (en) Simulation management system
US7685266B2 (en) Management of tools that process data to describe a physical layout of a circuit
CN116089040A (en) Scheduling method of business process and its device, electronic equipment and storage medium
CN117389528A (en) Service-oriented configurable workflow engine working method and device
CN109063040B (en) Client program data collection method and system
CN115292348A (en) Database processing method and system, electronic equipment and storage medium
CN116244272A (en) A data migration method, system, device and medium
CN111026509A (en) Method, system and storage medium for operation and maintenance remote host to execute operation
CN107506299B (en) Code analysis method and terminal equipment
CN109101321A (en) A kind of message monitoring method and device based on cloud platform
CN111290855A (en) GPU card management method, system and storage medium for multi-GPU server in distributed environment
CN118626485A (en) Configuration method, computer readable medium and system for form data verification
WO2023185137A1 (en) Task management method and apparatus, and device and storage medium
CN101111012A (en) Base station configuration system and method
CN117075812A (en) Host system cloning method and device
CN117215834A (en) System, method and equipment for saving and recovering simulation break points based on componentized modeling
CN116303276A (en) A method of springbatch nested script to realize file export
CN102521133A (en) TCL (tool command language)-based white-box testing automation method and TCL-based white-box testing automation system
CN107741963A (en) Cross-cluster data merging method and device, electronic equipment, computer storage medium
CN113342332B (en) An implementation method for customizable multi-interfaces based on model-driven components
CN112597121A (en) Logic script processing method and device, electronic equipment and storage medium
CN118885392A (en) Test data construction method and device based on generative artificial intelligence

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination