CN103425462B

CN103425462B - A kind of method and apparatus of workflow data persistence

Info

Publication number: CN103425462B
Application number: CN201210149423.0A
Authority: CN
Inventors: 章向明
Original assignee: Alibaba Group Holding Ltd
Current assignee: Alibaba Group Holding Ltd
Priority date: 2012-05-14
Filing date: 2012-05-14
Publication date: 2016-12-14
Anticipated expiration: 2032-05-14
Also published as: CN103425462A

Abstract

This application provides the method and device of a kind of workflow data persistence, wherein, described method includes: extract the information on services of statement in service end configuration file；Create dynamic proxy class for the service interface of statement in client configuration file, and generate the tactful configuration information of described service interface；Obtain and need the target operation flow data carrying out persistence；Call described workflow data persistence service interface and obtain its dynamic proxy class, and at described dynamic proxy apoplexy due to endogenous wind, described target operation flow data is assembled into event；Run described event according to the configuration information of described workflow data persistence strategy, it is thus achieved that the workflow data persistence information on services that described event is corresponding, and according to described workflow data persistence information on services, target operation flow data is carried out persistence operation.The application can save maintenance cost, strengthens the autgmentability of working flow products.

Description

A kind of method and apparatus of workflow data persistence

Technical field

The application relates to the technical field that Work stream data processes, and particularly relates to the side of a kind of workflow data persistence Method and the device of a kind of workflow data persistence.

Background technology

Workflow (Work Flow) is exactly the computation model of workflow, will be before and after the work how in workflow The logic organized together and rule are indicated with appropriate model and in a computer to the calculation that in fact plays tricks.Workflow to solve Subject matter certainly is: for realizing certain business objective, between multiple participants, utilize computer, by certain pre-defined rule Automatically document, information or task are transmitted.Briefly, workflow is exactly a series of business work being mutually linked, automatically carrying out Move or task.Regarding whole business procedure as Yi Tiaohe, the river wherein flow through is exactly workflow.

Workflow belong to computer supported cooperative work (Computer Supported Cooperative Work, CSCW) a part.The latter is how one colony of research at large realizes collaborative work with the help of computer.

Many companies use paper list, the mode of manual transmission, and one-level one-level is signed after examination, and work efficiency is the lowest Under, then can not realize for statistical report form function.And using working flow software, user only need to fill in relevant table on computers Single, the most down can run according to the flow process defined, next stage approver will receive related data, it is possible to repaiies as required Change, follow the tracks of, manage, inquire about, add up, printing etc., substantially increase efficiency.

The persistence of Work stream data is a requisite ingredient of working flow products, conventional operation miscarriage product Data persistence implementation, it is impossible to meet various persistence demand, with commonly used in the prior art without invade flexibly As a example by the products such as JBPM3, JBPM4 (Java Business Process Management, BPM), it achieves A kind of mode synchronizing persistence Work stream data, based on products such as described JBPM3, JBPM4, prior art also teaches one The persistence mode of Work stream data improved, specifically includes following steps:

Step one: the code of the stream perdurable data that finds a job, inside increases a judgment mechanism.

If it find that flow process context exists asynchronous mark, then call asynchronous queue, do the operation of asynchronous perdurable data. If synchronized, then directly invoke synchronous method.

Step 2: when there being a new persistence demand, such as: need according to a route specified, calls remotely Server asynchronous persistence flow data.Again change code this time, increase and judge and corresponding identifier.

Realize it can be seen that the scheme of prior art is form based on hard coded, whenever increasing a kind of persistence mode Time, it is required for revising code.Add the cost of maintenance, be unfavorable for the extension of business.

Therefore, the technical problem that current those skilled in the art are in the urgent need to address is.The most creative carries Go out the mechanism of a kind of workflow data persistence, in order to save maintenance cost, strengthen the autgmentability of working flow products.

Summary of the invention

The purpose of the application is to provide the method and apparatus of a kind of workflow data persistence, in order to improve computer with each Plant the safety of user terminal application, become the problem that those skilled in the art are in the urgent need to address.

In order to solve the problems referred to above, a kind of method that this application discloses workflow data persistence, including:

Extract the information on services of statement in service end configuration file；Wherein, described information on services includes that Work stream data is held Change information on services for a long time；

Create dynamic proxy class for the service interface of statement in client configuration file, and generate the plan of described service interface Slightly configuration information；Wherein, described service interface includes that workflow data persistence service interface, described strategy configuration information include The tactful configuration information of workflow data persistence；

Obtain and need the target operation flow data carrying out persistence；

Call described workflow data persistence service interface and obtain its dynamic proxy class, and at described dynamic proxy apoplexy due to endogenous wind Described target operation flow data is assembled into event；

Described event is run, it is thus achieved that described event is corresponding according to the configuration information of described workflow data persistence strategy Workflow data persistence information on services, and according to described workflow data persistence information on services, target operation flow data is entered Row persistence operates.

Preferably, described workflow data persistence information on services includes: service interface realize class, service interface is real The address of existing class, service interface realizes the parameter type of statement in the method for apoplexy due to endogenous wind and method；

In described extraction service end configuration file after the step of the information on services of statement, described method also includes:

Described information on services is registered in service end container according to the first preset data form.

Preferably, described the first preset data form includes:

Service container and registration class ServiceRegistry, wherein, member variable includes: expression comprises various the most of the same name The information on services set static Map<String, ServiceInfo claimed>；

Information ServiceInfo that service interface realizes, wherein, member variable includes: service interface realize class, expose Service interface, service interface realizes the address serviceURI of class, service interface realize apoplexy due to endogenous wind method information aggregate Map < String,OperationInfo>；

Service interface realizes information OperationInfo of apoplexy due to endogenous wind method, and wherein, member variable includes: method name, method The parameter information set List<ParameterInfo of middle statement>, method returns value information ReturnInfo returnInfo) Method abnormal information set List<ExceptionInfo>, method object (Method method)；

The parameter information ParameterInfo of statement in method, wherein, member variable includes: parameter type String TypeName, parameter type class Class type；

Method returns value information ReturnInfo, and wherein, member variable includes: return Value Types String typeName, Return Value Types class Class type；

Method abnormal information ExceptionInfo, wherein, member variable includes: Exception Type String typeName, Exception Type class Class type.

Preferably, after in for client configuration file, the service interface of statement creates the step of dynamic proxy class, Described method also includes:

Described dynamic proxy class is registered in client container.

Preferably, the configuration information of described workflow data persistence strategy includes:

When expression event occurs, the Event Policies eventName of the behavior act of execution；

When representing storage information, use the storage strategy storeRule of certain storage mode；

Represent the routing policy routeRule of the routing mechanism of message transmission；

The service of the position that expression interface realizes class place realizes address endpointUrl；

Represent the regulative strategy invokeType of the method for calling of event information；

And/or,

After representing that message is consumed successfully, the loopback address callbackUri of the address of readjustment initiator automatically.

Preferably, described event is unified event；Described call workflow data persistence service interface obtain its move State proxy class, and at described dynamic proxy apoplexy due to endogenous wind, the step that target operation flow data is assembled into event is included:

Workflow data persistence service interface is called from described client container；

The dynamic proxy class of correspondence is called by described workflow data persistence service interface；

At described dynamic proxy apoplexy due to endogenous wind, realize the parameter of statement in the method for apoplexy due to endogenous wind and method according to described service interface Type, and, the tactful configuration information of workflow data persistence, by described target operation flow data according to the second preset number It is assembled into unified event according to form.

Preferably, described the second preset data form includes:

Unified event object UniformEvent: wherein, member variable includes: sequence of events ID eventId, event name Claiming eventName, event call-back address callbackUri, event creates time createdTime, and event sends the time SendedTime, the unified message object UniformMessage of band in event；

Unified message object UniformMessage: wherein, member variable includes: message id messageId, message header UniformMessageHeader, message body UniformMessagePlayload, Message Processing result return value Object response；

Unified message body object UniformMessagePlayload: wherein, member variable includes: parameter list Object []params；

Unified message head object UniformMessageHeader: wherein, member variable includes: the name of event EventName, event call-back address callbackUri, the time createdTime that message produces, message sends the time SendedTime, service end realizes address endpointUrl, method name methodName, the time of Message Schemas consumption PlanTime, storage rule storeRule, routing rule routeRule, time-out time timeout, failure number of retries Retry, method of calling: synchronous/asynchronous invokeType.

Preferably, the described configuration information according to workflow data persistence strategy runs described event, it is thus achieved that described The workflow data persistence information on services that event is corresponding, and according to described workflow data persistence information on services to target work The step carrying out persistence operation as flow data includes:

Obtain the method for calling of message in the event configured according to described regulative strategy, if synchronization call, then trigger institute Stating event, described event has event title；

Realizing class according to the described corresponding action listener of event name acquiring, described action listener realizes class according to described thing The configuration of part strategy generates；

Realize apoplexy due to endogenous wind at described action listener, according to described routing policy, search and be located locally or long-range service interface Realize the address of class；

Realize the address of class according to described service interface, find corresponding service interface to realize class from service end container；

Call described service interface and realize class, described target operation flow data is saved in the work fluxion of Local or Remote According in storehouse.

Preferably, before calling described workflow data persistence service interface, described method also includes:

Affairs are started in default task manager；

The described configuration information according to workflow data persistence strategy runs described event, it is thus achieved that described event is corresponding Workflow data persistence information on services, and according to described workflow data persistence information on services, target operation flow data is entered The step of row persistence operation includes:

Obtain the method for calling of message in the event configured according to described regulative strategy, if asynchronous call, then create thing Business lock unit, and registration transactions lock unit in described task manager；

Submit affairs to, call transactional synchronization device, according to the message in described storage strategy preservation event, then event is added Enter in asynchronous queue；

When asynchronous queue's audiomonitor has listened to event addition, trigger described event；

The corresponding action listener of name acquiring according to described event realizes class, and described action listener realizes class according to described Event Policies configuration generates；

Call described service interface and realize class, described target operation flow data is saved in the work fluxion of Local or Remote According in storehouse；

Call successfully if described service interface realizes class, then according to described storage strategy, delete the event message preserved, Then according to described loopback address, readjustment initiator notify to operate successfully；

If described service interface realizes class malloc failure malloc, then according to described loopback address, readjustment initiator performs to compensate industry Business operation.

Preferably, described acquisition needs the step carrying out the target operation flow data of persistence to include:

Flow instance starts circulation, runs into the node needing to preserve data, the data of node instance is saved in flow process In the ordered queue hereinafter specified；

Flow instance circulation terminates, and obtaining the node instance data in described ordered queue is to need to carry out the mesh of persistence Mark Work stream data.

The embodiment of the present application also discloses the device of a kind of workflow data persistence, including:

Service end configuration module, for extracting the information on services of statement in service end configuration file；Wherein, described service letter Breath includes workflow data persistence information on services；

Client configuration module, for creating dynamic proxy class for the service interface of statement in client configuration file, and Generate the tactful configuration information of described service interface；Wherein, described service interface includes workflow data persistence service interface, Described strategy configuration information includes the tactful configuration information of workflow data persistence；

Work stream data acquisition module, needs, for obtaining, the target operation flow data carrying out persistence；

Proxy class calling module, is used for calling described workflow data persistence service interface and obtains its dynamic proxy class, And at described dynamic proxy apoplexy due to endogenous wind, described target operation flow data is assembled into event；

Event execution module, runs described event for the configuration information according to described workflow data persistence strategy, Obtain the workflow data persistence information on services that described event is corresponding, and according to described workflow data persistence information on services Target operation flow data is carried out persistence operation.

Described device also includes:

Service container Registering modules, is connected with described service end configuration module, is used for described information on services according to preset The first data form be registered in service end container.

Preferably, described the first preset data form includes:

Preferably, described device, also include:

Client container Registering modules, is connected with described client configuration module, for described dynamic proxy class being registered In client container.

And/or,

Preferably, described event is unified event；Described proxy class calling module includes:

Service interface calls submodule, connects for calling workflow data persistence service from described client container Mouthful；

Dynamic proxy class extracts submodule, for being called the dynamic of correspondence by described workflow data persistence service interface Proxy class；

Event assembles submodule, in described dynamic proxy apoplexy due to endogenous wind, the method realizing apoplexy due to endogenous wind according to described service interface And the parameter type of statement in method, and, the tactful configuration information of workflow data persistence, by described target operation stream Data are assembled into unified event according to the second preset data form.

Preferably, described the second preset data form includes:

Preferably, described event execution module includes:

First event triggers module, for obtaining the called side of message in the event configured according to described regulative strategy Formula, if synchronization call, then triggers described event, and described event has event title；

Action listener submodule, for realizing class, described event according to the described corresponding action listener of event name acquiring Monitoring realizes class and generates according to the configuration of described Event Policies；

Route submodule, for realizing apoplexy due to endogenous wind at described action listener, according to described routing policy, search be located locally or Long-range service interface realizes the address of class；

Realize class locator module, for realizing the address of class according to described service interface, find from service end container Corresponding service interface realizes class；

Persistence operator module, is used for calling described service interface and realizes class, is preserved by described target operation flow data In the workflow database of Local or Remote.

Preferably, described device, also include:

Affairs start module, for starting affairs in default task manager；

Described event execution module includes:

Transactional synchronization device creates submodule, for obtaining the called side of message in the event configured according to described regulative strategy Formula, if asynchronous call, then creates transactional synchronization device, and registration transactions lock unit in described task manager；

Transaction commitment processing submodule, is used for submitting affairs to, calls transactional synchronization device, preserves thing according to described storage strategy Message in part, then adds event in asynchronous queue；

Second event triggers module, when asynchronous queue's audiomonitor has listened to event addition, triggers described event；

Action listener submodule, for realizing class, described thing according to the corresponding action listener of name acquiring of described event Part is monitored and is realized class according to the configuration generation of described Event Policies；

Persistence operator module, is used for calling described service interface and realizes class, is preserved by described target operation flow data In the workflow database of Local or Remote；

Call and be successfully processed submodule, for described service interface realize class call successfully time, then according to described storage Strategy, deletes the event message preserved, and then according to described loopback address, readjustment initiator notify to operate successfully；

Malloc failure malloc processes submodule, for realizing class malloc failure malloc at described service interface, then according to described readjustment ground Location, readjustment initiator performs to compensate business operation.

Preferably, described Work stream data acquisition module includes:

Data genaration submodule, starts circulation for flow instance, runs into the node needing to preserve data, by node instance Data be saved in flow process context in the ordered queue specified；

Data extract submodule, terminate for flow instance circulation, obtain the node instance data in described ordered queue For needing to carry out the target operation flow data of persistence.

Compared with prior art, the application includes advantages below:

Present applicant proposes a kind of brand-new workflow data persistence strategy Configuration Framework, according to the feelings of workflow business Condition, during as increased a kind of persistence mode, it is not necessary to amendment code, it is only necessary to simple modification configuration file, can unrestricted choice thing Part strategy, the strategy of the workflow data persistence such as message storage is tactful, routing policy, regulative strategy realizes Work stream data Preserve, such that it is able to save maintenance cost, strengthen the autgmentability of working flow products.

Accompanying drawing explanation

Fig. 1 is the workflow diagrams as a example by loaning bill business of going on business；

Fig. 2 is the flow chart of steps of the embodiment of the method for a kind of workflow data persistence of the application；

Fig. 3 is the flow process of the concrete example of a kind of workflow data persistence method execution of application the embodiment of the present application Figure；

Fig. 4 is the structured flowchart of the device embodiment of a kind of workflow data persistence of the application.

Detailed description of the invention

Understandable for enabling the above-mentioned purpose of the application, feature and advantage to become apparent from, real with concrete below in conjunction with the accompanying drawings The application is described in further detail by mode of executing.

For making those skilled in the art be more fully understood that the application, below with " loaning bill of going on business " this concrete business for The related notion term that bright the application relates to.

With reference to the flow chart of the loaning bill business of going on business shown in Fig. 1, when employee goes on business, can be used for purchasing to corporate loans in advance Pay one's fare, the expense such as board and lodging.Corporate policy, employee go on business loan application the amount of money less than or equal to 5000 yuans time, need Supervisor's examination & approval, after supervisor's examination & approval, need financial approval, finally fund are beaten money in the wage card of employee by bank.If The amount of money that employee borrows money more than 5000 yuans, then needs supervisor's examination & approval, after supervisor's examination & approval, needs manager again to examine, warp Need financial approval after reason examination & approval, finally fund is beaten money in the wage card of employee by bank.If supervisor, manager or wealth Business examination & approval disagree, then need to send out mail and inform employee.

Term is explained as follows:

Node: refer to that some operational action defines.In this example, " financial approval " is exactly a node, and this node needs Very important person participates in, referred to as task node." money is beaten by bank " is also a node, and this node participates in without people, the most automatically joint Point.Node represents with rectangle frame in FIG." judgement borrowing balance " this activity, is used for judging that flow process is after this node Which from branch continue, referred to as decision node.

Directed connection: refer to the line of band arrow in Fig. 1, represent flow process from a state by which kind of mode to another shape State.As in this example, between manager's examination & approval node to financial approval node, there is a directed connection being " agreement ".

Flow definition: the symbol being used to describe some operation flow represents, by node and directed connection form quiet State definition file.

Terms above is all the concept of flow process configuration class, and related notion process flow operation during is described below.

Active instance: refer to the node instance of certain the most concrete service request process.Such as: Xiao Wang plans 2010 10 The moon goes to Beijing to go on business on 15th, loan application 7000 yuan.Xiao Wang is o'clock sharp in the morning 9 on October 14th, 2010, in Workflow system Submit application process to.Being responsible for and examine on October 14th, 2010 o'clock sharp in the morning 10, then flow process continues to walk downward.Wherein, describe The example of " supervisor's examination & approval " this activity is active instance.Generally active instance comprises this activity time started, end time, meter Draw and process people, actual treatment people, the information of subscription time etc. different dimensions.

Flow instance: refer to certain the most concrete service request.Such as: Xiao Wang goes to Beijing to go on business on October 15th, 2010, Loan application 7000 yuan.Flow instance is made up of a series of active instance.In the flow instance of this example indication, if Finally examine agreement, then comprise start node " application of going on business " active instance, " supervisor's examination & approval " active instance, " judge gold of borrowing money Volume " active instance, " manager's examination & approval " active instance, " financial approval " active instance, " money is beaten by bank " active instance, " end " lives Dynamic example.

Flow process context variable example: refer in certain the most concrete service request, for transmitting information between node Data.The usually form performance of name-value pair (key-value).General context variable instance refers to each flow instance, Regardless of whether belong to same flow definition, the context variable example all having.On context variable example is often referred to simply as Hereafter variable.

One of core idea of the embodiment of the present application is, creative proposes a kind of situation according to workflow business, Have only to simple modification configuration file, get final product unrestricted choice Event Policies, message storage strategy, routing policy, regulative strategy etc. The strategy of workflow data persistence, to realize the mechanism that Work stream data preserves.

With reference to Fig. 2, it is shown that the flow chart of steps of the embodiment of the method for a kind of workflow data persistence of the application, tool Body may include steps of:

Step 201, extracts the information on services of statement in service end configuration file；

Wherein, described information on services includes workflow data persistence information on services.

In implementing, described workflow data persistence information on services may include that the class that realizes of service interface, clothes Business interface realizes the address of class, and service interface realizes the parameter type of statement in the method for apoplexy due to endogenous wind and method.Need explanation It is that in described method, the parameter type of statement does not refer to concrete data, and refers to that service interface realizes the method reception of apoplexy due to endogenous wind The parameter of what type, is the statement of parameter type.

In a preferred embodiment of the present application, after described step 201, following steps can be performed:

Step 202, is registered to described information on services in service end container according to the first preset data form.

In implementing, upon power-up of the system, (service end configuration file is usually can to configure XML according to service end XML file), by the service registry stated in XML to service end container.XML is configured, by statement in XML according to service end Service registry is in service container.

A kind of example specifically applied as the embodiment of the present application, described the first preset data form can include as follows Content:

Certainly, the data form of above-mentioned service end container is solely for example, and those skilled in the art are according to the actual requirements It is all feasible for using any one data form, the application to this without being any limitation as.

Step 203, creates dynamic proxy class for the service interface of statement in client configuration file, and generates described service The tactful configuration information of interface；

Wherein, described service interface can include workflow data persistence service interface, and described strategy configuration information can To include the tactful configuration information of workflow data persistence.Described information on services and service interface have corresponding relation, described Workflow data persistence information on services is corresponding with workflow data persistence service interface.

Dynamic proxy class is that the reflex mechanism utilizing java generates.Current Java kit contained dynamic generation The support of reason. it realizes main by being java.lang.reflect.Proxy class and java.lang.reflect.Invoca TionHandler interface.

Proxy class is mainly used to obtain dynamic proxy object, and it is real that InvocationHandler interface is used for retraining caller Existing, as follows, the operational approach of HelloWorld interface definition, HelloWorldImpl is the realization of HelloWorld interface, HelloWorldHandler is that InvocationHandler interface realizes.Code is as follows:

Business interface:

InvocationHandler realizes, and needs to add some before and after calling interface method and processes work, the most only Only export two character strings before and after method call to backstage, its code is as follows:

Test code:

First obtain a business interface realizes object；

Obtain an InvocationHandler to realize, be HelloWorldHandler object herein；

Create dynamic proxy object；

By dynamic proxy object reference sayHelloWorld () method, now can be in primary object Two character strings are exported before and after HelloWorldImpl.sayHelloWorld () method.

The output of testing results class is as follows:

before method invoke！

Hello World！

after method invoke！

The method call code of Test apoplexy due to endogenous wind is the most herein, can be simplified by configuration file in actual applications Client call realization.

In implementing, XML (client configuration file, usually XML file) can be configured according to client, for In XML, the service interface of statement creates dynamic proxy class, and configuration event strategy eventName, the tactful storeRule of storage, Routing policy routeRule, service realizes address endpointUrl, regulative strategy invokeType, loopback address The strategy of the workflow data persistence such as callbackUri.

Specifically, the strategy of described workflow data persistence may include that

And/or,

Certainly, above-mentioned strategy configuration is solely for example, and those skilled in the art use any one plan according to the actual requirements It is all feasible for slightly configuring, the application to this without being any limitation as.

In a preferred embodiment of the present application, after described step 103, following steps can be performed:

Step 204, is registered to described dynamic proxy class in client container.

In implementing, after dynamic proxy class is registered in client container, client follow-up use when, Can obtain the most from container.

Step 205, it is thus achieved that need to carry out the target operation flow data of persistence；

A kind of example specifically applied as the embodiment of the present application, described step 205 can include following sub-step:

Sub-step S11, flow instance start circulation, run into the node needing to preserve data, the data of node instance are protected It is stored in flow process context in the ordered queue specified；

The circulation of sub-step S12, flow instance terminates, and obtaining the node instance data in described ordered queue is that needs are carried out The target operation flow data of persistence.

Step 206, call described workflow data persistence service interface and obtain its dynamic proxy class, and described dynamically Described target operation flow data is assembled into event by proxy class；

In implementing, can be before calling described workflow data persistence service interface, in default affairs Manager starts affairs, calls local service database manipulation, then recall workflow data persistence service interface.Its In, described affairs i.e. refer to local service db transaction, as a example by loan application of going on business, wherein, the place gone on business, the time, sky Number, the list of going on business of origin of an incident composition, it is simply that business datum, calls local service database manipulation and i.e. refers to preserve the industry of list of going on business Business data.

In a preferred embodiment of the present application, described event is unified event；Described step 206 specifically can include Following sub-step:

Sub-step S21, from described client container, call workflow data persistence service interface；

Sub-step S22, by described workflow data persistence service interface call correspondence dynamic proxy class；

Sub-step S23, at described dynamic proxy apoplexy due to endogenous wind, realize according to described service interface in method and the method for apoplexy due to endogenous wind The parameter type of statement, and, the tactful configuration information of workflow data persistence, by described target operation flow data according in advance The the second data form put is assembled into unified event.

Simply illustrate below by way of one and call described workflow data persistence service interface to obtain it dynamic The principle of proxy class:

Flow engine A apoplexy due to endogenous wind calls com.ali.xbpm.eda.test.EdaWorkflowService interface.A apoplexy due to endogenous wind One section of code is as follows:

EdaWorkflowService workflowClient=(EdaWorkflowService) ContextFactory

.get(“workflowClient”)；

workflowClient.storeProcess(bpmProcInst,contextMap,queue)

It is found that this workflow persistence service interface of EdaWorkflowService in epimere code, it is logical Cross acquisition in client container ContextFactory.Owing to being configured by client, create for this service interface Dynamic proxy class.So obtain from ContextFactory is dynamic proxy class, and non-real service interface realizes Class.

Owing to dynamic proxy class is according to client configuration file, the reflex mechanism of java is utilized to generate.It is actually It is that of interface realizes class.During the reflex mechanism utilizing java generates, just by the plan of workflow data persistence Slightly configuration information (the most various strategy configuration) reads, and is saved in the member variable of dynamic proxy class.Also because of dynamic generation Reason class, is exactly that another of interface realizes class, so can receive in method and the method that service interface realizes apoplexy due to endogenous wind in fact The data of the parameter type of statement.

Method for reflection below by way of one section of code description java:

The method of Java Method apoplexy due to endogenous wind:

java.lang.reflect.Method.invoke(Object obj,Object...args)throws IllegalAccessException,IllegalArgumentException,InvocationTargetException

Wherein, obj is exactly interface class name, and args is actual parameter list.

A kind of example specifically applied as the embodiment of the present application, described the second preset data form may include that

Certainly, the assemble method of above-mentioned event is solely for example, and those skilled in the art use according to the actual requirements and appoint A kind of assemble method is all feasible, the application to this without being any limitation as.

Step 207, runs described event according to the configuration information of described workflow data persistence strategy, it is thus achieved that described thing The workflow data persistence information on services that part is corresponding, and according to described workflow data persistence information on services to target operation Flow data carries out persistence operation.

In a preferred embodiment of the present application, described step 207 can include following sub-step:

Sub-step S31, obtain the method for calling of message in the event configured according to described regulative strategy, if same step With, then triggering described event, described event has event title；

Sub-step S32, realizing class according to the described corresponding action listener of event name acquiring, described action listener realizes class Generate according to the configuration of described Event Policies；

Sub-step S33, realize apoplexy due to endogenous wind at described action listener, according to described routing policy, search and be located locally or remotely Service interface realize the address of class；

Sub-step S34, realize the address of class according to described service interface, find corresponding service to connect from service end container The existing class of cause for gossip；

Sub-step S35, call described service interface and realize class, described target operation flow data is saved in Local or Remote Workflow database in.

In another preferred embodiment of the present application, described step 207 can include following sub-step:

Sub-step S41, obtain the method for calling of message in the event configured according to described regulative strategy, if asynchronous tune With, then create transactional synchronization device, and registration transactions lock unit in described task manager；

Utilizing transactional synchronization device, purpose is contemplated to ensure the Work stream data of local service data and (Local or Remote) Can have transaction consistency.

Sub-step S42, submission affairs, call transactional synchronization device, according to the message in described storage strategy preservation event, so After event is added in asynchronous queue；

When sub-step S43, asynchronous queue's audiomonitor have listened to event addition, trigger described event；

Sub-step S44, the corresponding action listener of name acquiring according to described event realize class, and described action listener realizes Class generates according to the configuration of described Event Policies；

Sub-step S45, realize apoplexy due to endogenous wind at described action listener, according to described routing policy, search and be located locally or remotely Service interface realize the address of class；

Sub-step S46, realize the address of class according to described service interface, find corresponding service to connect from service end container The existing class of cause for gossip；

Sub-step S47, call described service interface and realize class, described target operation flow data is saved in Local or Remote Workflow database in；

Call successfully if the described service interface of sub-step S48 realizes class, then according to described storage strategy, delete and preserved Event message, then according to described loopback address, readjustment initiator notify to operate successfully；

If the described service interface of sub-step S49 realizes class malloc failure malloc, then according to described loopback address, adjust back initiator Perform to compensate business operation.

For making those skilled in the art be more fully understood that the embodiment of the present application, below in conjunction with the application the application shown in Fig. 3 Embodiment is operated the flow chart of flow data persistence operation, is further illustrated by a concrete example.

Step one: configure XML according to service end, by the service registry stated in XML to service container, (i.e. service end is held Device) in (step 1 (1) in Fig. 3).

Wherein, the data form of service end container includes:

ServiceRegistry class: service end container and registration class

Member variable: static Map<String, ServiceInfo>, represent the service letter comprising various different names Breath set.

ServiceInfo information on services: describe the information that service interface realizes.

Member variable: the supplier of service (i.e. interface realize class), the service interface (can be multiple interface) of exposure, The address (String type serviceURI) of service, method information aggregate (Map<String, OperationInfo>).

OperationInfo method information: describe the information of method.

Member variable: method name, and method parameter information aggregate (List<ParameterInfo>), method returns value information (ReturnInfo returnInfo), and method abnormal information set (List<ExceptionInfo>), method object (Method method)。

ParameterInfo method parameter information: describe the information of method parameter.

Member variable: parameter type (String typeName), parameter type class (Class type)

ReturnInfo method returns value information: describe the return value information of method.

Member variable: return Value Types (String typeName), returns Value Types class (Class type)

ExceptionInfo method abnormal information: describe the abnormal information of method.

Member variable: Exception Type (String typeName), Exception Type class (Class type)

The example code of a kind of the embodiment of the present application presented below service end configuration file used in implementing:

Step 2: configure XML according to client, creates dynamic proxy, configuration event strategy for the interface of statement in XML EventName, storage strategy storeRule, routing policy routeRule, service realizes address endpointUrl, calls plan Slightly invokeType, loopback address callbackUri.(step 1 (2) in Fig. 3)

Wherein, Event Policies: represent when event occurs, the behavior act of execution.Including local method call event, remotely Mina calls event etc..

Storage strategy: when representing storage information, use which kind of storage mode.Storing including berkeleyDb, mysql stores Deng.

Routing policy: represent the routing mechanism of message transmission.Such as: circulation in local Java Virtual Machine, in remote procedure The heart circulates.

Service realizes address: represent that interface realizes the position at class place.Can be local, it is also possible to be long-range.

Regulative strategy: represent the method for calling of event information.Such as: synchronization call (sync), asynchronous call (async), Asynchronous reliably call (asyncrely) etc..

Loopback address: after representing that message is consumed successfully, automatically adjust back the address of initiator.

The example code of a kind of the embodiment of the present application presented below client configuration file used in implementing:

Step 3: flow instance starts circulation, runs into the node needing to preserve data, by node instance (i.e. active instance) Data are saved in flow process context in the ordered queue specified.(in Fig. 3 step 3,4)

Step 4: flow instance circulation terminates.Start to start affairs, call local service database manipulation, adjust the most again With Work stream data persistence service interface.This interface is exactly the interface of statement in step 2.It is actual that call is the dynamic of interface State proxy class.Described workflow data persistence service interface gets from the ordered queue of described flow process context accordingly Node instance data.(in Fig. 3 step 5,6,7,8,9)

Step 5: dynamic proxy apoplexy due to endogenous wind, according to the method for interface, parameter, is assembled into unified event.(step 10 in Fig. 3)

The data structure of unified event is as follows:

UniformEvent: unified event, is to support successor strategy, routing policy, and message storage strategy calls plan Cover object slightly.Event object does not transmits when cross-system calls.

Member variable has: sequence of events ID (eventId), the name of event (eventName, successor strategy according to This title determines), event call-back URI (loopback address after callbackUri, i.e. message success or failure), when event creates Between (createdTime), event send the time (sendedTime), in event band message object (UniformMessage).

UniformMessage: unified message, for the carrier of cross-system transmission data.

Member variable has: message id (messageId), message header (UniformMessageHeader), message body (UniformMessagePlayload), Message Processing result return value (Object response).

UniformMessagePlayload: unified message body object.

Member variable has: parameter list (Object [] params)

UniformMessageHeader: unified message head object.

Member variable has: the name [eventName] of event, event call-back URI [callbackUri], and message produces Time [createdTime], message sends the time [sendedTime], and service end realizes address [endpointUrl], method name [methodName], the time [planTime] of Message Schemas consumption, storage rule [storeRule], routing rule [routeRule], time-out time [timeout], failure number of retries [retry], method of calling: synchronous/asynchronous [invokeType]。

With loan application of going on business as example.After flow instance starts, entrance etc. after start node, supervisor's examination & approval node Treat state.Now have invoked workflow persistence service interface to preserve Work stream data, example code is as follows:

EdaWorkflowService workflowClient=(EdaWorkflowService) ContextFactory

.get(“workflowClient”)；

workflowClient.storeProcess(bpmProcInst,contextMap,queue)

Parameter list has: flow instance bpmProcInst, context Map data contextMap, in queue queue is Active instance data (the active instance data of supervisor's examination & approval node)

The unified event object assembled is as follows:

public class UniformEvent{

private String eventId；// sequence of events ID [unique id that system automatically generates]

private String eventName；The name [configuration read in step 2] of // event

private String callbackUri；// event call-back URI [configuration read in step 2]

private long createdTime；// event creates the time [system automatically generates current time]

private long sendedTime；// event sends the time [system automatically generates current time]

private UniformMessage message；The message object [assembling in dynamic proxy class] of band in // event

Assemble in dynamic proxy class and refer to this object following:

public class UniformMessage implements Serializable{

Private static final long serialVersionUID=1L；

private String messageId；// message id, UUID character string [unique id that system automatically generates]

private UniformMessageHeader header；// message header [assembles in proxy class]

private UniformMessagePlayload playload；// message body [assembles in proxy class]

I.e. parameter list has: flow instance bpmProcInst, and context Map data contextMap, in queue queue It is active instance data (the active instance data of supervisor's examination & approval node)

Step 6: according to the method for calling (i.e. regulative strategy) of message in event, calls event engine scheduling class.(in Fig. 3 Step 11)

If synchronization call, then trigger event, according to concrete event title, call different action listeners and realize class (i.e. Event Policies) (in Fig. 3 step 12.3,13.1).Then nine are gone to step.

If asynchronous call, then create transactional synchronization device, and registration transactions lock unit (in Fig. 3 in task manager Step 12,12.1,12.2).Then seven are gone to step.

Step 7, submits affairs to, calls transactional synchronization device, and the message in preservation event is (according to storage message policies, optional Select mysql and berkeleydb and carry out the storage of message), then event is added in asynchronous queue (step 13 in Fig. 3,14, 15、16)。

Step 8, asynchronous queue's audiomonitor, listened to event and added, then trigger event.According to concrete event title, Call different action listeners and realize class (i.e. Event Policies) (step 17 in Fig. 3).

Step 9, realizes apoplexy due to endogenous wind at action listener, according to routing policy, finds the service implementing type address of Local or Remote (step 18 in Fig. 3).

Step 10, according to service implementing type address, finds registered interface really to realize class from service end container.So After call this and realize class persistence Work stream data, Work stream data is preserved to the workflow database of Local or Remote (step 19 in Fig. 3,20).

Step 11: after calling successfully, if method of calling is asynchronous, according to storage strategy, deletes the event preserved Message.Then according to loopback address, readjustment initiator notifies successfully automatically；After malloc failure malloc, according to loopback address, automatically adjust back Initiator does compensation business operation (in Fig. 3 step 21,22).

One section of example code realizing above-mentioned steps six to step 11 presented below:

Application the embodiment of the present application, can be according to the situation of workflow business, it is only necessary to simply revise configuration file, i.e. Can unrestricted choice Event Policies, message storage strategy, routing policy, the workflow data persistence service strategy such as regulative strategy, Save maintenance cost, greatly strengthen the autgmentability of working flow products.

It should be noted that for embodiment of the method, in order to be briefly described, therefore it is all expressed as a series of action group Closing, but those skilled in the art should know, the application is not limited by described sequence of movement, because according to this Shen Please, some step can use other orders or carry out simultaneously.Secondly, those skilled in the art also should know, description Described in embodiment belong to preferred embodiment, necessary to involved action and module not necessarily the application.

With reference to Fig. 4, it is shown that the structured flowchart of the device embodiment of a kind of workflow data persistence of the application, specifically Can include such as lower module:

Service end configuration module 401, for extracting the information on services of statement in service end configuration file；Wherein, described clothes Business information includes workflow data persistence information on services；

Client configuration module 402, for creating dynamic proxy class for the service interface of statement in client configuration file, And generate the tactful configuration information of described service interface；Wherein, described service interface includes that workflow data persistence service connects Mouthful, described strategy configuration information includes the tactful configuration information of workflow data persistence；

Work stream data acquisition module 403, needs, for obtaining, the target operation flow data carrying out persistence；

Proxy class calling module 404, is used for calling described workflow data persistence service interface and obtains its dynamic proxy Class, and at described dynamic proxy apoplexy due to endogenous wind, described target operation flow data is assembled into event；

Event execution module 405, runs described thing for the configuration information according to described workflow data persistence strategy Part, it is thus achieved that the workflow data persistence information on services that described event is corresponding, and service according to described workflow data persistence Information carries out persistence operation to target operation flow data.

In implementing, described workflow data persistence information on services may include that the class that realizes of service interface, clothes Business interface realizes the address of class, and service interface realizes the parameter type of statement in the method for apoplexy due to endogenous wind and method；

In a preferred embodiment of the present application, described device can also include such as lower module:

Service container Registering modules, is connected with described service end configuration module 401, is used for described information on services according in advance The the first data form put is registered in service end container.

A kind of example specifically applied as the embodiment of the present application, the configuration information of described workflow data persistence strategy May include that

And/or,

In implementing, described event is unified event；Described proxy class calling module 404 can include following submodule Block:

A kind of example specifically applied as the embodiment of the present application, described the second preset data form can include as follows Content:

In a preferred embodiment of the present application, described event execution module 405 can include following submodule:

As another preferred embodiment of the present application, described device can also include that affairs start module, is used for The task manager preset starts affairs；

In this case, described event execution module 405 can include following submodule:

In implementing, described Work stream data acquisition module 403 includes:

For device embodiment, due to itself and embodiment of the method basic simlarity, so describe is fairly simple, relevant Part sees the part of embodiment of the method and illustrates.

Those skilled in the art are it should be appreciated that embodiments herein can be provided as method, system or computer program Product.Therefore, the reality in terms of the application can use complete hardware embodiment, complete software implementation or combine software and hardware Execute the form of example.And, the application can use at one or more computers wherein including computer usable program code The upper computer program product implemented of usable storage medium (including but not limited to disk memory, CD-ROM, optical memory etc.) The form of product.

The application is with reference to method, equipment (system) and the flow process of computer program according to the embodiment of the present application Figure and/or block diagram describe.It should be understood that can the most first-class by computer program instructions flowchart and/or block diagram Flow process in journey and/or square frame and flow chart and/or block diagram and/or the combination of square frame.These computer programs can be provided Instruction arrives the processor of general purpose computer, special-purpose computer, Embedded Processor or other programmable data processing device to produce A raw machine so that the instruction performed by the processor of computer or other programmable data processing device is produced for real The device of the function specified in one flow process of flow chart or multiple flow process and/or one square frame of block diagram or multiple square frame now.

These computer program instructions may be alternatively stored in and computer or other programmable data processing device can be guided with spy Determine in the computer-readable memory that mode works so that the instruction being stored in this computer-readable memory produces and includes referring to Make the manufacture of device, this command device realize at one flow process of flow chart or multiple flow process and/or one square frame of block diagram or The function specified in multiple square frames.

These computer program instructions also can be loaded in computer or other programmable data processing device so that at meter Perform sequence of operations step on calculation machine or other programmable devices to produce computer implemented process, thus at computer or The instruction performed on other programmable devices provides for realizing at one flow process of flow chart or multiple flow process and/or block diagram one The step of the function specified in individual square frame or multiple square frame.

Although having been described for the preferred embodiment of the application, but those skilled in the art once know basic creation Property concept, then can make other change and amendment to these embodiments.So, claims are intended to be construed to include excellent Select embodiment and fall into all changes and the amendment of the application scope.

Finally, in addition it is also necessary to explanation, in this article, the relational terms of such as first and second or the like be used merely to by One entity or operation separate with another entity or operating space, and not necessarily require or imply these entities or operation Between exist any this reality relation or order.And, term " includes ", " comprising " or its any other variant meaning Containing comprising of nonexcludability, so that include that the process of a series of key element, method, article or equipment not only include that A little key elements, but also include other key elements being not expressly set out, or also include for this process, method, article or The key element that equipment is intrinsic.In the case of there is no more restriction, statement " including ... " key element limited, do not arrange Except there is also other identical element in including the process of described key element, method, article or equipment.

Method and a kind of workflow data persistence to a kind of workflow data persistence provided herein above Device be described in detail, principle and the embodiment of the application are set forth by specific case used herein, The explanation of above example is only intended to help and understands the present processes and core concept thereof；Simultaneously for this area one As technical staff, according to the thought of the application, the most all will change, to sum up institute Stating, this specification content should not be construed as the restriction to the application.

Claims

1. the method for a workflow data persistence, it is characterised in that including:

Extract the information on services of statement in service end configuration file；Wherein, described information on services includes workflow data persistence Information on services；

Create dynamic proxy class for the service interface of statement in client configuration file, and the strategy generating described service interface is joined Confidence ceases；Wherein, described service interface includes that workflow data persistence service interface, described strategy configuration information include work The tactful configuration information of flow data persistence；

Obtain and need the target operation flow data carrying out persistence；

Call described workflow data persistence service interface and obtain its dynamic proxy class, and at described dynamic proxy apoplexy due to endogenous wind by institute State target operation flow data and be assembled into event；

Described event is run, it is thus achieved that the work that described event is corresponding according to the tactful configuration information of described workflow data persistence Flow data persistence service information, and according to described workflow data persistence information on services, target operation flow data is held Change operation for a long time.

Method the most according to claim 1, it is characterised in that described workflow data persistence information on services includes: clothes Business interface realize class, service interface realizes the address of class, and service interface realizes the ginseng of statement in the method for apoplexy due to endogenous wind and method Number type；

Method the most according to claim 2, it is characterised in that described the first preset data form includes:

Service container and registration class ServiceRegistry, wherein, member variable includes: represents and comprises various different names Information on services set static Map<String, ServiceInfo>；

Service interface realize information ServiceInfo, wherein, member variable includes: service interface realize class, the clothes of exposure Business interface, service interface realizes the address serviceURI of class, service interface realize apoplexy due to endogenous wind method information aggregate Map < String,OperationInfo>；

Service interface realizes information OperationInfo of apoplexy due to endogenous wind method, and wherein, member variable includes: method name, sound in method Bright parameter information set List<ParameterInfo>, method returns to value information<ReturnInfo returnInfo>, side Method abnormal information set List<ExceptionInfo>, method object<Method method>；

Method returns value information ReturnInfo, and wherein, member variable includes: return Value Types String typeName, returns Value Types class Class type；

Method abnormal information ExceptionInfo, wherein, member variable includes: Exception Type String typeName, abnormal Class types Class type.

Method the most according to claim 1, it is characterised in that the service interface wound of statement in for client configuration file After building the step of dynamic proxy class, described method also includes:

Described dynamic proxy class is registered in client container.

Method the most according to claim 4, it is characterised in that the tactful configuration information bag of described workflow data persistence Include:

And/or,

After representing that message is consumed successfully, the event call-back address callbackUri of the address of readjustment initiator automatically.

The most according to the method in claim 2 or 3, it is characterised in that described event is unified event；Described call workflow Data persistence service interface obtains its dynamic proxy class, and is assembled into by target operation flow data at described dynamic proxy apoplexy due to endogenous wind The step of event includes:

Workflow data persistence service interface is called from client container；

At described dynamic proxy apoplexy due to endogenous wind, realize the parameter class of statement in the method for apoplexy due to endogenous wind and method according to described service interface Type, and, the tactful configuration information of workflow data persistence, by described target operation flow data according to the second preset data Form is assembled into unified event.

Method the most according to claim 6, it is characterised in that described the second preset data form includes:

Unified event object UniformEvent: wherein, member variable includes: sequence of events ID eventId, Event Policies EventName, event call-back address callbackUri, event creates time createdTime, and event sends the time SendedTime, the unified message object UniformMessage of band in event；

Unified message object UniformMessage: wherein, member variable includes: message id messageId, unified message head Object UniformMessageHeader, unified message body object UniformMessagePlayload, Message Processing result is returned Return value Object response；

Unified message body object UniformMessagePlayload: wherein, member variable includes: parameter list Object [] params；

Unified message head object UniformMessageHeader: wherein, member variable includes: Event Policies eventName, thing Part loopback address callbackUri, the time MessagecreatedTime that message produces, message sends the time MessagesendedTime, service realizes address endpointUrl, method name methodName, the time of Message Schemas consumption PlanTime, storage strategy storeRule, routing policy routeRule, time-out time timeout, failure number of retries Retry, regulative strategy invokeType.

Method the most according to claim 7, it is characterised in that the described strategy configuration letter according to workflow data persistence Breath runs described event, it is thus achieved that the workflow data persistence information on services that described event is corresponding, and according to described work fluxion Step target operation flow data being carried out persistence operation according to persistence service information includes:

Obtain the method for calling of message in the event configured according to described regulative strategy, if synchronization call, then trigger described thing Part, described event has Event Policies；

Obtaining corresponding action listener according to described Event Policies and realize class, described action listener realizes class according to described event plan Slightly configure generation；

Realizing apoplexy due to endogenous wind at described action listener, according to routing policy, lookup is located locally or long-range service interface realizes class Address；

Call described service interface and realize class, described target operation flow data is saved in the workflow database of Local or Remote In.

Method the most according to claim 7, it is characterised in that call described workflow data persistence service interface it Before, described method also includes:

Affairs are started in default task manager；

The described tactful configuration information according to workflow data persistence runs described event, it is thus achieved that the work that described event is corresponding Flow data persistence service information, and according to described workflow data persistence information on services, target operation flow data is held The step of longization operation includes:

Obtain the method for calling of message in the event configured according to described regulative strategy, if asynchronous call, then create affairs with Step device, and registration transactions lock unit in described task manager；

Submit affairs to, call transactional synchronization device, according to the message in described storage strategy preservation event, then event is added different In step queue；

Realizing apoplexy due to endogenous wind at described action listener, according to described routing policy, lookup is located locally or long-range service interface realizes The address of class；

Call described service interface and realize class, described target operation flow data is saved in the workflow database of Local or Remote In；

Call successfully if described service interface realizes class, then according to described storage strategy, delete the event message preserved, then According to described event call-back address, readjustment initiator notify to operate successfully；

If described service interface realizes class malloc failure malloc, then according to described event call-back address, readjustment initiator performs to compensate industry Business operation.

Method the most according to claim 1, it is characterised in that described acquisition needs to carry out the target operation stream of persistence The step of data includes:

Flow instance starts circulation, runs into the node needing to preserve data, the data of node instance are saved in flow process context In the middle ordered queue specified；

Flow instance circulation terminates, and obtaining the node instance data in described ordered queue is the target work needing to carry out persistence Make flow data.

The device of 11. 1 kinds of workflow data persistence, it is characterised in that including:

Service end configuration module, for extracting the information on services of statement in service end configuration file；Wherein, described information on services bag Include workflow data persistence information on services；

Client configuration module, for creating dynamic proxy class for the service interface of statement in client configuration file, and generates The tactful configuration information of described service interface；Wherein, described service interface includes workflow data persistence service interface, described Strategy configuration information includes the tactful configuration information of workflow data persistence；

Proxy class calling module, is used for calling described workflow data persistence service interface and obtains its dynamic proxy class, and Described target operation flow data is assembled into event by described dynamic proxy apoplexy due to endogenous wind；

Event execution module, runs described event for the tactful configuration information according to described workflow data persistence, it is thus achieved that The workflow data persistence information on services that described event is corresponding, and according to described workflow data persistence information on services to mesh Mark Work stream data carries out persistence operation.

12. devices according to claim 11, it is characterised in that described workflow data persistence information on services includes: Service interface realize class, service interface realizes the address of class, and service interface realizes statement in the method for apoplexy due to endogenous wind and method Parameter type；

Described device also includes:

Service container Registering modules, is connected with described service end configuration module, is used for described information on services according to preset the One data form is registered in service end container.

13. devices according to claim 12, it is characterised in that described the first preset data form includes:

14. devices according to claim 11, it is characterised in that also include:

Client container Registering modules, is connected with described client configuration module, for described dynamic proxy class is registered to visitor In the end container of family.

15. devices according to claim 14, it is characterised in that the tactful configuration information of described workflow data persistence Including:

And/or,

16. according to the device described in claim 12 or 13, it is characterised in that described event is unified event；Described proxy class Calling module includes:

Service interface calls submodule, for calling workflow data persistence service interface from client container；

Dynamic proxy class extracts submodule, for being called the dynamic proxy of correspondence by described workflow data persistence service interface Class；

Event assembles submodule, at described dynamic proxy apoplexy due to endogenous wind, according to described service interface realize apoplexy due to endogenous wind method and The parameter type of statement in method, and, the tactful configuration information of workflow data persistence, by described target operation flow data It is assembled into unified event according to the second preset data form.

17. devices according to claim 16, it is characterised in that described the second preset data form includes:

18. devices according to claim 17, it is characterised in that described event execution module includes:

First event triggers module, for obtaining the method for calling of message in the event configured according to described regulative strategy, if For synchronization call, then triggering described event, described event has Event Policies；

Action listener submodule, realizes class, described action listener for obtaining corresponding action listener according to described Event Policies Realize class to generate according to the configuration of described Event Policies；

Route submodule, for realizing apoplexy due to endogenous wind at described action listener, according to routing policy, searches and is located locally or long-range clothes Business interface realizes the address of class；

Realize class locator module, for realizing the address of class according to described service interface, find corresponding from service end container Service interface realize class；

Persistence operator module, is used for calling described service interface and realizes class, and described target operation flow data is saved in this In ground or long-range workflow database.

19. devices according to claim 17, it is characterised in that also include:

Affairs start module, for starting affairs in default task manager；

Described event execution module includes:

Transactional synchronization device creates submodule, for obtaining the method for calling of message in the event configured according to described regulative strategy, If asynchronous call, then create transactional synchronization device, and registration transactions lock unit in described task manager；

Transaction commitment processing submodule, is used for submitting affairs to, calls transactional synchronization device, according in described storage strategy preservation event Message, then event is added in asynchronous queue；

Route submodule, for realizing apoplexy due to endogenous wind at described action listener, according to described routing policy, searches and is located locally or remotely Service interface realize the address of class；

Persistence operator module, is used for calling described service interface and realizes class, and described target operation flow data is saved in this In ground or long-range workflow database；

Call and be successfully processed submodule, for described service interface realize class call successfully time, then according to described storage strategy, Deleting the event message preserved, then according to described event call-back address, readjustment initiator notify to operate successfully；

Malloc failure malloc processes submodule, for realizing class malloc failure malloc at described service interface, then according to described event call-back ground Location, readjustment initiator performs to compensate business operation.

20. devices according to claim 11, it is characterised in that described Work stream data acquisition module includes:

Data genaration submodule, starts circulation for flow instance, runs into the node needing to preserve data, by the number of node instance According to being saved in flow process context in the ordered queue specified；

Data extract submodule, terminate for flow instance circulation, obtain the node instance data in described ordered queue for needing The target operation flow data of persistence to be carried out.