CN103812838A

CN103812838A - Service calling method and device and system

Info

Publication number: CN103812838A
Application number: CN201210453028.1A
Authority: CN
Inventors: 李锦枝
Original assignee: China Mobile Communications Group Co Ltd
Current assignee: China Mobile Communications Group Co Ltd
Priority date: 2012-11-13
Filing date: 2012-11-13
Publication date: 2014-05-21

Abstract

The invention discloses a service invocation method and equipment, which are applied to a capability opening system including a service module, and are characterized in that the capability opening system is also provided with a control device, and the method includes: the control device receives the service module sending A request message for calling other service modules, the request message carries the identifier of the called service module or the requested service type; the control device determines the called service module according to the identifier of the called service module or the requested service type ; The control device sends the request message to the determined called service module. By adopting the present invention, each service module does not need to directly communicate with other service modules, and does not need to know the addresses of other modules, which reduces the complexity of module design. When adding a new module, only the control device needs to be modified. For the existing modules, only a simple update is required, thereby improving the compatibility and scalability of the capability opening system.

Description

A kind of service calling method and equipment and system

Technical field

The present invention relates to communication technical field, relate in particular to a kind of service calling method and equipment and system.

Background technology

Ability open system refers to integrating and utilizing on the basis of existing telecommunication resources, adopts the open interface of unified multi-layer to open telecommunication capability, and the developer who assembles on the internet utilizes these abilities constantly to create better business application and service.

As shown in Figure 1, be the system architecture schematic diagram of ability open system in prior art, wherein, the service modules such as access module, authentication module, administration module are used for carrying out specific service logic, as particular Web service.Each service module in the ability open system realizing based on Traditional Web services mode with the tightly coupled mode of one each other between two between communication, form netted communication pattern.This mode outstanding feature be exactly by part irrelevant with service logic route etc. together with service logic blending.

Reciprocal process in prior art between any two service modules is:

(1) calling module sends SOAP(Simple Object Access Protocol, Simple Object Access Protocol) request;

(2) after called module is received request, by this request of inter-process logical process, and result is returned to calling module with SOAP form.

For synchronous Web Service(network service) method of calling, after calling module sends request, within the time of called resume module request, respond in same thread execution because calling module sends SOAP request and receives SOAP, therefore calling module can be waited for the response of called module always.For asynchronous Web Service method of calling, the main thread of calling module can return in time, continues other affairs of response.After treating afterwards the called complete request of resume module, result is notified to calling module.

The ability open system realizing based on Traditional Web services mode, adopts synchronization call mode conventionally, and this synchronization call mode exists following shortcoming:

(1) calling module need to be known the URI(Uniform Resource Location of called module, URL(uniform resource locator)) so that the URI based on service module calls.If Web service is deployed to new position (as upgraded the URI of service module), the new URI that must allow other service modules know.

(2), during service operation, the thread of calling module must block.If the response time of called module is long, calling module can be abandoned called request before the response that receives called module.

In prior art, in order to address the above problem, can adopt asynchronous system to realize calling between service module.Although asynchronous system can address the aforementioned drawbacks (2),, still need each service module to know in advance the address of other service modules.In addition, because the interface of each service module may be different, require each service module can process various dissimilar message, cause the design of module very complicated, and in the time adding new service module, in order to process the message of the service module transmission newly adding, need to carry out complicated loaded down with trivial details operation to upgrade other service modules, cause compatibility and the autgmentability of ability open system poor.

Summary of the invention

The embodiment of the present invention provides a kind of service calling method and equipment and system, to reduce the complexity of modular design, and improves compatibility and the extensibility of ability open system.

For achieving the above object, the embodiment of the present invention provides a kind of service calling method, is applied to the ability open system that includes service module, in described ability open system, is also provided with control device, and described method comprises:

Control device receives the request message that calls other service module that service module sends, and has carried the mark of invoked service module or the type of service of asking in described request message;

Described control device is determined invoked service module according to the mark of described invoked service module or the type of service of asking;

Described control device sends to described request message the invoked service module of determining.

Preferably, each service module correspondence is provided with receiving queue and transmit queue;

Described control device also comprises after receiving the request message of service module transmission: the request message receiving is put into the corresponding transmit queue of service module that sends this request message;

Described control device sends to described request message the invoked service module of determining, specifically comprise: described control device takes out described request message from the corresponding transmit queue of service module of transmission described request message, the request message of taking-up is put into the corresponding receiving queue of invoked service module of determining, and from described receiving queue, copy described request message, by the invoked service module that copies the request message obtaining and determine described in sending to.

Preferably, described control device will copy after the request message obtaining sends to the invoked service module of determining, and also comprises:

If the invoked service module that described control device is determined described in confirming does not receive described request message, again copy described request information and sending to described in the invoked service module determined;

If the invoked service module of determining described in described control device confirmation receives described request message, from described receiving queue, delete described request message.

Preferably, described request message is sent to the invoked service module of determining after, also comprise:

The response message that the invoked service module of determining described in described control device receives returns according to described request message, has carried the mark that sends the service module of described request message in described response message;

Described control device determines according to the mark of the service module that sends described request message the service module that sends described request message;

Described control device sends to described response message the service module that sends described request message.

After the response message that the invoked service module of determining described in described control device receives returns, also comprise: transmit queue corresponding to invoked service module of determining described in the response message receiving is put into;

Described control device sends to described response message the service module that sends described request message, specifically comprise: described control device takes out described response message from transmit queue corresponding to the described invoked service module of determining, the response message of taking-up is sent to the corresponding receiving queue of service module that sends described request message, and from described receiving queue, copy described response message, send to by copying the response message obtaining the service module that sends described request message.

Preferably, described control device will copy after the response message obtaining sends to the service module that sends described request message, also comprises:

If described control device is confirmed the service module that sends described request message and do not received described response message, again copy described response message and send to the service module that sends described request message;

If described control device is confirmed the service module that sends described request message and is received described response message, delete described response message from described receiving queue.

Preferably, described receiving queue and described transmit queue are fifo queue, and described control device takes out described response message from transmit queue corresponding to the described invoked service module of determining, and specifically comprises:

Described control device takes out response message according to the time order and function order of each response message in transmit queue from transmit queue corresponding to the described invoked service module of determining;

Described control device copies described response message from described receiving queue, specifically comprises:

Described control device is according to the time order and function copy orderly response message of each response message in receiving queue.

Preferably, described control device, according to asked type of service, sends to described invoked service module by described request message, specifically comprises:

If at least two service modules of type of service correspondence of asking, described control device, according to the load of described at least two service modules or/and processing delay is therefrom selected a service module, and sends to described request message the service module of selecting.

The embodiment of the present invention also provides a kind of control device, is applied to the ability open system that includes service module, and described control device comprises:

Receiving element, the request message that calls other service modules sending for receiving service module, has carried the mark of invoked service module or the type of service of asking in described request message;

Control unit, for determining invoked service module according to the mark of described invoked service module or the type of service of asking;

Transmitting element, for the invoked service module of determining according to described control unit, the described request message that described receiving element is received sends to the invoked service module of determining.

Preferably, each service module correspondence is provided with receiving queue and transmit queue, and described control unit comprises the first storing sub-units, the first replicon unit,

Described the first storing sub-units, for receiving after described request message at described receiving element, the described request message receiving is put into the corresponding transmit queue of service module that sends described request message, and for the request message of described transmit queue is taken out, and the corresponding receiving queue of invoked service module of determining described in the request message of taking-up is put into;

Described the first replicon unit after the corresponding receiving queue of invoked service module of determining described in the request message of taking-up being put in described the first storing sub-units, copies described request message from described receiving queue;

Described transmitting element, sends to specifically for described the first replicon unit is copied to the described request message obtaining the invoked service module of determining.

Preferably, described control unit also comprises the first confirmation subelement, the first deletion subelement,

Described first confirms subelement, for sending to after the invoked service module of determining copying the request message obtaining at described transmitting element, whether the invoked service module of determining described in confirmation receives described request message, and confirming as while being, indicate described first to delete subelement deletion request message, confirming as when no, indicate described the first replicon unit to copy described request message;

Described the first replicon unit, also, for according to the indication of described the first confirmation subelement, copies described request message;

Described first deletes subelement, for according to the indication of described the first confirmation subelement, deletes described request message from described receiving queue.

Preferably, described receiving element, the response message of also returning according to described request message for the invoked service module of determining described in receiving, has carried the mark that sends the service module of described request message in described response message;

Described control unit, also determines for the mark of the service module that sends a request message described in basis the service module that sends described request message;

Described transmitting element, also, for the service module of the transmission described request message determined according to described control unit, the described response message that described receiving element is received sends to the service module that sends described request message.

Preferably, each service module correspondence is provided with receiving queue and transmit queue, and described control unit comprises the second storing sub-units, the second replicon unit,

Described the second storing sub-units, for after described receiving element receives described response message, transmit queue corresponding to invoked service module of determining described in the described response message receiving is put into, and for the response message of described transmit queue is taken out, and the response message of taking-up is put into the corresponding receiving queue of service module that sends described request message;

Described the second replicon unit, sends after the receiving queue that the service module of described request message is corresponding for the response message of taking-up being put in described the second storing sub-units, copies described response message from described receiving queue;

Described transmitting element, sends to specifically for described the second replicon unit being copied to the response message obtaining the service module that sends described request message.

Preferably, described control unit also comprises the second confirmation subelement, the second deletion subelement,

Described second confirms subelement, for sending to after the service module that sends described request message copying the response message obtaining at described transmitting element, confirm whether the service module that sends described request message receives described response message, and confirming as while being, indicate described second to delete subelement deletion request message, confirming as when no, indicate described the second replicon unit to copy described request message;

Described the second replicon unit, also, for according to the indication of described the second confirmation subelement, copies described response message;

Described second deletes subelement, for according to the indication of described the second confirmation subelement, deletes described response message from described receiving queue.

The embodiment of the present invention also provides a kind of ability open server, comprises control device and at least 2 service modules;

Described service module, for send the request message that calls other service modules to described control device, in described request message, carry the mark of invoked service module or the type of service of asking, and the response message of returning according to described request message for receiving the described invoked service module of described control device transmission;

Described control device, the request message sending for receiving described service module, and determine invoked service module according to the mark of described invoked service module or the type of service of asking, and described request message is sent to the invoked service module of determining, and for receiving the described response message that sends the mark of the service module of described request message of having carried that described invoked service module sends, and determine according to the mark of the service module that sends described request message the service module that sends described request message, and described response message is sent to the service module that sends described request message.

Preferably, each service module correspondence is provided with receiving queue and transmit queue,

Described control device, also for after receiving the request message of service module transmission, the request message receiving is put into the corresponding transmit queue of service module that sends this request message, and also for taking out described request message from the corresponding transmit queue of service module that sends described request message, and the request message of taking-up is put into the corresponding receiving queue of invoked service module of determining, and from described receiving queue, copy described request message, by the invoked service module that copies the request message obtaining and determine described in sending to.

Preferably, described control device, also for will copy after the request message obtaining sends to the invoked service module of determining, whether the invoked service module of determining described in confirmation receives described request message, and also for not receiving after described request message at the invoked service module of determining described in confirmation, again copy described request information and sending to described in the invoked service module determined, the invoked service module of determining described in confirming receives after described request message, from described receiving queue, delete described request message.

Described control device, also for after the response message of returning at the invoked service module of determining described in receiving, transmit queue corresponding to invoked service module of determining described in the response message receiving is put into, and also for taking out described response message from described transmit queue corresponding to invoked service module of determining, the response message of taking-up is sent to the corresponding receiving queue of service module that sends described request message, and from described receiving queue, copy described response message, send to by copying the response message obtaining the service module that sends described request message.

Preferably, described control device, also for will copy after the response message obtaining sends to the service module that sends described request message, confirm whether the service module that sends described request message receives described response message, and also for confirming that the service module that sends described request message does not receive after described response message, again copy described response message and send to the service module that sends described request message, confirming that the service module that sends described request message receives after described response message, from described receiving queue, delete described response message.

Preferably, also comprise adaptation module;

Described adaptation module, the message sending for receiving control device, the message that the message conversion that described control device is sent provides system to resolve for ability, and send to described ability that system is provided, and the message that provides system to send for receiving ability, and the message conversion that provides system to send described ability is the message that described control device can be resolved, and send to described control device.

Compared with prior art, the embodiment of the present invention at least has the following advantages:

By control device being set in capability development system, the mark of the invoked service module carrying in the request message being sent according to service module by control device or the type of service of asking, request message is sent to invoked service module, mode with loose coupling between each service module is communicated by control device, thereby make service module not need directly to communicate by letter with other service modules, do not need to know the address of other service modules yet, reduce the complexity of modular design, in the time adding new service module, only need to modify to control device, only need to simply upgrade for existing service module, thereby compatibility and the extensibility of ability open system are improved.

Accompanying drawing explanation

Fig. 1 is the system architecture schematic diagram of ability open system in prior art;

Fig. 2 is the system architecture schematic diagram of the ability open system that provides of the embodiment of the present invention;

Fig. 3 is the call flow schematic diagram between the service module that provides of the embodiment of the present invention;

Fig. 4 is the call flow schematic diagram between the service module that provides of the embodiment of the present invention;

Fig. 5 is the call flow schematic diagram between the service module that provides of the embodiment of the present invention;

Fig. 6 be the embodiment of the present invention provide under ability open system, access adaptation module and ability provides the schematic diagram of the system architecture after system;

Fig. 7 is the structural representation of the control device that provides of the embodiment of the present invention;

Fig. 8 be the embodiment of the present invention provide under ability open server, access adaptation module and ability provides the schematic diagram of the system architecture after system;

Fig. 9 is the structural representation of the ability open server that provides of the embodiment of the present invention.

Embodiment

Below in conjunction with the accompanying drawing in the present invention, the technical scheme in the present invention is clearly and completely described, obviously, described embodiment is only a part of embodiment of the present invention, rather than whole embodiment.Based on the embodiment in the present invention, those of ordinary skills, not making the every other embodiment obtaining under creative work prerequisite, belong to the scope of protection of the invention.

The system architecture schematic diagram of the ability open system providing for the embodiment of the present invention as shown in Figure 2.In this ability open system, be provided with control device, each service module all has communication connection with control device, and communicates by letter with other service modules by control device.

The ability call request that ability open system is mainly used in user's (being ability user) to send is carried out access control.Service module in ability open system generally includes access module, authentication module, also can further comprise administration module, and some miscellaneous function modules, such as business statistics module and alarm module, service module in certain ability open system is not limited to above-mentioned several, can increase and decrease on this basis as required.Wherein, access module and authentication module can cooperatively interact to realize the ability call request that this ability open system is received and carry out access control, ability call request is carried out in access control process, access module is carried out business statistics or/and authentication module also can be called business statistics module, calls alarm module and carries out service alarm etc.

This ability open system can be integrated system, be that control device and the equal concentrated setting of all service modules are on a network equipment, also can be distributed system, be control device and service module at least by two independently the network equipment realize, each LA Management Room communicates by network.

In each service module, dispose the corresponding relation of the mark of other each modules and the type of service of corresponding module (being the type of service of the performed service logic of corresponding module), wherein the mark of service module is at this ability open system unique identification service module, the mark of service module can be can unique identification service module any information.In control device, be provided with the mark of each service module and the corresponding relation of address in advance, for receiving at control device after the request message of the mark that carries called service module of service module transmission, search the address of this called service module according to the mark of the called service module in request message, and according to the address finding, this call request message is sent to corresponding called service module.

It should be noted that, in embodiments of the present invention, service module in ability open system is as still called module of calling module, to be determined as caller or the callee of business by this service module, be same service module, in the time that it calls the business of other service modules, this service module is calling module, in the time that its business is called by other service modules, this service module is called module.

Based on aforementioned capabilities open system, the call flow between service module can as shown in Figure 3, comprise the following steps:

Step 301, control device receives the request message of the mark of carrying called module of calling module transmission, for the called module of request call.

Wherein, the mark that can also carry calling module in this request message.Concrete, in embodiments of the present invention, take calling module as access module, called module is that alarm module is that example describes, wherein, the ID of access module is 001, the ID of alarm module is 002, when access module receives the ability call request that ability user sends, need to call alarm business time, access module is searched the mark of each module and the corresponding relation of type of service that self configures, know that the module that ID is 002 can provide respective service, and the module I D(002 that will be called) and self ID (001) be carried at and in request message, send to control device.

Step 302, request message is sent to the called module corresponding with the mark of the module that is called by control device.

Concrete, control device is receiving after request message, the ID that parses the called module of carrying in request message is 002, the mark of each service module and the corresponding relation of address of control device inquiry self configuration, know that ID is that the address of 002 service module is 1.1.1.1, request message is sent to the service module that destination address is 1.1.1.1 by control device.

Step 303, control device receives the response message of carrying calling module mark that called module is returned according to request message.

Concrete, alarm module receives after request message, the ID of being known the service module of initiating call request by the calling module ID carrying in request message is 001, alarm module carries out corresponding alarm judgement according to this request message, if the flow that for example user has used exceedes set meal limited flow rate, alarm module judgement need to be sent alarm, in such cases, alarm module is carried at corresponding warning information in response message, and access module ID is carried in response message as the mark of object service module, and response message is sent to control device.

Step 304, control device returns to response message the service module of initiating this request.

Concrete, control device receives after the response message of alarm module transmission, the ID that parses the service module as recipient carrying in response message is 001, the mark of each service module and the corresponding relation of address of control device inquiry self configuration, know that ID is that the address of 001 service module is 1.1.1.2, response message is sent to the service module that destination address is 1.1.1.2 by control device.

By the scheme that adopts the embodiment of the present invention to provide, make each service module not need directly to communicate by letter with other service modules, do not need to know the address of other modules yet, reduce the complexity of modular design, in the time adding new module, only need to modify to control device, only need to simply upgrade for existing service module, thereby improve compatibility and the extensibility of ability open system.

The embodiment of the present invention also provides a kind of ability open system, and its structure is identical with the system configuration shown in Fig. 2, and difference is: can pre-configured type of service in each service module and the corresponding relation of the mark of other each service modules; Also can pre-configured module id in control device and the corresponding relation of module's address, but the corresponding relation of configuration service type and module's address.

In this system, provide the service module of identical services to have multiple, the address that a kind of type of service can corresponding multiple service modules, to realize the load balancing of service module.

Based on this ability open system, the call flow between service module can as shown in Figure 4, comprise the following steps:

Step 401, control device receives the request message that carries type of service that calling module sends, and this type of service represents the type of the business that this calling module asks.

Step 402, control device, according to the type of service of carrying in this request message, sends to this request message the called module that respective type business can be provided.

Concrete, control device, according to the corresponding relation of this type of service inquiry business type and service module address, if inquire the address of a service module, sends to respective service module according to the address inquiring by this request message; If inquire the address of multiple service modules, from these service modules, select one, and according to the address of the service module of selecting, this request message is sent to respective service module.

Control device, in the time selecting service module, can be selected according to the load of service module or processing delay.Control device can active obtaining ability open system in the load information of each service module, also can be by the load information of each service module periodic report self, control device can the multiple service modules corresponding from asked type of service, select the minimum service module of load.Control device can be in the time communicating by letter with each service module, according to the response time of service module, know the processing delay information of each service module, control device can the multiple service modules corresponding from asked type of service, select the module of processing delay minimum.Wherein, for centralized ability open system, the processing delay of service module mainly refers to that service module carries out the response time of Business Processing; For distributed capability open system, the processing delay of service module mainly refers to network communication delay.

Step 403, control device receives the response message of carrying calling module mark that called module is returned according to request message.

Step 404, control device returns to response message the service module of initiating this request.

By the scheme that adopts the embodiment of the present invention to provide, make the control device can be according to the sending strategy of the load of each service module and processing delay optimization request message, thereby on the compatibility of the ability of raising open system and the basis of extensibility, the further load balancing of fulfillment capability open system.

The number of threads of considering control device is limited, when control device receives a large amount of request messages or/and when response message, limited thread is not enough to process all message simultaneously, the message that now needs temporary cache not process in time, simultaneously, pass through buffered message, can also avoid in the time of calling module or called module failure, request message or response message are lost, therefore, in another embodiment of the present invention, on the basis of above each ability open system, for each service module is wherein provided with transmit queue and receiving queue, the request message that transmit queue sends to control device for buffer memory calling module and called module are thought the response message that control device sends, request message and response message that receiving queue sends for buffer control device.

Based on the ability open system that is provided with receiving queue and transmit queue, the call flow between service module can as shown in Figure 5, comprise the following steps:

Step 501, control device receives the request message of the mark of carrying called module of calling module transmission.

Step 502, this request message is put into the transmit queue that this calling module is corresponding by control device.

Step 503, control device takes out request message according to the queue mechanism of this transmit queue (as first in first out) from transmit queue corresponding to calling module, and the request message of taking-up is sent to called receiving queue corresponding to module.

Step 504, according to the queue mechanism of this receiving queue, (as first in first out) copies the one or more request messages in this receiving queue to control device, and the request message copying is sent to called module., can, according to the type of the mark of called module or the business of asking, this request message be sent to called module herein, its specific implementation ditto described in, do not repeat them here.

In this step, be repeated to take out for fear of request message, control device in the time getting request message from receiving queue, get the request message not being labeled, obtaining after request message, can carry out mark to the request message of getting, to indicate respective request message to be sent to called module.

Further, all have request message if having in the receiving queue that multiple service modules are corresponding, control device can adopt polling mechanism or alternate manner, obtains request message successively from these receiving queues.

Step 505, control device, according to whether successfully this request message successfully being sent to called module, carries out follow-up respective handling.If this request message is successfully sent to called module, perform step 506, otherwise execution step 507.

Control device can, according to the feedback of called module, judge whether successfully request message to be sent to called module.The embodiment of the present invention requires service module receiving after request message, to control device feedback response message, with advisory that oneself has been received to request message to control device.If control device is sending after request message, set receive that called module returns in long-time for notifying the response message that receives request message, judge and successfully request message sent to called module; If control device is sending after request message, set do not receive that called module returns in long-time for notifying the response message that receives request message, judge unsuccessful request message to be sent to called module.

Step 506, control device is deleted the request message that in receiving queue corresponding to this called module, success is received by this called module.

Step 507, the request message that failing of sending for calling module successfully received by the module that is called, control device copies this request message from receiving queue corresponding to this called module, and sends it to called module, then proceeds to step 505.

Step 508, control device receives the response message that called module is returned according to request message.

Step 509, this response message is put into transmit queue corresponding to this called module by control device.

Step 510, control device takes out response message according to the queue mechanism of this transmit queue (as first in first out) from transmit queue corresponding to called module, and the response message of taking-up is sent to the receiving queue that calling module is corresponding.

Step 511, according to the queue mechanism of this receiving queue, (as first in first out) copies the one or more response messages in this receiving queue to control device, according to the mark of the calling module of initiation respective request message, the response message copying is sent to this calling module.

In this step, be repeated to take out for fear of response message, control device in the time getting response message from receiving queue, get the response message not being labeled, obtaining after response message, can carry out mark to the breath of replying of getting, to indicate respective acknowledgement message to be sent to calling module.

Further, all have response message if having in the receiving queue that multiple service modules are corresponding, control device can adopt polling mechanism or alternate manner, obtains response message successively from these receiving queues.

Step 512, control device, according to whether successfully this response message being sent to calling module, carries out follow-up respective handling.If control device judgement successfully sends to calling module by this response message, perform step 513, otherwise execution step 514.

Described in the same, control device can, according to the feedback of calling module, judge whether successfully response message to be sent to calling module.

Step 513, control device is deleted the response message that in receiving queue corresponding to this called module, successfully called module receives.

Step 514, that sends for called module fails the response message that called module successfully receives, and control device copies this response message from receiving queue corresponding to this calling module, and sends it to calling module, then proceeds to step 512.

Consider that some service modules need to, according to the transmitting time order of request message, receive and process corresponding response message, therefore preferred, the corresponding receiving queue of each service module and transmit queue all adopt the queue mechanism of first in first out.

By the scheme that adopts the embodiment of the present invention to provide, make the control device can be by receiving queue and transmit queue cache request message and response message, thereby break down and fail while receiving request message or response message at service module, avoid losing because of request message or response message the malloc failure malloc causing, on basis with the compatibility in the ability of raising open system and extensibility, further improve the stability of ability open system.

The ability open system of considering is conventionally connected with ability system is provided, in order to the interface of access capability open system to be provided to service developer and Service User, in order to make ability open system and ability provide system better to communicate, preferred in embodiments of the present invention, as shown in Figure 6, can in ability open system, increase adaptation module, this adaptation module is connected to control device and ability provides between system, pass through adaptation module, can provide the protocol adaptation between the interface of system and the interface of ability open system by fulfillment capability, , the message conversion that provides system and ability open system to send to the other side ability is the message that the other side can resolve.

The system architecture diagram as shown in Figure 6 proposing for the present invention, in the time that needs increase new ability system are provided, only need to provide the agreement configuring on the interface of system for the ability of new access, develop corresponding adaptation module, then in ability open system, increase this ability the configuration information of system is provided.

By the scheme that adopts the embodiment of the present invention to provide, use adaptation module fulfillment capability that the protocol adaptation between the interface of system and the interface of ability open system is provided, thereby avoid providing system different with the agreement of ability open system because of ability, interface to ability open system improves, and then realize on the compatibility of the ability of raising open system and the basis of extensibility, reduce the development and maintenance cost of ability open system.

As previously mentioned, the ability open system that the embodiment of the present invention provides can be distributed system, also can be integrated system, accordingly, the embodiment of the present invention also provides a kind of control device that can be used for above-mentioned distributed system, and a kind of ability open server of realizing above-mentioned integrated system.

As shown in Figure 7, the control device that the embodiment of the present invention provides can be realized by the network equipment, preferred, can be realized by server independently, and this control device comprises:

Receiving element 710, the request message that calls other service modules sending for receiving service module, has carried the mark of invoked service module or the type of service of asking in described request message;

Control unit 720, for determining invoked service module according to the mark of described invoked service module or the type of service of asking;

Transmitting element 730, for the invoked service module of determining according to described control unit 720, the described request message that described receiving element 710 is received sends to the invoked service module of determining.

Each service module correspondence is provided with receiving queue and transmit queue, and described control unit 720 comprises the first storing sub-units 721, the first replicon unit 722,

Described the first storing sub-units 721, for receiving after described request message at described receiving element 710, the described request message receiving is put into the corresponding transmit queue of service module that sends described request message, and for the request message of described transmit queue is taken out, and the corresponding receiving queue of invoked service module of determining described in the request message of taking-up is put into;

Described the first replicon unit 722 after the corresponding receiving queue of invoked service module of determining described in the request message of taking-up being put in described the first storing sub-units 721, copies described request message from described receiving queue;

Described transmitting element 730, sends to specifically for described the first replicon unit 722 is copied to the described request message obtaining the invoked service module of determining.

Described control unit 720 also comprises the first confirmation subelement 723, the first deletion subelement 724,

Described first confirms subelement 723, for sending to after the invoked service module of determining copying the request message obtaining at described transmitting element 730, whether the invoked service module of determining described in confirmation receives described request message, and confirming as while being, indicate described first to delete subelement 724 deletion request messages, confirming as when no, indicate described the first replicon unit 722 to copy described request message;

Described the first replicon unit 722, also, for according to the indication of described the first confirmation subelement 723, copies described request message;

Described first deletes subelement 724, for according to the indication of described the first confirmation subelement 723, deletes described request message from described receiving queue.

Described receiving element 710, the response message of also returning according to described request message for the invoked service module of determining described in receiving, has carried the mark that sends the service module of described request message in described response message;

Described control unit 720, also determines for the mark of the service module that sends a request message described in basis the service module that sends described request message;

Described transmitting element 730, also, for the service module of the transmission described request message determined according to described control unit 720, the described response message that described receiving element 710 is received sends to the service module that sends described request message.

Each service module correspondence is provided with receiving queue and transmit queue, and described control unit 720 comprises the second storing sub-units 725, the second replicon unit 726,

Described the second storing sub-units 725, for after described receiving element 710 receives described response message, transmit queue corresponding to invoked service module of determining described in the described response message receiving is put into, and for the response message of described transmit queue is taken out, and the response message of taking-up is put into the corresponding receiving queue of service module that sends described request message;

Described the second replicon unit 726, sends after the receiving queue that the service module of described request message is corresponding for the response message of taking-up being put in described the second storing sub-units 725, copies described response message from described receiving queue;

Described transmitting element 730, sends to specifically for described the second replicon unit 726 being copied to the response message obtaining the service module that sends described request message.

Described control unit 720 also comprises the second confirmation subelement 727, the second deletion subelement 728,

Described second confirms subelement 727, for sending to after the service module that sends described request message copying the response message obtaining at described transmitting element 730, confirm whether the service module that sends described request message receives described response message, and confirming as while being, indicate described second to delete subelement 728 deletion request messages, confirming as when no, indicate described the second replicon unit 726 to copy described request message;

Described the second replicon unit 726, also, for according to the indication of described the second confirmation subelement 727, copies described response message;

Described second deletes subelement 728, for according to the indication of described the second confirmation subelement 727, deletes described response message from described receiving queue.

The ability open server that can realize above-mentioned integrated system, its framework can be as shown in Figure 8, and this framework and aforesaid ability open systems architecture are similar, comprise control device and at least one service module.The function of control device and service module is identical with distributed system, does not repeat them here; Different from distributed system, the communication mechanism between control device and service module is server intercommunication mechanism.

As shown in Figure 9, the control device that the embodiment of the present invention provides can be realized by the network equipment, preferred, can be realized by centralized server, and this server comprises:

Described service module 910, for send the request message that calls other service modules to described control device, in described request message, carry the mark of invoked service module or the type of service of asking, and the response message of returning according to described request message for receiving the described invoked service module of described control device transmission;

Described control device 920, the request message sending for receiving described service module, and determine invoked service module according to the mark of described invoked service module or the type of service of asking, and described request message is sent to the invoked service module of determining, and for receiving the described response message that sends the mark of the service module of described request message of having carried that described invoked service module sends, and determine according to the mark of the service module that sends described request message the service module that sends described request message, and described response message is sent to the service module that sends described request message.

Each service module correspondence is provided with receiving queue and transmit queue,

Described control device 920, also for after receiving the request message of service module transmission, the request message receiving is put into the corresponding transmit queue of service module that sends this request message, and also for taking out described request message from the corresponding transmit queue of service module that sends described request message, and the request message of taking-up is put into the corresponding receiving queue of invoked service module of determining, and from described receiving queue, copy described request message, by the invoked service module that copies the request message obtaining and determine described in sending to.

Described control device 920, also for will copy after the request message obtaining sends to the invoked service module of determining, whether the invoked service module of determining described in confirmation receives described request message, and also for not receiving after described request message at the invoked service module of determining described in confirmation, again copy described request information and sending to described in the invoked service module determined, the invoked service module of determining described in confirming receives after described request message, from described receiving queue, delete described request message.

Described control device 920, also for after the response message of returning at the invoked service module of determining described in receiving, transmit queue corresponding to invoked service module of determining described in the response message receiving is put into, and also for taking out described response message from described transmit queue corresponding to invoked service module of determining, the response message of taking-up is sent to the corresponding receiving queue of service module that sends described request message, and from described receiving queue, copy described response message, send to by copying the response message obtaining the service module that sends described request message.

Described control device 920, also for will copy after the response message obtaining sends to the service module that sends described request message, confirm whether the service module that sends described request message receives described response message, and also for confirming that the service module that sends described request message does not receive after described response message, again copy described response message and send to the service module that sends described request message, confirming that the service module that sends described request message receives after described response message, deletes described response message from described receiving queue.

Also comprise adaptation module 930;

Described adaptation module 930, the message sending for receiving control device 920, the message that the message conversion that described control device 920 is sent provides system to resolve for ability, and send to described ability that system is provided, and the message that provides system to send for receiving ability, and the message conversion that provides system to send described ability is the message that described control device 920 can be resolved, and send to described control device 920.

Through the above description of the embodiments, those skilled in the art can be well understood to the mode that the present invention can add essential general hardware platform by software and realize, and can certainly pass through hardware, but in a lot of situation, the former is better execution mode.Based on such understanding, the part that technical scheme of the present invention contributes to prior art in essence in other words can embody with the form of software product, this computer software product is stored in a storage medium, comprise that some instructions (can be personal computers in order to make a computer equipment, server, or the network equipment etc.) carry out the method described in each embodiment of the present invention.

It will be appreciated by those skilled in the art that accompanying drawing is the schematic diagram of a preferred embodiment, the module in accompanying drawing or flow process might not be that enforcement the present invention is necessary.

It will be appreciated by those skilled in the art that the module in the device in embodiment can be distributed in the device of embodiment according to embodiment description, also can carry out respective change and be arranged in the one or more devices that are different from the present embodiment.The module of above-described embodiment can be merged into a module, also can further split into multiple submodules.

The invention described above embodiment sequence number, just to describing, does not represent the quality of embodiment.

Disclosed is above only several specific embodiment of the present invention, and still, the present invention is not limited thereto, and the changes that any person skilled in the art can think of all should fall into protection scope of the present invention.

Claims

1. A method for invoking a service, applied to a capability opening system including a service module, characterized in that a control device is also provided in the capability opening system, and the method includes:

控制装置接收服务模块发送的调用其它服务模块的请求消息，所述请求消息中携带了被调用的服务模块的标识或所请求的业务类型；The control device receives a request message for calling other service modules sent by the service module, and the request message carries the identifier of the called service module or the requested service type;

所述控制装置根据所述被调用的服务模块的标识或所请求的业务类型确定被调用的服务模块；The control device determines the called service module according to the identifier of the called service module or the requested service type;

所述控制装置将所述请求消息发送给确定出的被调用的服务模块。The control device sends the request message to the determined called service module.

2. The method according to claim 1, wherein each service module is correspondingly provided with a receiving queue and a sending queue;

所述控制装置接收到服务模块发送的请求消息之后，还包括：将接收到的请求消息放入发送该请求消息的服务模块所对应的发送队列；After the control device receives the request message sent by the service module, it also includes: putting the received request message into the sending queue corresponding to the service module sending the request message;

所述控制装置将所述请求消息发送给确定出的被调用的服务模块，具体包括：所述控制装置从发送所述请求消息的服务模块所对应的发送队列中取出所述请求消息，将取出的请求消息放入确定出的被调用的服务模块所对应的接收队列，并从所述接收队列中复制所述请求消息，将复制得到的请求消息发送给所述确定出的被调用的服务模块。The control device sends the request message to the determined called service module, which specifically includes: the control device takes out the request message from the sending queue corresponding to the service module sending the request message, and takes out the request message put the request message into the receiving queue corresponding to the determined called service module, copy the request message from the receiving queue, and send the copied request message to the determined called service module .

3. The method according to claim 2, wherein, after the control device sends the copied request message to the determined called service module, further comprising:

若所述控制装置确认所述确定出的被调用的服务模块未接收到所述请求消息，则再次复制所述请求消息并发送给所述确定出的被调用的服务模块；If the control device confirms that the determined called service module has not received the request message, copying the request message again and sending it to the determined called service module;

若所述控制装置确认所述确定出的被调用的服务模块接收到所述请求消息，则从所述接收队列中删除所述请求消息。If the control device confirms that the determined called service module receives the request message, delete the request message from the receiving queue.

4. The method according to claim 1, characterized in that, after sending the request message to the determined called service module, further comprising:

所述控制装置接收所述确定出的被调用的服务模块根据所述请求消息返回的应答消息，所述应答消息中携带了发送所述请求消息的服务模块的标识；The control device receives a response message returned by the determined called service module according to the request message, where the response message carries the identifier of the service module that sent the request message;

所述控制装置根据发送所述请求消息的服务模块的标识确定发送所述请求消息的服务模块；The control device determines the service module that sends the request message according to the identifier of the service module that sends the request message;

所述控制装置将所述应答消息发送给发送所述请求消息的服务模块。The control device sends the response message to the service module that sent the request message.

5. The method according to claim 4, wherein each service module is correspondingly provided with a receiving queue and a sending queue;

所述控制装置接收到所述确定出的被调用的服务模块返回的应答消息之后，还包括：将接收到的应答消息放入所述确定出的被调用的服务模块对应的发送队列；After the control device receives the response message returned by the determined called service module, it further includes: putting the received response message into the sending queue corresponding to the determined called service module;

所述控制装置将所述应答消息发送给发送所述请求消息的服务模块，具体包括：所述控制装置从所述确定出的被调用的服务模块对应的发送队列中取出所述应答消息，将取出的应答消息发送给发送所述请求消息的服务模块所对应的接收队列，并从所述接收队列中复制所述应答消息，将复制得到的应答消息发送给发送所述请求消息的服务模块。The control device sends the response message to the service module that sent the request message, specifically including: the control device takes out the response message from the sending queue corresponding to the determined called service module, and sends the response message to The retrieved response message is sent to the receiving queue corresponding to the service module that sent the request message, and the response message is copied from the receiving queue, and the copied response message is sent to the service module that sent the request message.

6. The method according to claim 5, wherein, after the control device sends the copied response message to the service module sending the request message, it further comprises:

若所述控制装置确认发送所述请求消息的服务模块未接收到所述应答消息，则再次复制所述应答消息并发送给发送所述请求消息的服务模块；If the control device confirms that the service module that sent the request message has not received the response message, then copy the response message again and send it to the service module that sent the request message;

若所述控制装置确认发送所述请求消息的服务模块接收到所述应答消息，则从所述接收队列中删除所述应答消息。If the control device confirms that the service module sending the request message has received the response message, delete the response message from the receiving queue.

7. The method according to claim 5, wherein the receiving queue and the sending queue are first-in-first-out queues, and the control device selects from the sending queue corresponding to the determined called service module The response message is taken out, specifically including:

所述控制装置根据发送队列中各应答消息的时间先后顺序从所述确定出的被调用的服务模块对应的发送队列中取出应答消息；The control device takes out the response message from the transmission queue corresponding to the determined called service module according to the chronological order of the response messages in the transmission queue;

所述控制装置从所述接收队列中复制所述应答消息，具体包括：Copying the response message from the receiving queue by the control device specifically includes:

所述控制装置根据接收队列中各应答消息的时间先后顺序复制应答消息。The control device copies the response messages according to the time sequence of the response messages in the receiving queue.

8. The method according to claim 1, wherein the control device sends the request message to the invoked service module according to the requested service type, specifically comprising:

若所请求的业务类型对应至少两个服务模块，则所述控制装置根据所述至少两个服务模块的负载或/和处理延迟从中选择一个服务模块，并将所述请求消息发送给选择出的服务模块。If the requested business type corresponds to at least two service modules, the control device selects one of the service modules according to the load or/and processing delay of the at least two service modules, and sends the request message to the selected service module.

9. A control device applied to a capability opening system including a service module, characterized in that the control device includes:

接收单元，用于接收服务模块发送的调用其他服务模块的请求消息，所述请求消息中携带了被调用的服务模块的标识或所请求的业务类型；The receiving unit is configured to receive a request message for invoking other service modules sent by the service module, where the request message carries the identifier of the called service module or the requested service type;

控制单元，用于根据所述被调用的服务模块的标识或所请求的业务类型确定被调用的服务模块；A control unit, configured to determine the invoked service module according to the identifier of the invoked service module or the requested service type;

发送单元，用于根据所述控制单元确定出的被调用的服务模块，将所述接收单元接收到的所述请求消息发送给确定出的被调用的服务模块。The sending unit is configured to send the request message received by the receiving unit to the determined called service module according to the called service module determined by the control unit.

10. The control device according to claim 9, wherein each service module is correspondingly provided with a receiving queue and a sending queue, and the control unit includes a first storage subunit, a first replication subunit,

所述第一存储子单元，用于在所述接收单元接收到所述请求消息后，将接收到的所述请求消息放入发送所述请求消息的服务模块所对应的发送队列，以及用于将所述发送队列中的请求消息取出，并将取出的请求消息放入所述确定出的被调用的服务模块所对应的接收队列；The first storage subunit is configured to, after the receiving unit receives the request message, put the received request message into the sending queue corresponding to the service module sending the request message, and to taking out the request message in the sending queue, and putting the taken out request message into the receiving queue corresponding to the determined called service module;

所述第一复制子单元，用于在所述第一存储子单元将取出的请求消息放入所述确定出的被调用的服务模块所对应的接收队列后，从所述接收队列中复制所述请求消息；The first copying subunit is configured to copy the retrieved request message from the receiving queue after the first storage subunit puts the fetched request message into the receiving queue corresponding to the determined called service module. the above request message;

所述发送单元，具体用于将所述第一复制子单元复制得到的所述请求消息发送给确定出的被调用的服务模块。The sending unit is specifically configured to send the request message copied by the first copying subunit to the determined called service module.

11. The control device according to claim 10, wherein the control unit further comprises a first confirmation subunit, a first deletion subunit,

所述第一确认子单元，用于在所述发送单元将复制得到的请求消息发送给确定出的被调用的服务模块后，确认所述确定出的被调用的服务模块是否接收到所述请求消息，并在确认为是时，指示所述第一删除子单元删除请求消息，在确认为否时，指示所述第一复制子单元复制所述请求消息；The first confirming subunit is configured to confirm whether the determined called service module receives the request after the sending unit sends the copied request message to the determined called service module message, and when the confirmation is yes, instruct the first deletion subunit to delete the request message, and when the confirmation is no, instruct the first replication subunit to copy the request message;

所述第一复制子单元，还用于根据所述第一确认子单元的指示，复制所述请求消息；The first copying subunit is further configured to copy the request message according to the instruction of the first confirmation subunit;

所述第一删除子单元，用于根据所述第一确认子单元的指示，从所述接收队列中删除所述请求消息。The first deleting subunit is configured to delete the request message from the receiving queue according to the instruction of the first confirming subunit.

12. The control device according to claim 9, wherein the receiving unit is further configured to receive a response message returned by the determined called service module according to the request message, wherein the response message carrying the identifier of the service module sending the request message;

所述控制单元，还用于根据所述发送请求消息的服务模块的标识确定发送所述请求消息的服务模块；The control unit is further configured to determine the service module sending the request message according to the identifier of the service module sending the request message;

所述发送单元，还用于根据所述控制单元确定出的发送所述请求消息的服务模块，将所述接收单元接收到的所述应答消息发送给发送所述请求消息的服务模块。The sending unit is further configured to send the response message received by the receiving unit to the service module sending the request message according to the service module sending the request message determined by the control unit.

13. The control device according to claim 12, wherein each service module is correspondingly provided with a receiving queue and a sending queue, and the control unit includes a second storage subunit and a second replication subunit,

所述第二存储子单元，用于在所述接收单元接收到所述应答消息之后，将接收到的所述应答消息放入所述确定出的被调用的服务模块对应的发送队列，以及用于将所述发送队列中的应答消息取出，并将取出的应答消息放入发送所述请求消息的服务模块所对应的接收队列；The second storage subunit is configured to, after the receiving unit receives the response message, put the received response message into the sending queue corresponding to the determined called service module, and use Taking out the response message in the sending queue, and putting the taken out response message into the receiving queue corresponding to the service module that sent the request message;

所述第二复制子单元，用于在所述第二存储子单元将取出的应答消息放入发送所述请求消息的服务模块对应的接收队列后，从所述接收队列中复制所述应答消息；The second copying subunit is configured to copy the response message from the receiving queue after the second storage subunit puts the retrieved response message into the receiving queue corresponding to the service module that sent the request message ;

所述发送单元，具体用于将所述第二复制子单元复制得到的应答消息发送给发送所述请求消息的服务模块。The sending unit is specifically configured to send the response message copied by the second copying subunit to the service module sending the request message.

14. The control device according to claim 13, wherein the control unit further comprises a second confirmation subunit, a second deletion subunit,

所述第二确认子单元，用于在所述发送单元将复制得到的应答消息发送给发送所述请求消息的服务模块后，确认发送所述请求消息的服务模块是否接收到所述应答消息，并在确认为是时，指示所述第二删除子单元删除请求消息，在确认为否时，指示所述第二复制子单元复制所述请求消息；The second confirmation subunit is configured to confirm whether the service module sending the request message has received the response message after the sending unit sends the copied response message to the service module sending the request message, And when the confirmation is yes, instruct the second deletion subunit to delete the request message, and when the confirmation is no, instruct the second replication subunit to copy the request message;

所述第二复制子单元，还用于根据所述第二确认子单元的指示，复制所述应答消息；The second copying subunit is further configured to copy the response message according to the instruction of the second confirmation subunit;

所述第二删除子单元，用于根据所述第二确认子单元的指示，从所述接收队列中删除所述应答消息。The second deleting subunit is configured to delete the response message from the receiving queue according to the instruction of the second confirming subunit.

15. A capability opening server, characterized in that it comprises a control device and at least two service modules;

所述服务模块，用于向所述控制装置发送调用其他服务模块的请求消息，所述请求消息中携带了被调用的服务模块的标识或所请求的业务类型，以及用于接收所述控制装置发送的所述被调用的服务模块根据所述请求消息返回的应答消息；The service module is configured to send a request message to the control device for invoking other service modules, the request message carries the identifier of the called service module or the requested service type, and is used to receive the request message from the control device Sending the response message returned by the called service module according to the request message;

所述控制装置，用于接收所述服务模块发送的请求消息，并根据所述被调用的服务模块的标识或所请求的业务类型确定被调用的服务模块，并将所述请求消息发送给确定出的被调用的服务模块，以及用于接收所述被调用的服务模块发送的携带了发送所述请求消息的服务模块的标识的所述应答消息，并根据发送所述请求消息的服务模块的标识确定发送所述请求消息的服务模块，并将所述应答消息发送给发送所述请求消息的服务模块。The control device is configured to receive the request message sent by the service module, determine the called service module according to the identifier of the called service module or the requested service type, and send the request message to the determined The called service module is used for receiving the response message sent by the called service module and carrying the identification of the service module sending the request message, and according to the service module sending the request message Identify the service module that is determined to send the request message, and send the response message to the service module that sent the request message.

16. The capability opening server according to claim 15, wherein each service module is correspondingly provided with a receiving queue and a sending queue,

所述控制装置，还用于在接收到服务模块发送的请求消息之后，将接收到的请求消息放入发送该请求消息的服务模块所对应的发送队列，以及还用于从发送所述请求消息的服务模块所对应的发送队列中取出所述请求消息，并将取出的请求消息放入确定出的被调用的服务模块所对应的接收队列，并从所述接收队列中复制所述请求消息，将复制得到的请求消息发送给所述确定出的被调用的服务模块。The control device is further configured to, after receiving the request message sent by the service module, put the received request message into the sending queue corresponding to the service module that sent the request message, and is also used to send the request message from taking out the request message from the sending queue corresponding to the service module, and putting the taken out request message into the receiving queue corresponding to the determined called service module, and copying the request message from the receiving queue, Send the copied request message to the determined called service module.

17. The capability exposing server according to claim 16, wherein the control device is further configured to, after sending the copied request message to the determined called service module, confirm the determined Whether the called service module has received the request message, and is also used to copy the request message again and send it to the determined service module after confirming that the determined called service module has not received the request message The called service module deletes the request message from the receiving queue after confirming that the called service module has received the request message.

18. The capability opening server according to claim 15, wherein each service module is correspondingly provided with a receiving queue and a sending queue,

所述控制装置，还用于在接收到所述确定出的被调用的服务模块返回的应答消息之后，将接收到的应答消息放入所述确定出的被调用的服务模块对应的发送队列，以及还用于从所述确定出的被调用的服务模块对应的发送队列中取出所述应答消息，将取出的应答消息发送给发送所述请求消息的服务模块所对应的接收队列，并从所述接收队列中复制所述应答消息，将复制得到的应答消息发送给发送所述请求消息的服务模块。The control device is further configured to, after receiving the response message returned by the determined called service module, put the received response message into the sending queue corresponding to the determined called service module, And it is further used to extract the response message from the sending queue corresponding to the determined called service module, send the extracted response message to the receiving queue corresponding to the service module sending the request message, and retrieve the response message from the Copy the response message in the receiving queue, and send the copied response message to the service module that sent the request message.

19. The capability opening server according to claim 18, characterized in that,

所述控制装置，还用于在将复制得到的应答消息发送给发送所述请求消息的服务模块之后，确认发送所述请求消息的服务模块是否接收到所述应答消息，以及还用于在确认发送所述请求消息的服务模块未接收到所述应答消息后，再次复制所述应答消息并发送给发送所述请求消息的服务模块，在确认发送所述请求消息的服务模块接收到所述应答消息后，从所述接收队列中删除所述应答消息。The control device is also used for confirming whether the service module sending the request message has received the response message after sending the copied response message to the service module sending the request message, and for confirming After the service module that sent the request message did not receive the response message, it copied the response message again and sent it to the service module that sent the request message, and after confirming that the service module that sent the request message received the response After receiving the message, delete the reply message from the receiving queue.

20. The capability opening server according to claim 15, further comprising an adaptation module;

所述适配模块，用于接收控制装置发送的消息，将所述控制装置发送的消息转换为能力提供系统能够解析的消息，并发送给所述能力提供系统，以及用于接收能力提供系统发送的消息，并将所述能力提供系统发送的消息转换为所述控制装置能够解析的消息，并发送给所述控制装置。The adaptation module is configured to receive a message sent by the control device, convert the message sent by the control device into a message that the capability providing system can parse, and send it to the capability providing system, and is used to receive the message sent by the capability providing system , convert the message sent by the capability providing system into a message that the control device can parse, and send it to the control device.