CN105959385A

CN105959385A - Information communication method, device and system

Info

Publication number: CN105959385A
Application number: CN201610406810.6A
Authority: CN
Inventors: 李云震
Original assignee: Inspur Software Group Co Ltd
Current assignee: Inspur Software Group Co Ltd
Priority date: 2016-06-06
Filing date: 2016-06-06
Publication date: 2016-09-21

Abstract

The invention provides an information communication method, a device and a system, wherein the method comprises the following steps: the core end obtains an access request of a service requester sent by the web front end by using a request queue channel for information communication with the web front end, wherein the access request comprises service information and a unique service identifier of a service provider; acquiring a service access address corresponding to the unique service identifier from a database; and sending the service access address and the service information to the adapter end by using the request queue channel for carrying out information communication with the adapter end. The adapter end can forward the service information sent by the core end to the service provider corresponding to the service access address, so that the service provider can process the service information, and the information communication between the service requester and the service provider is completed. Therefore, the scheme can automatically carry out information communication between services.

Description

A kind of information communicating method, Apparatus and system

Technical field

The present invention relates to field of computer technology, particularly to a kind of information communicating method, Apparatus and system.

Background technology

Along with developing rapidly of software engineering, various software products arise at the historic moment.For meeting service needed, Each company or unit would generally purchase various software product, to apply multiple service simultaneously.When each service it Between when needing interactive information, need to carry out mutually calling between different service.

At present, typically serviced to call other by manual operation under line by staff, thus realize not With the information communication between service.

It can be seen that owing to needs are communicated by manual operation, therefore existing implementation is not Information communication between automatically servicing.

Summary of the invention

The invention provides a kind of information communicating method, Apparatus and system, it is possible between automatically servicing Information communicates.

In order to achieve the above object, the present invention is achieved through the following technical solutions:

First aspect, the invention provides a kind of information communicating method, is applied to core end, predetermined The the first request queue passage communicated with outside web front-end, and enter with external adapter end Second request queue passage of row information communication, also includes:

S1: utilize described first request queue passage, obtaining external service that described web front-end sends please The access request of the side of asking, and described access request includes that business information and external service provider's is unique Service identifiers；

S2: obtain the service access address that described unique device mark is corresponding from external data base；

S3: utilize described second request queue passage, by described service access address and described business information It is sent to described adapter end.

Further, described access request also includes: service provider's identification code of described service requester；

Also included before S3: from described data base, determine the access that described unique device mark is corresponding Authority, and described access rights include at least one service provider's identification code；Judge described service requester Service provider's identification code whether in described access rights, if so, perform S3.

Further, also included before S3: predefine and communicate with described web front-end First response queue's passage, and the second response queue communicated with described adapter end leads to Road；The timeout threshold that described unique device mark is corresponding is obtained from described data base；

In S1, utilize described first request queue passage, obtain the outside that described web front-end is sent During the access request of service requester, also include: record the current acquisition request time；

Also include after S3: based on the described acquisition request time, it is judged that reaching described timeout threshold Time, if get the described service that described adapter end utilizes described second response queue's passage to send and carry The return information of supplier, if it is not, generate the request failure response message that described access request is corresponding, and profit With described first response queue's passage, described request failure response message is sent to described web front-end.

Further, also included before S3: utilize obtaining of service access address described in counter records Taking number of times, when obtaining described service access address, described acquisition number of times is from adding 1, described receiving During return information corresponding to service access address, described acquisition number of times is from subtracting 1；Obtain from described data base Take the maximum number of concurrent that described unique device mark is corresponding；Judge the acquisition number of times of described service access address Whether less than described maximum number of concurrent, if so, perform S3.

Further, also include after S1: by resolving described access request, determine described access The communication protocol that request is corresponding；And utilize described second request queue passage described communication protocol to be sent To described adapter end, wherein,

Described communication protocol includes: Web Service, MQ (Message Queue) and FTP (File Transfer Protocol, file transfer protocol (FTP)) in any one.

Second aspect, the invention provides a kind of core end, including:

Determine unit, for determining the first request queue passage communicated with outside web front-end, And the second request queue passage communicated with external adapter end；

First acquiring unit, is used for utilizing described first request queue passage, obtains described web front-end and send out The access request of external service request side come, and described access request includes business information and outside clothes The unique device mark of business provider；

Second acquisition unit, for obtaining the service that described unique device mark is corresponding from external data base Reference address；

Transmitting element, is used for utilizing described second request queue passage, by described service access address and institute State business information and be sent to described adapter end.

Further, this core end also includes: the first processing unit；

Described access request also includes: service provider's identification code of described service requester；

Described first processing unit, for determining described unique device mark correspondence from described data base Access rights, and described access rights include at least one service provider's identification code；Judge that described service please Service provider's identification code of the side of asking, whether in described access rights, if so, triggers described transmitting element.

Further, this core end also includes: the second processing unit；

Described determine unit, be additionally operable to determine the first response team communicated with described web front-end Row passage, and the second response queue's passage communicated with described adapter end；

Described first acquiring unit, is additionally operable to utilizing described first request queue passage, obtains described web During the access request of the external service request side that front end is sent, record the current acquisition request time；

Described second acquisition unit, is additionally operable to obtain described unique device mark correspondence from described data base Timeout threshold；

Described second processing unit, for based on the described acquisition request time, it is judged that reaching described time-out During threshold value, if get the described clothes that described adapter end utilizes described second response queue's passage to send The return information of business provider, if it is not, generate the request failure response message that described access request is corresponding, And before utilizing described first response queue's passage that described request failure response message is sent to described web End.

Further, this core end also includes: counting unit and the 3rd processing unit；

Described second acquisition unit, is additionally operable to obtain described unique device mark correspondence from described data base Maximum number of concurrent；

Described counting unit, for utilizing the acquisition number of times of service access address described in counter records, When obtaining described service access address, described acquisition number of times, from adding 1, is receiving described service access ground During return information corresponding to location, described acquisition number of times is from subtracting 1；

Described 3rd processing unit, for judging that whether the acquisition number of times of described service access address is less than institute State maximum number of concurrent, if so, trigger described transmitting element.

Further, described first processing unit, it is additionally operable to, by resolving described access request, determine institute State the communication protocol that access request is corresponding, wherein,

Described communication protocol includes: any one in Web Service, MQ and FTP；

Described transmitting element, is additionally operable to utilize described second request queue passage, described communication protocol is sent out Give described adapter end.

The third aspect, the invention provides a kind of information communication system, including:

Any of the above-described described core end, and data base, web front-end, adapter end, for described The first request queue passage that core end and described web front-end communicate, for described core end The second request queue passage of communicating with described adapter end, at least one service requester and At least one service provider；

Described web front-end, for receive described service requester send include unique device mark and industry The access request of business information；And utilize described first request queue passage, described access request is sent To described core end；

Described data base, visits for the unique device mark and service storing each described service provider Ask address；

Described adapter end, is used for utilizing described second request queue passage, obtains described core end and send Service access address and business information；And described business information is sent to described service access address Corresponding service provider.

Further, described web front-end includes: at least one service access interface, wherein,

At least one service access interface described includes: Web Service communication protocol service access interface, In MQ communication protocol service access interface, FPT communication protocol service access interface any one or many Kind；

Described web front-end, specifically for utilizing arbitrary described service access interface, receiving described service please The access request that the side of asking sends, and the business information that described access request includes is XML (Extensible Markup Language, extensible markup language) the service message character string of form；By adding in advance The header determined, and/or, described service message character string is packaged by telegram end；After encapsulation will be included The described access request of service message character string add in described first request queue passage；

Described adapter end, is additionally operable to utilize described second request queue passage, obtains described core end and send out The communication protocol that next described access request is corresponding；This communication protocol predefined specifically for utilization Corresponding handling process, is sent to described service access address by the service message character string after described encapsulation Corresponding service provider.

Further, described web front-end includes: service registry interface；

Described web front-end, is additionally operable to utilize described service registry interface, receives described service provider and send out The service registration information come；And described service registration information is preserved to described data base, wherein,

Described service registration information includes: the unique device mark of described service provider and service access Location,

Or,

Unique device mark and service reference address, and, service name, service describing, service provider's title, Service provider's identification code, include the access rights of at least one service provider's identification code, timeout threshold, maximum also Any one or more in the communication protocol send out number, supporting.

Further, the logic of described web front-end, described core end and described adapter end disposes framework Deployment mode include: concentrate deployment mode, distribution deployment mode and mixed deployment pattern in any one Kind, wherein,

Described concentration deployment mode is for by described web front-end, described core end and described adapter end Administration is in same server；Described distribution deployment mode for by described web front-end, described core end and Described adapter end is deployed in different server respectively；Described mixed deployment pattern is for by described web Front end, with, described core end and described adapter end are disposed in different server；

Described logic disposes framework, with, at least one service requester described and at least one service described The deployment architecture of provider includes: B/S (Browser/Server, browser/server) structure.

The invention provides a kind of information communicating method, Apparatus and system, before core end utilizes itself and web The request queue passage that end communicates, the access obtaining the service requester that web front-end is sent please Ask, and this access request includes the unique device mark of business information and service provider；From data base The service access address that middle acquisition unique device mark is corresponding；It is utilized to communicate with adapter end Request queue passage, service access address and business information are sent to adapter end.Due to adapter The business information that core end is sent can be forwarded to the service provider that service access address is corresponding by end, therefore This business information can be processed by service provider, thus completes service requester and service provider Information communication, this realizes process without manual operation, can be automatically performed.Therefore, energy of the present invention Information communication between enough automatically servicing.

Accompanying drawing explanation

In order to be illustrated more clearly that the embodiment of the present invention or technical scheme of the prior art, below will be to reality Execute the required accompanying drawing used in example or description of the prior art to be briefly described, it should be apparent that below, Accompanying drawing in description is some embodiments of the present invention, for those of ordinary skill in the art, not On the premise of paying creative work, it is also possible to obtain other accompanying drawing according to these accompanying drawings.

Fig. 1 is the flow chart of a kind of information communicating method that one embodiment of the invention provides；

Fig. 2 is the flow chart of the another kind of information communicating method that one embodiment of the invention provides；

Fig. 3 is the schematic diagram of a kind of core end that one embodiment of the invention provides；

Fig. 4 is the schematic diagram of the another kind of core end that one embodiment of the invention provides；

Fig. 5 is the schematic diagram of a kind of information communication system that one embodiment of the invention provides.

Detailed description of the invention

For making the purpose of the embodiment of the present invention, technical scheme and advantage clearer, below in conjunction with this Accompanying drawing in bright embodiment, is clearly and completely described the technical scheme in the embodiment of the present invention, Obviously, described embodiment is a part of embodiment of the present invention rather than whole embodiments, based on Embodiment in the present invention, those of ordinary skill in the art are institute on the premise of not making creative work The every other embodiment obtained, broadly falls into the scope of protection of the invention.

As it is shown in figure 1, embodiments provide a kind of information communicating method, it is applied to core end, May comprise steps of:

Step 101: the first request queue passage that predetermined and outside web front-end communicates, And the second request queue passage communicated with external adapter end.

Step 102: utilize described first request queue passage, obtain the outside that described web front-end is sent The access request of service requester, and described access request includes business information and external service provider Unique device mark.

Step 103: obtain the service access address that described unique device mark is corresponding from external data base.

Step 104: utilize described second request queue passage, by described service access address and described industry Business information is sent to described adapter end.

Embodiments providing a kind of information communicating method, core end utilizes it to carry out with web front-end The request queue passage of information communication, obtains the access request of the service requester that web front-end is sent, and This access request includes the unique device mark of business information and service provider；Obtain from data base The service access address that unique device mark is corresponding；Utilize the request that itself and adapter end communicate Queue passage, is sent to adapter end by service access address and business information.Owing to adapter end is permissible The business information that core end is sent is forwarded to the service provider that service access address is corresponding, therefore service carries This business information can be processed by supplier, thus completes the information of service requester and service provider Communication, this realizes process without manual operation, can be automatically performed.Therefore, embodiment of the present invention energy Information communication between enough automatically servicing.

In one embodiment of the invention, in order to limit unauthorized service requester to respective service offer Side illegally calls, and can arrange the access rights of each service provider, so,

Farther included before step 104: from described data base, determine that described unique device mark is right The access rights answered, and described access rights include at least one service provider's identification code；Judge described clothes Service provider's identification code of business requesting party, whether in described access rights, if so, performs step 104.

Such as, service provider's identification code of service requester A is 001, and unique clothes of service provider B In the access rights that business mark is corresponding, including service provider's identification code be 003 and 005.It can be seen that 001 not included in these access rights, illustrate that service requester A haves no right to call service provider B.This One implementation can avoid service provider illegally to be called.

In one embodiment of the invention, in order to ensure high reliability, the high stability that system runs, The overtime control of service granularity can be provided, so,

Farther included before step 104: predetermined communicate with described web front-end First response queue's passage, and the second response queue's passage communicated with described adapter end； The timeout threshold that described unique device mark is corresponding is obtained from described data base；

In a step 102, utilize described first request queue passage, obtain what described web front-end was sent During the access request of external service request side, farther include: record the current acquisition request time；

Farther include after step 104: based on the described acquisition request time, it is judged that reaching described During timeout threshold, if get the institute that described adapter end utilizes described second response queue's passage to send State the return information of service provider, if it is not, generate the request failure response report that described access request is corresponding Literary composition, and utilize described first response queue's passage that described request failure response message is sent to described web Front end.

Therefore, based on a determination that timeout threshold and the acquisition request time, if core end is reaching timeout threshold Time do not receive the return information of service provider all the time, then explanation there may be system exception, service provides Side is without problems such as response, adapter end operation irregularities, thus causes the access request of service requester to process Failure, therefore this service requester can be notified, in order to staff pinpoints the problems in time and solves Certainly problem.

In one embodiment of the invention, in order to ensure the high reliability that system is run, it is provided that clothes The flow-control of business granularity, so,

Farther included before step 104: utilize the acquisition of service access address described in counter records Number of times, when obtaining described service access address, described acquisition number of times, from adding 1, is receiving described clothes During business return information corresponding to reference address, described acquisition number of times is from subtracting 1；Obtain from described data base The maximum number of concurrent that described unique device mark is corresponding；The acquisition number of times judging described service access address is No less than described maximum number of concurrent, if so, perform step 104.

When too much being called due to arbitrary service provider, be likely to result in systemic breakdown, service carries simultaneously Supplier processes the access request situation such as not in time, therefore need to be controlled the maximum number of concurrent of service call, To ensure the properly functioning of service call flow process.

In one embodiment of the invention, in order to for the access request of different communication protocol, Join the handling process access request with process service requester of the same communications protocols, so,

Farther include after step 102: by resolving described access request, determine that described access please Seek corresponding communication protocol；And utilize described second request queue passage described communication protocol to be sent to Described adapter end, wherein,

Described communication protocol includes: any one in Web Service, MQ and FTP.

Access request based on arbitrary communication protocol, adapter end needs to mate the process of the same communications protocols Flow process is to support service call.Therefore core end can be by resolving access request, to determine the logical of its correspondence Letter agreement, and the communication protocol determined is sent to adapter end, to ensure normally entering of service call OK.

As in figure 2 it is shown, one embodiment of the invention provides another kind of information communicating method, the method with Between the service of actual application as a example by information communication, specifically include following steps:

Step 201: create message queue passage.

In detail, in embodiments of the present invention, it is possible to use message queue instrument creates message queue and leads to Road, and create message queue passage can include following 6 kinds:

(a) first request queue passage: Queue_FrontToMule_Request, for by information by Web front-end is transferred to core end；

(b) first response queue's passage: Queue_FrontToMule_Response, for by information by Core end is back to web front-end；

C () first dead letter passage: Queue_FrontToMule_Death, is used for depositing web front-end and core Dead chain in information exchanging process between heart end and junk information；

(d) second request queue passage: Queue_MuleToAdapter_Request, for by information by Core end is transferred to adapter end；

E () second response queue's passage: Queue_MuleToAdapter_Response, for by information It is back to core end by adapter end；

F () second dead letter passage: Queue_MuleToAdapter_Death, is used for depositing core end and fitting Dead chain in information exchanging process between orchestration end and junk information.

In an embodiment of the invention, if without service provider return information, and without handling dead Chain and junk information, the message queue passage created can also only include the first request queue passage and Two request queue passages, equally complete service requester and call service provider.

In an embodiment of the invention, for different actual demands, as considered motility, disposing just Victory, O&M situation etc., the logic of web front-end, core end and adapter end disposes framework, Ke Yiwei Concentrate deployment mode, distribution deployment mode and mixed deployment pattern in any one.

In detail, concentrate deployment mode to may be used for web front-end, core end and adapter end to dispose In same server.This deployment mode at least can have that deployment is simple, O&M convenient, overall laterally Extend without understanding the advantages such as relation between built-in system and access system.

In detail, distribution deployment mode may be used for web front-end, core end and adapter end difference portion Administration is in different server.This deployment mode at least can have total system stability height, system event Phragma updates the advantages such as convenient from, independent backstage adapter.

In detail, mixed deployment pattern may be used for web front-end, with, core end and adapter end Administration is in different server.This deployment mode can be with the advantage of two kinds of deployment modes of summary.

In an embodiment of the invention, disposing framework for any of the above-described logic, this logic disposes framework Can be B/S structure with the deployment architecture of service requester and service provider.It is apparent that service request Side and the usual more than one of number of service provider, and same service can be to service in different system Any one in provider and service requester.

In an embodiment of the invention, web front-end can be the B/S structure based on Java Web Service interface；Core end can be the message resolution module with Mule as technical support；Adaptive Device end can be the message transmission module with Mule as technical support；Each message queue passage can be with MQ is the passage carrying out message transmission supported.

Step 202:web front end utilizes service registry interface, receives the service note that service provider is sent Volume information, and the service registration information received is preserved to data base.

In detail, web front-end can include an external unified service registry interface, each service Provider all can carry out service registry by this service registry interface in advance.Such as, service provider Service registry interface can be passed through, the service registration information of self correspondence is sent to web front-end, and Whole service registration information can be preserved to data base by web front-end, in order to core end can be right Arbitrary service registration information is inquired about or is called.

Calling service provider to realize service requester, service registration information at least can include The unique device mark of service provider and service reference address.Wherein, this unique device mark can be There is the Services Code of uniqueness.

In an embodiment of the invention, in order to meet the various practical situation in service invocation procedure, as Avoid service illegally call, service call without response or response time is long, system is busy, these clothes Business log-on message can also include: the service name of service provider, service describing, service provider's title, Service provider's identification code, include the access rights of at least one service provider's identification code, timeout threshold, maximum also Any one or more in the communication protocol send out number, supporting.

Wherein, for arbitrary service provider, identified by the whole service providers in the access rights of setting Code, can be prevented effectively from service requester corresponding to other service provider's identification codes and call this service provider. Additionally, the service requester for the ease of authorizing carries out service call, service provider generally can be supported Various communications protocols, therefore service requester can be by handling process corresponding to arbitrary communication protocol with success Call service.

Step 203: whole service registration information that web front-end is received by data base store.

Step 204:web front end utilizes service access interface, and the access that reception service requester is sent please Ask.

In detail, web front-end can include at least one the most unified service access interface, each Service requester all can pass through arbitrary service access interface, sends access request with the service of calling.

In an embodiment of the invention, due to can based on various communications protocols successfully to call service, Therefore the service access interface that web front-end includes at least may include that Web Service communication protocol services Appointing in access interface, MQ communication protocol service access interface, FPT communication protocol service access interface Anticipate one or more.Wherein, from the access request of arbitrary communication protocol service access interface input, rear In continuous operating process, need the handling process utilizing this communication protocol corresponding with the service of calling.

In detail, the transport layer protocol of Web Service technology can be HTTP, HTTPS, and version can Think that SOAP1.1, SOAP1.2, request response mode can support to synchronize and asynchronous call, this technology Extensibility is strong, unrelated with operation system operation platform and development language, it is provided that multiple security strategy. MQ technology can provide reception message, the function of dispatch messages, and request response mode can be supported asynchronous Call, and be applicable to asynchronous, the most concurrent actual application scenarios.

In the present embodiment, request response mode can be asynchronous call.

In an embodiment of the invention, the access request that service requester is sent may include that business is believed Breath, service provider's identification code of service requester, need to call service provider unique device mark.

In the present embodiment, for ease of system identification, business information can be the business report of XML format Chinese character string.

In an embodiment of the invention, the service message character string of XML format to realize code permissible As follows:

<？Xml version=" 1.0 " encoding=" UTF-8 "？>

< service xmlns=" http://www.gzds.gov.cn/spec/ " Xmlns:xsi=" http://www.w3.org/2001/XMLSchema-instance " >

<head>

<tran_id>C00.SB.SPHM.ZGCZ.Get</tran_id>

<channel_id>C000AHXQZ</channel_id>

<tran_seq>eea4ff11269045068f421dd</tran_seq>

<tran_date>20160523</tran_date>

<tran_time>083231475</tran_time>

</head>

</service>

In the service message character string of above-mentioned XML format, it is possible to use [CDATA []] service of filling in please The side of asking needs to pass to the real messages content of service provider, and other label is internal system storage The parameter of requirements of process.

Web front-end, when receiving access request, can carry out validity check to business information therein, As only identified the service message character string of XML format.

Business information in access request is packaged by step 205:web front end, and will include encapsulation After the access request of business information add in the first request queue passage.

From the foregoing, it will be observed that business information not only comprises service requester need to pass to the reality of service provider Border message content, also comprises the parameter of internal system Stored Procedure needs.In order to make business information make Be that an entirety is transmitted so that core end when receiving this business information without reading business information In detailed content, therefore the business information in access request is packaged by web front-end.

In detail, the header that web front-end can will predefine, and/or, telegram end, adds to industry In business information, so that business information is packaged.Wherein, web front-end predefines header and report Tail can be by core end identification.

In the present embodiment, the access request of service requester can be added to the first request by web front-end Ranking in queue passage, when queuing up successfully, this access request can be pushed to core end.

Additionally, web front-end is when utilizing the first request queue passage to send access request to core end, Can be in respective response queue, i.e. first response queue's passage waits for the arrival of news return.Such as, service provides Side will can process completion status by the first response queue accordingly when completing to process this access request Passage is back to web front-end, thus is back to service requester by web front-end again.

In an embodiment of the invention, for the request queue passage created, it is also possible to predetermined phase The message queue's time threshold answered.Such as, at web front-end, the access request of service requester is added extremely After in first request queue passage, if the queuing duration of this access request exceedes this message queue Between threshold value, then this access request can be deposited to the first dead letter queue passage.In a kind of possible reality In existing mode, core end can be periodically to the whole dead chain deposited in the first dead letter queue passage and rubbish letter Breath is uniformly processed.

Step 206: core end utilizes the first request queue passage, and the service that acquisition web front-end is sent please The access request of the side of asking, and record the current acquisition request time.

For the access request of service requester, when the process overlong time of this access request or without response Time, in order to the corresponding process state information of return is to notify service requester in time, therefore core end can To record the current acquisition request time when receiving this access request.

In an embodiment of the invention, access request can also added to the second request team by core end During row passage, current time is recorded as the acquisition request time.The recording mode of acquisition request time is different Time, the corresponding timeout threshold pre-set can also change.

Step 207: core end obtain from data base service access address corresponding to unique device mark, Access rights, timeout threshold, maximum number of concurrent.

For the access request received, identify according to the unique device of service provider therein, core End can obtain the multinomial information that this unique device mark is corresponding from data base: service access address, visit Ask authority, timeout threshold, maximum number of concurrent.

Step 208: core end judge service provider's identification code of service requester whether in access rights, If so, perform step 209, otherwise, terminate current process.

In detail, the access rights of service provider may include that at least one service provider's identification code.

In order to determine whether service requester has the right to call this service provider, therefore according in access request Service provider's identification code of service requester, it can be determined that whether there is this in the access rights of service provider Service provider's identification code.In the presence of judged result is, illustrate that service requester is had the right to call this service and provided Side, and continue executing with current process.

Step 209: core end judges whether the acquisition number of times of service access address is less than maximum number of concurrent, If so, perform step 210, otherwise, suspend current process, and again perform step 209.

In order to ensure system stability, can be with the number of times of qualified call service provider less than the maximum set Number of concurrent.In detail, core end can utilize the acquisition number of times of counter records service access address, When obtaining service access address, enumerator, from adding 1, is receiving the return letter that service access address is corresponding During breath, enumerator is from subtracting 1.

If core end judges that the acquisition number of times of service access address is not less than maximum number of concurrent, then to currently Access request time-out process, and again perform judge operation, until judging obtaining of service access address When taking number of times less than maximum number of concurrent, continue executing with subsequent operation.

In detail, the judged result for core end is this request no, it may be predetermined that again carry out Judge the time interval of operation.Start timing when judged result is no, and reach this time interval Again carry out judging operation during the corresponding time, so circulate, during until judged result is for being, perform step Rapid 210.

Except setting above-mentioned time interval, in an embodiment of the invention, owing to core end can utilize Timer records the acquisition number of times of service access address the most accurately, therefore when core end detects timer When obtaining number of times less than the maximum number of concurrent set of record, can perform step 209 again, or directly Connect execution step 210.

Step 210: core end, by resolving access request, determines the communication protocol that access request is corresponding, And communication protocol, service access address and business information are added to the second request queue passage.

As it has been described above, communication protocol can be any one in Web Service, MQ and FTP.Example As, the access request inputted by the Web Service communication protocol service access interface of web front-end, Corresponding communication protocol is Web Service, then adapter end needs to call this communication of Web Service The handling process that agreement is corresponding, is sent to the service provider that service access address is corresponding by business information.

In an embodiment of the invention, core end can also obtain service provider support from data base Communication protocol, with when determining communication protocol corresponding to access request, it is judged that whether service provider Support this communication protocol.

In an embodiment of the invention, core end can be according to the communication protocol determined, to business information Carry out message attribute renewal, and the business information after updating is added to the second request queue passage, with Passed through adapter end to send to service provider.

Additionally, except above-mentioned access mandate, message attribute updates, maximum number of concurrent controls, communication protocols View type judges, core end can also be encrypted deciphering, business flowing water log recording etc. to business information Process.Such as, by record traffic flowing water daily record, to preserve message transmission detail, such that it is able to be easy to Carry out flow process inquiry, eliminating etc. to process.

Core end, can when sending communication protocol, service access address and business information to adapter end With in respective response queue, i.e. second response queue's passage waits for the arrival of news return.

Step 211: adapter end utilizes the second request queue passage, obtains the communication protocols that core end is sent View, service access address and business information, utilize the process stream that this communication protocol predefined is corresponding Journey, is sent to the service provider that service access address is corresponding by business information.

In detail, classifying according to function and usage, adapter end can be with service adapter and protocol adaptor two Kind.Wherein, service adapter can be called for core end, and certainly realizes business service, can be used for this locality The applied business changing characteristic processes and business innovation；Protocol adaptor is mainly used in service provider support Communication protocol carry out adaptation, the service interface of service provider is carried out actual calling.

In the present embodiment, protocol adaptor can be selected.In detail, adapter end can predefine The handling process that each communication protocol is corresponding, and when determining the communication protocol of service requester, profit By handling process corresponding to this communication protocol, the business information of service requester is sent to service access ground The service provider that location is corresponding, so that service provider processes this business information.

Service provider, when completing to process business information, can generate return information, as return information can Think the status information whether business information is successfully processed.This return information can be depended on by service provider Secondary before adapter end, second response queue's passage, core end, first response queue's passage, web End, is ultimately sent to service requester.

Therefore, in embodiments of the present invention, by web front-end, core end, adapter end and each message The synergy of queue passage, it is possible to achieve service provider is called by service requester, thus automatically Complete the information communication between service.This implementation solves and can not be managed collectively between service and mutually The technical problem called, be of value to improve staff to all services or project control ability, strengthen Enterprise work efficiency and capax negotii etc..

Step 212: based on the acquisition request time, when reaching timeout threshold, and do not obtain determining When utilizing the return information of service provider that second response queue's passage sends to adapter end, core end Generate the request failure response message that access request is corresponding, and utilize first response queue's passage request to be lost Lose response message and be sent to web front-end.

Owing to core end is when being successfully sent to adapter end by the access request of service requester, Ke Yi First response queue's passage waits the return information that this access request is corresponding.When receiving this return information Time, it can be sent to service requester through web front-end.If do not receive this return information always, Then the first response queue persistently waits, and the acquisition request time based on above-mentioned core end record, until reaching During to timeout threshold, core end can judge.Core end is through interpretation and determines that not receiving return believes During breath, corresponding request failure response message can be generated according to the access request of service requester, and It is notified service requester through web front-end.Additionally, the first response queue can terminate to believe this return The wait of breath, and reject when this return information delays to reach.

Additionally, no matter transmit return information, or sending failure response message, core end can be to accordingly Business flowing water daily record record and preserve.

In embodiments of the present invention, except the access request of service requester being sent to servicing offer Outside side is to process, it is also possible to access request is carried out control of authority, overtime control, maximum concurrently Numerical control system, return message transmission etc. process.This implementation is capable of the information communication between service, And be of value to guarantee system reliability of operation and stability, and it is applicable to the actual application of service call Scene.

As it is shown on figure 3, one embodiment of the invention provides a kind of core end 30, including:

Determine unit 301, for determining the first request queue communicated with outside web front-end Passage, and the second request queue passage communicated with external adapter end；

First acquiring unit 302, is used for utilizing described first request queue passage, before obtaining described web Hold the access request of the external service request side sent, and described access request includes that business information is with outer The unique device mark of portion's service provider；

Second acquisition unit 303, for obtaining described unique device mark correspondence from external data base Service access address；

Transmitting element 304, is used for utilizing described second request queue passage, by described service access address It is sent to described adapter end with described business information.

In an embodiment of the invention, refer to Fig. 4, this core end 30 can also include: at first Reason unit 401；

Described first processing unit 401, right for determining described unique device mark from described data base The access rights answered, and described access rights include at least one service provider's identification code；Judge described clothes Service provider's identification code of business requesting party, whether in described access rights, if so, triggers described transmitting element 304。

In an embodiment of the invention, refer to Fig. 4, this core end 30 can also include: at second Reason unit 402；

Described determine unit 301, be further used for determining communicated with described web front-end One response queue's passage, and the second response queue's passage communicated with described adapter end；

Described first acquiring unit 302, is further used for utilizing described first request queue passage, obtains When taking the access request of the external service request side that described web front-end is sent, record current acquisition request Time；

Described second acquisition unit 303, is further used for obtaining described unique device from described data base The timeout threshold that mark is corresponding；

Described second processing unit 402, for based on the described acquisition request time, it is judged that is reaching described During timeout threshold, if get the institute that described adapter end utilizes described second response queue's passage to send State the return information of service provider, if it is not, generate the request failure response report that described access request is corresponding Literary composition, and utilize described first response queue's passage that described request failure response message is sent to described web Front end.

In an embodiment of the invention, refer to Fig. 4, this core end 30 can also include: counting is single Unit 403 and the 3rd processing unit 404；

Described second acquisition unit 303, is further used for obtaining described unique device from described data base The maximum number of concurrent that mark is corresponding；

Described counting unit 403, for utilizing the acquisition number of times of service access address described in counter records, When obtaining described service access address, described acquisition number of times, from adding 1, is receiving described service access During return information corresponding to address, described acquisition number of times is from subtracting 1；

Described 3rd processing unit 404, for judging that the acquisition number of times of described service access address is the least In described maximum number of concurrent, if so, trigger described transmitting element 304.

In an embodiment of the invention, refer to Fig. 4, described first processing unit 401, use further In by resolving described access request, determine the communication protocol that described access request is corresponding, wherein,

Described transmitting element 304, is further used for utilizing described second request queue passage, by described logical Letter agreement is sent to described adapter end.

As it is shown in figure 5, embodiments provide a kind of information communication system, including:

Any of the above-described described core end 30, and data base 40, web front-end 50, adapter end 60, The first request queue passage of communicating for described core end 30 and described web front-end 50, The second request queue passage of communicating for described core end 30 and described adapter end 60 end, At least one service requester 70 and at least one service provider 80；

Described web front-end 50, for receive described service requester 70 send include unique device mark Know and the access request of business information；And utilize described first request queue passage, please by described access Ask and be sent to described core end 30；

Described data base 40, for store each described service provider 80 unique device mark and Service access address；

Described adapter end 60 end, is used for utilizing described second request queue passage, obtains described core end Service access address that 30 send and business information；And described business information is sent to described service visit Ask the service provider 80 that address is corresponding.

In an embodiment of the invention, described web front-end 50 includes: at least one service access connects Mouthful, wherein,

Described web front-end 50, specifically for utilizing arbitrary described service access interface, receives described service The access request that requesting party 70 sends, and the business information that described access request includes is XML format Service message character string；The header predefined by interpolation, and/or, telegram end is to described business report Chinese character string is packaged；The described access request of the service message character string after including encapsulation is added extremely In described first request queue passage；

Described adapter end 60 end, is further used for utilizing described second request queue passage, obtains described The communication protocol that described access request that core end 30 is sent is corresponding；Predefine specifically for utilization The handling process that this communication protocol is corresponding, is sent to described clothes by the service message character string after described encapsulation The service provider 80 that business reference address is corresponding.

In an embodiment of the invention, described web front-end 50 includes: service registry interface；

Described web front-end 50, is further used for utilizing described service registry interface, receives described service and carry The service registration information that supplier 80 sends；And described service registration information is preserved to described data base In 40, wherein,

Described service registration information includes: the unique device mark of described service provider 80 and service access Address,

Or,

In an embodiment of the invention, described web front-end 50, described core end 30 and described adaptation The logic of device end 60 end is disposed the deployment mode of framework and is included: concentrate deployment mode, distribution deployment mode and Any one in mixed deployment pattern, wherein,

Described concentration deployment mode is for by described web front-end 50, described core end 30 and described adaptation Device end 60 end is deployed in same server；Described distribution deployment mode for by described web front-end 50, Described core end 30 and described adapter end 60 end are deployed in different server respectively；Described mixing unit Administration's pattern for by described web front-end 50, with, described core end 30 and described adapter end 60 end Administration is in different server；

Described logic disposes framework, with, at least one service requester 70 described and at least one clothes described The deployment architecture of business provider 80 includes: B/S structure.

The contents such as the information between each unit in said apparatus is mutual, execution process, due to the present invention Embodiment of the method is based on same design, and particular content can be found in the narration in the inventive method embodiment, this Place repeats no more.

In sum, each embodiment of the present invention at least has the advantages that

1, in the embodiment of the present invention, core end utilizes the request team that itself and web front-end communicate Row passage, obtains the access request of the service requester that web front-end is sent, and this access request includes The unique device mark of business information and service provider；Unique device mark correspondence is obtained from data base Service access address；Utilize the request queue passage that itself and adapter end communicate, will service Reference address and business information are sent to adapter end.Industry core end can sent due to adapter end Business information is forwarded to the service provider that service access address is corresponding, therefore service provider can be to this business Information processes, thus completes service requester and communicate with the information of service provider, and this realized Cheng Wuxu manual operation, can be automatically performed.Therefore, between the embodiment of the present invention can service automatically Information communication.

2, in the embodiment of the present invention, by web front-end, core end, adapter end and each message queue The synergy of passage, it is possible to achieve service provider is called by service requester, thus be automatically performed Information communication between service.This implementation solves and can not be managed collectively and mutually call between service Technical problem, be of value to improve staff to all services or project control ability, strengthen enterprise Work efficiency and capax negotii etc..

3, in the embodiment of the present invention, except the access request of service requester being sent to servicing offer Outside side is to process, it is also possible to access request is carried out control of authority, overtime control, maximum concurrently Numerical control system, return message transmission etc. process.This implementation is capable of the information communication between service, And be of value to guarantee system reliability of operation and stability, and it is applicable to the actual application of service call Scene.

It should be noted that in this article, the relational terms of such as first and second etc be used merely to by One entity or operation separate with another entity or operating space, and not necessarily require or imply this Relation or the order of any this reality is there is between a little entities or operation.And, term " includes ", " comprise " or its any other variant is intended to comprising of nonexcludability, so that include that one is The process of row key element, method, article or equipment not only include those key elements, but also include the brightest Other key elements really listed, or also include intrinsic for this process, method, article or equipment Key element.In the case of there is no more restriction, statement " include a 〃 " and limit Key element, it is not excluded that there is also another in including the process of described key element, method, article or equipment Outer same factor.

One of ordinary skill in the art will appreciate that: realize all or part of step of said method embodiment Can be completed by the hardware that programmed instruction is relevant, aforesaid program can be stored in embodied on computer readable Storage medium in, this program upon execution, performs to include the step of said method embodiment；And it is aforementioned Storage medium include: various Jie that can store program code such as ROM, RAM, magnetic disc or CD In matter.

Last it should be understood that the foregoing is only presently preferred embodiments of the present invention, it is merely to illustrate this The technical scheme of invention, is not intended to limit protection scope of the present invention.All spirit in the present invention and former Any modification, equivalent substitution and improvement etc. done within then, are all contained in protection scope of the present invention.

Claims

1. an information communicating method, it is characterised in that be applied to core end, predetermined and outside The first request queue passage that web front-end communicates, and carry out information with external adapter end Second request queue passage of communication, also includes:

Method the most according to claim 1, it is characterised in that

Farther included before S3: from described data base, determine described unique device mark correspondence Access rights, and described access rights include at least one service provider's identification code；Judge that described service please Service provider's identification code of the side of asking, whether in described access rights, if so, performs S3；

And/or,

Farther included before S3: predefine first communicated with described web front-end Response queue's passage, and the second response queue's passage communicated with described adapter end；From Described data base obtains the timeout threshold that described unique device mark is corresponding；

In S1, utilize described first request queue passage, obtain the outside that described web front-end is sent During the access request of service requester, farther include: record the current acquisition request time；

Farther include after S3: based on the described acquisition request time, it is judged that reaching described time-out During threshold value, if get the described clothes that described adapter end utilizes described second response queue's passage to send The return information of business provider, if it is not, generate the request failure response message that described access request is corresponding, And before utilizing described first response queue's passage that described request failure response message is sent to described web End；

And/or,

Farther included before S3: utilize the acquisition number of times of service access address described in counter records, When obtaining described service access address, described acquisition number of times, from adding 1, is receiving described service access During return information corresponding to address, described acquisition number of times is from subtracting 1；Described in obtaining from described data base only The maximum number of concurrent that one service identifiers is corresponding；Judge whether the acquisition number of times of described service access address is less than Described maximum number of concurrent, if so, performs S3.

Method the most according to claim 1 and 2, it is characterised in that

Farther include after S1: by resolving described access request, determine described access request pair The communication protocol answered；And it is described to utilize described second request queue passage described communication protocol to be sent to Adapter end, wherein,

Described communication protocol includes: any one in Web Service, MQ and file transfer protocol (FTP) FTP Kind.

4. a core end, it is characterised in that including:

Core end the most according to claim 4, it is characterised in that

Farther include: the first processing unit；

Described first processing unit, for determining described unique device mark correspondence from described data base Access rights, and described access rights include at least one service provider's identification code；Judge that described service please Service provider's identification code of the side of asking, whether in described access rights, if so, triggers described transmitting element；

And/or,

Farther include: the second processing unit；

Described determine unit, be further used for determining the first sound communicated with described web front-end Answer queue passage, and the second response queue's passage communicated with described adapter end；

Described first acquiring unit, is further used for utilizing described first request queue passage, obtains institute When stating the access request of the external service request side that web front-end is sent, record the current acquisition request time；

Described second acquisition unit, is further used for obtaining described unique device mark from described data base Corresponding timeout threshold；

Described second processing unit, for based on the described acquisition request time, it is judged that reaching described time-out During threshold value, if get the described clothes that described adapter end utilizes described second response queue's passage to send The return information of business provider, if it is not, generate the request failure response message that described access request is corresponding, And before utilizing described first response queue's passage that described request failure response message is sent to described web End；

And/or,

Farther include: counting unit and the 3rd processing unit；

Described second acquisition unit, is further used for obtaining described unique device mark from described data base Corresponding maximum number of concurrent；

6. according to the core end described in claim 4 or 5, it is characterised in that

Described first processing unit, is further used for, by resolving described access request, determining described access The communication protocol that request is corresponding, wherein,

Described communication protocol includes: any one in Web Service, MQ and file transfer protocol (FTP) FTP Kind；

Described transmitting element, is further used for utilizing described second request queue passage, by described communication protocols View is sent to described adapter end.

7. an information communication system, it is characterised in that including:

Core end as described in arbitrary in claim 4 to 6, and data base, web front-end, adaptation Device end, the first request queue passage communicated for described core end and described web front-end, The second request queue passage of communicating for described core end and described adapter end, at least one Individual service requester and at least one service provider；

Information communication system the most according to claim 7, it is characterised in that

Described web front-end includes: at least one service access interface, wherein,

At least one service access interface described includes: Web Service communication protocol service access interface, In MQ communication protocol service access interface, file transfer protocol (FTP) FPT communication protocol service access interface Any one or more；

Described web front-end, specifically for utilizing arbitrary described service access interface, receiving described service please The access request that the side of asking sends, and the business information that described access request includes is extensible markup language The service message character string of XML format；The header predefined by interpolation, and/or, telegram end pair Described service message character string is packaged；The described access of service message character string after encapsulation will be included Request is added to described first request queue passage；

Described adapter end, is further used for utilizing described second request queue passage, obtains described core Hold the communication protocol that the described access request sent is corresponding；This communication predefined specifically for utilization The handling process that agreement is corresponding, is sent to described service access by the service message character string after described encapsulation The service provider that address is corresponding.

Described web front-end includes: service registry interface；

Described web front-end, is further used for utilizing described service registry interface, and receiving described service provides The service registration information that side sends；And described service registration information is preserved to described data base, its In,

Or,

10. according to described information communication system arbitrary in claim 7 to 9, it is characterised in that

The logic of described web front-end, described core end and described adapter end disposes the deployment mode of framework Including: concentrate deployment mode, distribution deployment mode and mixed deployment pattern in any one, wherein,

Described logic disposes framework, with, at least one service requester described and at least one service described The deployment architecture of provider includes: browser/server B/S structure.