CN102025650A - Message processing system and message processing method of enterprise service bus - Google Patents
Message processing system and message processing method of enterprise service bus Download PDFInfo
- Publication number
- CN102025650A CN102025650A CN 201010197429 CN201010197429A CN102025650A CN 102025650 A CN102025650 A CN 102025650A CN 201010197429 CN201010197429 CN 201010197429 CN 201010197429 A CN201010197429 A CN 201010197429A CN 102025650 A CN102025650 A CN 102025650A
- Authority
- CN
- China
- Prior art keywords
- message
- processing
- message processing
- threads
- messages
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
- 238000012545 processing Methods 0.000 title claims abstract description 170
- 238000003672 processing method Methods 0.000 title abstract description 5
- 238000012544 monitoring process Methods 0.000 claims abstract description 6
- 230000005540 biological transmission Effects 0.000 claims description 28
- 238000000034 method Methods 0.000 claims description 27
- 238000012163 sequencing technique Methods 0.000 claims description 13
- 238000005111 flow chemistry technique Methods 0.000 claims description 6
- 238000012546 transfer Methods 0.000 claims description 5
- 230000010354 integration Effects 0.000 description 21
- 238000005516 engineering process Methods 0.000 description 6
- 230000008569 process Effects 0.000 description 6
- 229910000831 Steel Inorganic materials 0.000 description 4
- 239000010959 steel Substances 0.000 description 4
- 238000007726 management method Methods 0.000 description 3
- 238000012986 modification Methods 0.000 description 3
- 230000004048 modification Effects 0.000 description 3
- 230000008901 benefit Effects 0.000 description 2
- 230000003139 buffering effect Effects 0.000 description 2
- 230000006837 decompression Effects 0.000 description 2
- 238000012856 packing Methods 0.000 description 2
- 230000015572 biosynthetic process Effects 0.000 description 1
- 230000008859 change Effects 0.000 description 1
- 230000000739 chaotic effect Effects 0.000 description 1
- 238000004891 communication Methods 0.000 description 1
- 230000008878 coupling Effects 0.000 description 1
- 238000010168 coupling process Methods 0.000 description 1
- 238000005859 coupling reaction Methods 0.000 description 1
- 238000010586 diagram Methods 0.000 description 1
- 238000001914 filtration Methods 0.000 description 1
- 230000000977 initiatory effect Effects 0.000 description 1
- 238000012423 maintenance Methods 0.000 description 1
- 238000012797 qualification Methods 0.000 description 1
- 230000008054 signal transmission Effects 0.000 description 1
- 239000000126 substance Substances 0.000 description 1
Images
Landscapes
- Computer And Data Communications (AREA)
Abstract
The invention provides a message processing system of an enterprise service bus. The system comprises a message receiving module, a message processing module and a message control module, wherein the message receiving module is used for receiving messages sent by a plurality of users, ordering the messages according to a preset rule and storing the ordered messages in a message queue; the message processing module is used for receiving a preset quantity of ordered messages from the message receiving module and processing the received messages; and the message control module is used for monitoring the presence of the messages in the message queue and the state of the message processing module in real time through a predefined monitoring command and controlling the message processing module to receive or not to receive the messages transmitted by the message receiving module. The invention also provides a message processing method of the enterprise service bus. The messages are buffered through the message queue and a message thread group, a service request is processed, the quantity of messages which can be processed by an electronic transaction platform is limited through a message processing thread group and response to messages surpassing the quantity is not made, so that the electronic transaction platform is prevented from failing due to over high calling pressure of a certain service.
Description
Technical field
The present invention relates to the e-commerce transaction technical field, relate in particular to a kind of message handling system and message treatment method of ESB.
Background technology
At present, the application integration service between large enterprise's net is complicated day by day, and the system integration of traditional point-to-point formula seems awkward.In order to address this problem, people have proposed request processing method (enterprise service bus, abbreviation ESB) notion, each subsystem of promptly forming enterprise network inserts a public information platform in the mode that is similar to connector, relatively independent each other, carry out unified data dispatch by scheduling engine, with high effective integration data and operation flow.Study the definition of being given with Gartner company of consulting firm according to famous IT, the request processing method is a kind of architecture, utilize Web service, request middleware, intelligent route and the switch technology of enterprise, be the product that traditional intermediate technology combines with technology such as XML, Web services, ESB provides connection maincenter the most basic in the network.The target of request processing method technology is with the application integration of standardized mode enterprise, finish interconnected, the intercommunication and the interoperability of business-to-business application system, standardization effort wherein comprises connector standardsization, management standardization, service request standard chemical combination request standardization etc.
The appearance of ESB has changed traditional software architecture, can provide than the more cheap solution of traditional middleware software product, simultaneously it can also eliminate the technological disparity between the different application, allows different application server coordinate operation, communication and the integration between the different services.On function, ESB provides the tupe of event-driven and document guiding, and distributed management method, and it supports content-based route and filtration, has possessed the transmittability of complex data, and a series of standard interface is provided.For example, application number discloses a kind of implementation method of ESB for the Chinese patent application of " 200810227316.9 ".
Existing E-commerce transaction platform, it is multi-to-multi that the service user directly calls the ISP, chaotic, be difficult to maintenance management is carried out in the service in the row; The degree of coupling is too high between service call person and backstage service, often pulls one hair and move the whole body.And because the Service Source of E-commerce transaction platform is limited, usually face in actual applications in the same period, the user of use is too much, and the message that needs to handle is crowded, as to certain service (application module) to call pressure excessive, cause electronic trade platform to work as the problem of machine.
Summary of the invention
The problem that the present invention solves provides a kind of message handling system and message treatment method, avoids in ESB, and is excessive to the pressure that calls of certain service (application module), causes electronic trade platform to work as machine.
For addressing the above problem, the invention provides a kind of message handling system of ESB, comprising:
The message sink module is used to receive a plurality of messages sent by users, and sorts by pre-defined rule and to be stored in the message queue;
Message processing module is used for receiving from described message sink module the ordering message of predetermined quantity, and handles this message;
The message control module is used for by the described message queue of predefined monitoring instruction real-time listening whether message being arranged, and the state of message processing module., and whether the control messages processing module receives the message of message sink module transmission.
Optionally, described message processing module includes Message Processing sets of threads and Message Processing pipeline, wherein, the Message Processing sets of threads receives the message of message control module transmission, with described transmission of messages to the Message Processing pipeline, and the Message Processing thread space that takies of the message that discharges end of transmission simultaneously, described Message Processing sets of threads has the higher limit of predetermined quantity; The Message Processing pipeline receives the message that described Message Processing sets of threads is transmitted, and described message is handled.
Optionally, when the message control module listens to described Message Processing sets of threads when having idle Message Processing thread, then control the message that described message processing module receives described Message Processing thread.
Optionally, the described ordering by pre-defined rule is meant that sending the time sequencing that the time sequencing of message or message sink module receive by the user sorts.
Optionally, described message comprises at least one service request; When comprising at least two service requests in the described message, message queue receives a plurality of service requests in the described message; When comprising a service request in the described message, a message queue receives a service request in chronological order.
Optionally, in the described message queue, time of reception be better than the preceding the time after transmission of messages to the Message Processing pipeline, a kind of service request of each Message Processing pipeline alignment processing.
Optionally, in the message that described message sink module receives, comprise that the message of at least one service request is encrypted, before described Message Processing line treatment service request, described message is decrypted.
Optionally, described Message Processing pipeline the processing stage comprise: according to the intended flow processing messages corresponding, and call application module according to the pre-defined rule in the intended flow with message.
The present invention also provides a kind of message treatment method of ESB, comprising:
Receive message, sorting by pre-defined rule is stored in the message queue;
According to the order of described message queue, to the Message Processing sets of threads, described Message Processing sets of threads space has the higher limit of predetermined quantity with the transmission of messages in the described message queue; If when the message number in the Message Processing sets of threads reaches described higher limit, then stop the transmission of messages of message queue to the Message Processing sets of threads;
Message in the message processing threads group is handled.
Optionally, the described ordering by pre-defined rule is meant that the time sequencing that sends or receive by message sorts.
Optionally, described message comprises at least one service request; When comprising at least two service requests in the described message, message queue receives a plurality of service requests in the described message; When comprising a service request in the described message, a message queue receives a service request in chronological order.
Optionally, described message in the message processing threads group is handled after, discharge the corresponding shared Message Processing sets of threads of information space simultaneously.
Optionally, behind the shared Message Processing sets of threads of the information space of release correspondence,, will not transfer to the transmission of messages of message threads group in the message queue to the Message Processing sets of threads according to the message queue order.
Optionally, described message in the message processing threads group is handled comprises: transfer to the Message Processing pipeline with limiting number of messages in the Message Processing sets of threads, wherein, the corresponding reception of each Message Processing pipeline handled a kind of service request.
Optionally, in the message that described message sink module receives, comprise that the message of at least one service request is encrypted, before described Message Processing line treatment service request, described message is decrypted.
Optionally, described Message Processing pipeline the processing stage comprise: according to the intended flow processing messages corresponding, and call application module according to the pre-defined rule in the intended flow with message.
Compared with prior art, the present invention has the following advantages: the message treatment method that the invention provides a kind of ESB, by message queue and message threads group buffering message, the request of managing business, limit the quantity of the manageable message of electronic trade platform simultaneously by the Message Processing sets of threads, do not respond surpassing this number of messages, avoid excessive, cause electronic trade platform to work as machine the pressure that calls of certain service (application module).
Description of drawings
Fig. 1 is the inside structure schematic diagram of message handling system of the ESB of the specific embodiment of the invention;
Fig. 2 is the FB(flow block) of message treatment method of the ESB of the specific embodiment of the invention.
Embodiment
The invention provides a kind of message handling system and message treatment method of ESB, by message queue and message threads group buffering message, the request of managing business, limit the quantity of the manageable message of electronic trade platform simultaneously by the Message Processing sets of threads, do not respond surpassing this number of messages, avoid excessive, cause electronic trade platform to work as machine the pressure that calls of certain service (application module).
As shown in Figure 1,, the invention provides a kind of message handling system 001 of ESB, comprising for addressing the above problem:
In the present embodiment, the message sink module is also by calling ciphering unit, with the message encryption of message sink module reception.
Also can rank to the message in the message receiver module 100 among other embodiment of the present invention, for example the message in the message receiver module 100 be ranked according to the priority (importance) of message according to other pre-defined rules.
Wherein, the message of described message sink module reception comprises at least one service request; When comprising a service request in the described message, a message queue receives a service request in chronological order; When comprising at least two service requests in the described message, message queue receives a plurality of service requests in the described message;
Wherein, Message Processing sets of threads 310 is used for from the ordering message of described message sink module 100 reception predetermined quantities; Processing threads group 310 comprises the processing threads of predetermined quantity, is respectively processing threads 1, processing threads 2 ... processing threads n.The quantity of the processing threads in the processing threads group 310 is predetermined quantity, this quantity is set according to the disposal ability of electronic trade platform, for example, the quantity of the processing threads in the processing threads group 310 is 200, then same time electronic trade platform can only respond 200 message, and for the 200th later message, electronic trade platform does not respond, avoid the service user too much to cause electronic trade platform to work as the phenomenon of machine, thereby can guarantee the normal operation of electronic trade platform.
Described message processing module 300 also comprises Message Processing pipeline 320, is used to receive the message of described Message Processing sets of threads 310 transmission, and described message is handled;
In this specific embodiment, Message Processing pipeline 320 comprises a plurality of Message Processing pipelines, be respectively Message Processing pipeline 1, Message Processing pipeline 2, Message Processing pipeline 3, Message Processing pipeline 4, Described Message Processing thread sends to corresponding Message Processing pipeline with the message of obtaining.Need to prove, there is corresponding relation in service request in described Message Processing pipeline and the message, the Message Processing pipeline of the corresponding identical type of each service request, when the Message Processing pipeline receives or obtains message, according to predetermined flow process it is handled by the Message Processing pipeline of corresponding kind.If include a plurality of service requests in the described message, then described transmission of messages also comprises described message is split into service request, and described service request is transferred in the corresponding Message Processing pipeline to the Message Processing pipeline.Wherein, message is split into service request can carry out before temporary entering described message queue, also can carry out before entering described Message Processing line treatment.
In the present embodiment, each Message Processing pipeline comprise the deciphering stage (stage) and the processing stage, the described deciphering stage is decrypted information encrypted; According to described predetermined flow processing message, and according to the predetermined rule invocation application module in the predetermined flow process, and after handling, the result of described message is sent to the clients corresponding computer processing stage of described.
In other embodiments, each Message Processing pipeline can comprise the different stages, for example also can comprise decompression phase.
As other embodiment, described message handling system 001 can also comprise receive path (not shown): the user of service use side sends message by receive path (not shown) to the message sink module 100 of described message handling system 001.If include a plurality of service requests in the message that the user of service use side once sends, then before described receive path 100 receives message, described a plurality of service requests are packaged into a message, and the message after the described packing is temporary in the message queue.
According to above-mentioned message handling system, the present invention also provides a kind of message treatment method of ESB, comprising: receive message, sorting by pre-defined rule is stored in the message queue; According to the order of described message queue, to the Message Processing sets of threads, described Message Processing sets of threads space has higher limit with the transmission of messages in the described message queue; If when the message number in the Message Processing sets of threads reaches described higher limit, then stop the transmission of messages of message queue to the Message Processing sets of threads; Message in the message processing threads group is handled.
For making above-mentioned purpose of the present invention, feature and advantage can become apparent more, below in conjunction with accompanying drawing specific implementation method of the present invention are described in detail.
As shown in Figure 2, described message treatment method comprises:
Execution in step S10 receives message, and sorting by pre-defined rule is stored in the message queue.The time sequencing that described pre-defined rule sends for the user or the time sequencing of message sink, the message of described reception is encrypted;
Execution in step S20 reads message from described message queue.After reading, described message such as is at state to be transmitted;
Execution in step S30 judges whether the Message Processing thread surpasses higher limit.Wherein, described higher limit is a predetermined quantity, judge promptly whether described Message Processing thread has idle Message Processing thread:, then will be in the extremely corresponding idle message processing threads of transmission of messages of waiting for transmission state, and enter subsequent step S40 if having idle Message Processing thread; If do not have idle Message Processing thread, then enter wait state, promptly wait for idle Message Processing thread;
Execution in step S40, the initiation message processing threads is handled the described message that reads, and wherein, described being treated to transfers to the Message Processing pipeline with limiting number of messages in the described Message Processing sets of threads;
Execution in step S50 discharges the Message Processing thread that processing messages takies;
Execution in step S60 judges whether message queue also has message, if also have the message of not transmission process in the described message queue, execution in step S20 then, according to the message queue order, from described message queue, read message, and with the Message Processing thread of described transmission of messages to the free time; If do not have the message of not transmission process in the described message queue, then finish.
Wherein, described message comprises at least one service request; When comprising at least two service requests in the described message, message queue receives a plurality of service requests in the described message; When comprising a service request in the described message, a message queue receives a service request in chronological order.
When described message has plural service request, then before receiving described message, also comprise described message is packaged into a message, be temporary among the message queue.
Described Message Processing pipeline receives in the process of message, there is corresponding relation in service request in described Message Processing pipeline and the message, the Message Processing pipeline of the corresponding identical type of each service request, when the Message Processing pipeline receives or obtains message, according to predetermined flow process it is handled by the Message Processing pipeline of corresponding kind.If include a plurality of service requests in the described message, then described transmission of messages also comprises described message is split into service request, and described service request is transferred in the corresponding Message Processing pipeline to the Message Processing pipeline.Wherein, message is split into service request can carry out before temporary entering described message queue, also can carry out before entering described Message Processing line treatment.
In the present embodiment, each Message Processing pipeline comprise the deciphering stage (stage) and the processing stage, the described deciphering stage is decrypted information encrypted; According to described predetermined flow processing message, and according to the predetermined rule invocation application module in the predetermined flow process, and after handling, the result of described message is sent to the clients corresponding computer processing stage of described.
In other embodiments, each Message Processing pipeline can comprise the different stages, for example also can comprise decompression phase.
Below in conjunction with the use of concrete ESB, message handling system of the present invention and message treatment method are elaborated.
Described message among the present invention can be the transaction message of extensive stock, e-commerce transaction with steel is an example, commodity are steel, transaction message comprises the transaction message (corresponding to outbound, the warehouse-in of steel) of issue steel stock, the Transaction Information of contract (corresponding to the purpose of buying, sale), also comprise registration message (becoming the member of electronic trade platform corresponding to registration), new commodity message more, logout message (corresponding to the member who nullifies electronic trade platform), registration updating message (corresponding to upgrading membership information), integration inquiry, credit inquiry etc.
Because electronic trade platform is connected by standard interface with a plurality of clients, client is corresponding to service user in the e-commerce transaction and ISP, the service user is generally the user that need carry out e-commerce transaction by electronic trade platform, and the ISP can be bank, logistics provider etc.Receive path comprises a plurality of receive paths, receives the message of each client issue, can include some service requests in the message.
Need inquire about the message relevant with user profile such as integration and credit with the user of service use side is the example explanation, the user of service use side sends the message of searching user's information, at first, receive path receives the information of searching user's information, because user profile comprises information such as integration, credit, the information of searching user's information comprises the integration query requests, credit inquiry request etc., receive path is the message call packetization module before receiving message, with packings such as the integration request of searching user's information correspondence, credit request, send to the message sink module afterwards; After the message sink module receives the information of searching user's information, call encrypting module, message to this searching user's information is encrypted, message with this searching user's information sends to message queue afterwards, also can directly from receive path, obtain the message of searching user's information by message queue, when message queue receives message, call request splits module, searching user's information is split into corresponding integration request, credit request etc., and the inquiring user request that therefore enters in the message queue can be the message after splitting; Message in the message queue etc. enters the Message Processing thread through the message control module afterwards, and after the qualification quantity through the Message Processing thread, the Message Processing pipeline that the request of entering is corresponding, request enters the Message Processing pipeline of integration request correspondence as integration, credit request enters the Message Processing pipeline of credit request correspondence, by each self-corresponding Message Processing pipeline to the integration request, credit request is handled, with the integration request is example, the Message Processing pipeline of integration request correspondence is at first deciphered the integration request of encrypting through the deciphering stage, enter the integration processing of request stage after the deciphering, this the processing stage, call database, from database, inquire about integration.
The integration processing of request stage of above-described specific embodiment does not relate to concrete business, is simple integration inquiry, does not therefore relate to operation flow.Electronic trade platform relates to concrete transaction business, must have operation flow, according to predetermined operation flow business is carried out smoothly, and predetermined flow process is finished decision the kind of the request of transaction needs.
Though the present invention with preferred embodiment openly as above; but it is not to be used for limiting the present invention; any those skilled in the art without departing from the spirit and scope of the present invention; can utilize the method and the technology contents of above-mentioned announcement that technical solution of the present invention is made possible change and modification; therefore; every content that does not break away from technical solution of the present invention; to any simple modification, equivalent variations and modification that above embodiment did, all belong to the protection range of technical solution of the present invention according to technical spirit of the present invention.
Claims (16)
1. the message handling system of an ESB is characterized in that, comprising:
The message sink module is used to receive a plurality of messages sent by users, and sorts by pre-defined rule and to be stored in the message queue;
Message processing module is used for receiving from described message sink module the ordering message of predetermined quantity, and handles this message;
The message control module is used for by the described message queue of predefined monitoring instruction real-time listening whether message being arranged, and the state of message processing module, and whether the control messages processing module receives the message of message sink module transmission.
2. message handling system as claimed in claim 1, it is characterized in that, described message processing module includes Message Processing sets of threads and Message Processing pipeline, wherein, the Message Processing sets of threads receives the message of message control module transmission, described transmission of messages to the Message Processing pipeline, and is discharged the Message Processing thread space that the message of end of transmission takies simultaneously, and described Message Processing sets of threads has the higher limit of predetermined quantity; The Message Processing pipeline receives the message that described Message Processing sets of threads is transmitted, and described message is handled.
3. message handling system as claimed in claim 2 is characterized in that, when the message control module listens to described Message Processing sets of threads when having idle Message Processing thread, then controls the message that described message processing module receives described Message Processing thread.
4. message handling system as claimed in claim 1 is characterized in that, the described ordering by pre-defined rule is meant that sending the time sequencing that the time sequencing of message or message sink module receive by the user sorts.
5. message handling system as claimed in claim 1 is characterized in that described message comprises at least one service request; When comprising at least two service requests in the described message, message queue receives a plurality of service requests in the described message; When comprising a service request in the described message, a message queue receives a service request in chronological order.
6. message handling system as claimed in claim 1 is characterized in that, in the described message queue, time of reception be better than the preceding the time after transmission of messages to the Message Processing pipeline, a kind of service request of each Message Processing pipeline alignment processing.
7. message handling system as claimed in claim 6 is characterized in that, in the message that described message sink module receives, comprises that the message of at least one service request is encrypted, before described Message Processing line treatment service request, described message is decrypted.
8. message handling system as claimed in claim 7 is characterized in that, described Message Processing pipeline the processing stage comprise: according to the intended flow processing messages corresponding, and call application module according to the pre-defined rule in the intended flow with message.
9. the message treatment method of an ESB is characterized in that, comprising:
Receive message, sorting by pre-defined rule is stored in the message queue;
According to the order of described message queue, to the Message Processing sets of threads, described Message Processing sets of threads space has higher limit with the transmission of messages in the described message queue; If when the message number in the Message Processing sets of threads reaches described higher limit, then stop the transmission of messages of message queue to the Message Processing sets of threads;
Message in the message processing threads group is handled.
10. message treatment method as claimed in claim 9 is characterized in that, the described ordering by pre-defined rule is meant that the time sequencing that sends or receive by message sorts.
11. message treatment method as claimed in claim 9 is characterized in that, described message comprises at least one service request; When comprising at least two service requests in the described message, message queue receives a plurality of service requests in the described message; When comprising a service request in the described message, a message queue receives a service request in chronological order.
12. message treatment method as claimed in claim 9 is characterized in that, described message in the message processing threads group is handled after, discharge the corresponding shared Message Processing sets of threads of information space simultaneously.
13. message treatment method as claimed in claim 12 is characterized in that, behind the shared Message Processing sets of threads of the information space of release correspondence, according to the message queue order, will not transfer to the transmission of messages of message threads group in the message queue to the Message Processing sets of threads.
14. as claim 9 or 11 described message treatment methods, it is characterized in that, described message in the message processing threads group is handled comprises: transfer to the Message Processing pipeline with limiting number of messages in the Message Processing sets of threads, wherein, the corresponding reception of each Message Processing pipeline handled a kind of service request.
15. message treatment method as claimed in claim 14, it is characterized in that, in the message that described message sink module receives, comprise that the message of at least one service request is encrypted, before described Message Processing line treatment service request, described message is decrypted.
16. message treatment method as claimed in claim 15 is characterized in that, described Message Processing pipeline the processing stage comprise: according to the intended flow processing messages corresponding, and call application module according to the pre-defined rule in the intended flow with message.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN 201010197429 CN102025650A (en) | 2010-06-04 | 2010-06-04 | Message processing system and message processing method of enterprise service bus |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN 201010197429 CN102025650A (en) | 2010-06-04 | 2010-06-04 | Message processing system and message processing method of enterprise service bus |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN102025650A true CN102025650A (en) | 2011-04-20 |
Family
ID=43866522
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN 201010197429 Pending CN102025650A (en) | 2010-06-04 | 2010-06-04 | Message processing system and message processing method of enterprise service bus |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN102025650A (en) |
Cited By (20)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102271139A (en) * | 2011-09-05 | 2011-12-07 | 盛趣信息技术（上海）有限公司 | C/S (Client/Server) framework-based communication system and method |
| CN103093342A (en) * | 2013-01-11 | 2013-05-08 | 北京掌上汇通科技发展有限公司 | Online transaction processing platform and transaction processing method thereof |
| CN103366471A (en) * | 2013-06-26 | 2013-10-23 | 福建联迪商用设备有限公司 | Online service concurrent processing method, system and server |
| CN103780375A (en) * | 2012-10-19 | 2014-05-07 | 中国电信股份有限公司 | Data transmitting method and device, and data receiving method and device |
| CN104933577A (en) * | 2015-06-09 | 2015-09-23 | 广西家之宝网络科技有限公司 | Online retailer platform having message buffering function based on an ORM framework |
| CN104933573A (en) * | 2015-06-09 | 2015-09-23 | 广西家之宝网络科技有限公司 | Online retailer system having functions of message buffering and automatic retransmission |
| CN104933598A (en) * | 2015-06-09 | 2015-09-23 | 广西家之宝网络科技有限公司 | Non-refresh interaction online retailer system having message buffering function |
| CN104933579A (en) * | 2015-06-09 | 2015-09-23 | 广西家之宝网络科技有限公司 | Non-refreshment interaction online retailer system having functions of message buffering and automatic re-transmission |
| CN104933572A (en) * | 2015-06-09 | 2015-09-23 | 广西家之宝网络科技有限公司 | Online retailer system having message buffering function |
| CN104933576A (en) * | 2015-06-09 | 2015-09-23 | 广西家之宝网络科技有限公司 | Online retailer platform having message buffering function based on ORM framework |
| CN104933600A (en) * | 2015-06-09 | 2015-09-23 | 广西家之宝网络科技有限公司 | Non-refresh interaction online retailer system having functions of message buffering and automatic retransmission |
| CN104965766A (en) * | 2015-06-09 | 2015-10-07 | 广西家之宝网络科技有限公司 | Message caching and automatic retransmitting E-commerce system based on ORM framework |
| CN105516265A (en) * | 2015-11-27 | 2016-04-20 | 山东中创软件商用中间件股份有限公司 | Short message transmission method and apparatus |
| CN106453136A (en) * | 2016-09-05 | 2017-02-22 | 深圳前海微众银行股份有限公司 | Method and device for establishing message queue |
| CN103856392B (en) * | 2013-06-26 | 2017-05-24 | 上海携程商务有限公司 | Message push method, outgoing server using message push method and outgoing server system |
| CN107609852A (en) * | 2017-09-05 | 2018-01-19 | 北京小度信息科技有限公司 | For handling the method and apparatus for paying request |
| CN107659547A (en) * | 2016-07-25 | 2018-02-02 | 武汉票据交易中心有限公司 | A kind of flow path processing method and device and server based on event |
| CN109995666A (en) * | 2019-04-12 | 2019-07-09 | 深圳市元征科技股份有限公司 | A kind of method for message transmission and relevant apparatus |
| CN111343239A (en) * | 2020-02-10 | 2020-06-26 | 中国银联股份有限公司 | Communication request processing method, communication request processing device and transaction system |
| CN112464263A (en) * | 2020-12-04 | 2021-03-09 | 苏州浪潮智能科技有限公司 | Data encryption method, system, device and medium |
Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1740974A (en) * | 2005-09-14 | 2006-03-01 | 艾默生网络能源有限公司 | A threading scheduling management method and system |
| US20080201719A1 (en) * | 2007-02-20 | 2008-08-21 | Jerome Daniel | System and method for balancing information loads |
| US7454475B1 (en) * | 2008-01-26 | 2008-11-18 | International Business Machines Corporation | Method and system for using message content to group messages |
| CN101459609A (en) * | 2008-11-27 | 2009-06-17 | 北京思普科科技开发有限公司 | Enterprise service bus implementing method |
| CN101621540A (en) * | 2009-08-10 | 2010-01-06 | 浙江大学 | Method for combining inner service of enterprise service bus based on BPEL engine |
| CN101719929A (en) * | 2009-11-20 | 2010-06-02 | 山东中创软件商用中间件股份有限公司 | Method for realizing real-time data transmission under Web Service |
-
2010
- 2010-06-04 CN CN 201010197429 patent/CN102025650A/en active Pending
Patent Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1740974A (en) * | 2005-09-14 | 2006-03-01 | 艾默生网络能源有限公司 | A threading scheduling management method and system |
| US20080201719A1 (en) * | 2007-02-20 | 2008-08-21 | Jerome Daniel | System and method for balancing information loads |
| US7454475B1 (en) * | 2008-01-26 | 2008-11-18 | International Business Machines Corporation | Method and system for using message content to group messages |
| CN101459609A (en) * | 2008-11-27 | 2009-06-17 | 北京思普科科技开发有限公司 | Enterprise service bus implementing method |
| CN101621540A (en) * | 2009-08-10 | 2010-01-06 | 浙江大学 | Method for combining inner service of enterprise service bus based on BPEL engine |
| CN101719929A (en) * | 2009-11-20 | 2010-06-02 | 山东中创软件商用中间件股份有限公司 | Method for realizing real-time data transmission under Web Service |
Cited By (21)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102271139A (en) * | 2011-09-05 | 2011-12-07 | 盛趣信息技术（上海）有限公司 | C/S (Client/Server) framework-based communication system and method |
| CN103780375A (en) * | 2012-10-19 | 2014-05-07 | 中国电信股份有限公司 | Data transmitting method and device, and data receiving method and device |
| CN103093342A (en) * | 2013-01-11 | 2013-05-08 | 北京掌上汇通科技发展有限公司 | Online transaction processing platform and transaction processing method thereof |
| CN103366471A (en) * | 2013-06-26 | 2013-10-23 | 福建联迪商用设备有限公司 | Online service concurrent processing method, system and server |
| CN103856392B (en) * | 2013-06-26 | 2017-05-24 | 上海携程商务有限公司 | Message push method, outgoing server using message push method and outgoing server system |
| CN104933600A (en) * | 2015-06-09 | 2015-09-23 | 广西家之宝网络科技有限公司 | Non-refresh interaction online retailer system having functions of message buffering and automatic retransmission |
| CN104933577A (en) * | 2015-06-09 | 2015-09-23 | 广西家之宝网络科技有限公司 | Online retailer platform having message buffering function based on an ORM framework |
| CN104933579A (en) * | 2015-06-09 | 2015-09-23 | 广西家之宝网络科技有限公司 | Non-refreshment interaction online retailer system having functions of message buffering and automatic re-transmission |
| CN104933572A (en) * | 2015-06-09 | 2015-09-23 | 广西家之宝网络科技有限公司 | Online retailer system having message buffering function |
| CN104933576A (en) * | 2015-06-09 | 2015-09-23 | 广西家之宝网络科技有限公司 | Online retailer platform having message buffering function based on ORM framework |
| CN104933573A (en) * | 2015-06-09 | 2015-09-23 | 广西家之宝网络科技有限公司 | Online retailer system having functions of message buffering and automatic retransmission |
| CN104965766A (en) * | 2015-06-09 | 2015-10-07 | 广西家之宝网络科技有限公司 | Message caching and automatic retransmitting E-commerce system based on ORM framework |
| CN104933598A (en) * | 2015-06-09 | 2015-09-23 | 广西家之宝网络科技有限公司 | Non-refresh interaction online retailer system having message buffering function |
| CN105516265A (en) * | 2015-11-27 | 2016-04-20 | 山东中创软件商用中间件股份有限公司 | Short message transmission method and apparatus |
| CN107659547A (en) * | 2016-07-25 | 2018-02-02 | 武汉票据交易中心有限公司 | A kind of flow path processing method and device and server based on event |
| CN106453136A (en) * | 2016-09-05 | 2017-02-22 | 深圳前海微众银行股份有限公司 | Method and device for establishing message queue |
| CN106453136B (en) * | 2016-09-05 | 2019-06-25 | 深圳前海微众银行股份有限公司 | Method and device for establishing message queue |
| CN107609852A (en) * | 2017-09-05 | 2018-01-19 | 北京小度信息科技有限公司 | For handling the method and apparatus for paying request |
| CN109995666A (en) * | 2019-04-12 | 2019-07-09 | 深圳市元征科技股份有限公司 | A kind of method for message transmission and relevant apparatus |
| CN111343239A (en) * | 2020-02-10 | 2020-06-26 | 中国银联股份有限公司 | Communication request processing method, communication request processing device and transaction system |
| CN112464263A (en) * | 2020-12-04 | 2021-03-09 | 苏州浪潮智能科技有限公司 | Data encryption method, system, device and medium |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN102025650A (en) | Message processing system and message processing method of enterprise service bus | |
| CN102025649A (en) | Message processing method of enterprise service bus | |
| CN102025653B (en) | Enterprise service bus and message processing method thereof | |
| CN102469033B (en) | Message subscription system and message sending method | |
| US8805938B2 (en) | Enterprise service bus and message processing method thereof | |
| US20040068479A1 (en) | Exploiting asynchronous access to database operations | |
| CN110851248B (en) | Asynchronous task data processing method and device and computer readable storage medium | |
| CN102025651B (en) | Event-driven method applied to enterprise service bus | |
| CN111240862A (en) | Universal interface platform and data conversion method | |
| CN102316160A (en) | Website system and communication method thereof | |
| CN106230985B (en) | One kind is based on Internet of Things big data processing method, system and service processing end | |
| CN101540781B (en) | Method and apparatus for anonymous subject-based addressing | |
| CN102025652B (en) | Service bus and message processing method | |
| CN104240070A (en) | Data release service system and method | |
| CN110399212A (en) | Task requests processing method, device, electronic equipment and computer-readable medium | |
| CN112991064B (en) | Service processing method, device, computer equipment and storage medium | |
| CN103677975A (en) | System and method for having access to internal objects of application systems | |
| US20100325244A1 (en) | Real time data network | |
| CN102510407A (en) | Method and system for reading and writing microblog | |
| KR100759218B1 (en) | Improved RDF middleware engine system and implementation method | |
| CN105224594B (en) | Service-oriented architecture data interconnection query system and query method | |
| CN113129162A (en) | Information interaction method and device for intelligent energy service platform | |
| US20090132582A1 (en) | Processor-server hybrid system for processing data | |
| CN105427149A (en) | Cross-border e-commerce BPO service method and device based on SOA expansion framework | |
| CN102150397B (en) | Method for responding to request relative to hose name and method for entrusting multiple host names in shared entrusted environments |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| C06 | Publication | ||
| PB01 | Publication | ||
| C10 | Entry into substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| ASS | Succession or assignment of patent right |
Owner name: XIBEN NEW LINE E-COMMERCE CO., LTD. Free format text: FORMER OWNER: XIBEN NEW LINE CO., LTD Effective date: 20120202 |
|
| C41 | Transfer of patent application or patent right or utility model | ||
| C53 | Correction of patent of invention or patent application | ||
| CB02 | Change of applicant information |
Address after: 200437, room 2, building 990, 201 East Sports Club Road, Shanghai, Hongkou District Applicant after: West Ben Shinkansen Ltd. Address before: 200437, room 2, building 990, 201 East Sports Club Road, Shanghai, Hongkou District Applicant before: XiBen New Line Stock Co.,Ltd. |
|
| COR | Change of bibliographic data |
Free format text: CORRECT: ADDRESS; FROM: 200437 HONGKOU, SHANGHAI TO: 215434 SUZHOU, JIANGSU PROVINCE |
|
| TA01 | Transfer of patent application right |
Effective date of registration: 20120202 Address after: 215434 No. 88 Binjiang Avenue, Taicang Port Development Zone Applicant after: XiBen New Line Stock Co.,Ltd. Address before: 200437, room 2, building 990, 201 East Sports Club Road, Shanghai, Hongkou District Applicant before: West Ben Shinkansen Ltd. |
|
| C12 | Rejection of a patent application after its publication | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20110420 |