Movatterモバイル変換


[0]ホーム

URL:


CN108762945A - A kind of implementation method for supporting a variety of message queues - Google Patents

A kind of implementation method for supporting a variety of message queues
Download PDF

Info

Publication number
CN108762945A
CN108762945ACN201810455605.8ACN201810455605ACN108762945ACN 108762945 ACN108762945 ACN 108762945ACN 201810455605 ACN201810455605 ACN 201810455605ACN 108762945 ACN108762945 ACN 108762945A
Authority
CN
China
Prior art keywords
message
message queue
queue
variety
supporting
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Pending
Application number
CN201810455605.8A
Other languages
Chinese (zh)
Inventor
岳现国
王君
邹承元
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Inspur General Software Co Ltd
Original Assignee
Inspur General Software Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Inspur General Software Co LtdfiledCriticalInspur General Software Co Ltd
Priority to CN201810455605.8ApriorityCriticalpatent/CN108762945A/en
Publication of CN108762945ApublicationCriticalpatent/CN108762945A/en
Pendinglegal-statusCriticalCurrent

Links

Classifications

Landscapes

Abstract

The invention discloses a kind of implementation method for supporting a variety of message queues, realization process is:Message queue connector is configured first, and it includes transmission message which, which provides, receive message, message is monitored, the messenger service of message monitoring;The service that message queue connector provides is called to realize the asynchronous communication between user.A kind of implementation method for supporting a variety of message queues of the present invention is compared with prior art, provide general message queue connection type, various types of message queues can be adapted to, reduce the cost of implementation that asynchronous communication is carried out using message queue, it is highly practical, it is applied widely, solve the problems, such as that different clients carry out business application system asynchronous communication using different types of message queue.

Description

A kind of implementation method for supporting a variety of message queues
Technical field
The present invention relates to a kind of communication information technical field, specifically a kind of realization side supporting a variety of message queuesMethod.
Background technology
It is logical into line asynchronous commonly using message queue between application system or in application system between different function moduleLetter, interconnected with reaching system, module decoupling, the values such as peak load shifting.Application system is sent in calling message queueOr when receiving message, need to establish the connection with Message Queuing Services;But the connection type that different message queues is establishedDifference, this certainly will cause identical application to need to develop a variety of message queue connection processing logics.Therefore, application oriented system,There is provided a kind of method that is general, supporting a variety of message queues is very important.
Invention content
The technical assignment of the present invention is to be directed to the above shortcoming, provides a kind of realization side supporting a variety of message queuesMethod.
The technical solution adopted by the present invention to solve the technical problems is:
A kind of implementation method for supporting a variety of message queues, realization process are:
Step 1: first configure message queue connector, the message queue connector offer includes send message, reception message,Message monitors, the messenger service of message monitoring;
Step 2: the service that message queue connector provides is called to realize the asynchronous communication between user.
In the step 1, the configuration process of message queue connector is:
1)Configure Message Queuing Services connection;
2)It configures message queue and sends message interface;
3)It configures message queue and receives message interface;
4)It configures message queue and monitors service;
5)Configure message queue management service.
The step 1)In, Message Queuing Services connection includes the server address of message queue connector, port numbers, companyConnect mode, connection description information, registrable multiple, a plurality of types of Message Queuing Services of the Message Queuing Services.
The step 2)In, it includes the transmission message interface program that message queue provides that message queue, which sends message interface,Collection, class name, method name and parameter declaration information.
The step 3)In, it includes the reception message interface program that message queue provides that message queue, which receives message interface,Collection, class name, method name and parameter declaration information.
The step 4)In, the message queue service of monitoring includes the monitoring service routine collection, class name, side of message queue offerReligious name and parameter declaration information.
The step 5)In, message queue management service includes the supervisor services collection, class name, side of message queue offerReligious name and parameter declaration information.
The asynchronous communication realized in the step 2 refers to:By message queue connector configuration in business application system orBetween asynchronous communication scene between system, a variety of message queues are connected by message queue connector, provides and disappears for all usersBreath service, realizes message communicating.
The specific implementation process of the step 2 is:
The message transmission interface that message sender calls message queue connector to provide carries out message transmission;
Message receiver calls the message sink interface that message queue connector provides, and receives message and generates corresponding respond;
In message transmitting process, the management service of message queue offer, the transmission of monitoring message or reception condition are called.
Compared to the prior art a kind of implementation method for supporting a variety of message queues of the present invention, has below beneficial to effectFruit:
The present invention is provided general message queue connection type, can be fitted by a kind of connector for supporting a variety of message queuesWith various types of message queues, the cost of implementation that asynchronous communication is carried out using message queue is reduced, it is highly practical, it is applicable in modelIt encloses extensively, solves the problems, such as that different clients carry out business application system asynchronous communication using different types of message queue.
Description of the drawings
It, below will be to embodiment or existing for the clearer technical solution for illustrating the embodiment of the present invention or the prior artAttached drawing is briefly described needed in technology description, it should be apparent that, the accompanying drawings in the following description is only this hairSome bright embodiments for those of ordinary skill in the art without creative efforts, can be with rootOther attached drawings are obtained according to these attached drawings.
Attached drawing 1 is the realization schematic diagram of the present invention.
Attached drawing 2 is the realization code map of the present invention.
Specific implementation mode
The invention will be further described in the following with reference to the drawings and specific embodiments.
As shown in Fig. 1, a kind of implementation method for supporting a variety of message queues of the invention, mainly by registering a variety of disappearThe mode of queue service is ceased to realize that a variety of message queues of connection carry out message communicating, it is intended to be solved different clients and be used inhomogeneityThe message queue of type carries out the problem of business application system asynchronous communication.
Its realization process is:
Step 1: first configure message queue connector, the message queue connector offer includes send message, reception message,Message monitors, the messenger service of message monitoring;
Step 2: the service that message queue connector provides is called to realize the asynchronous communication between user.
Above-mentioned message queue connector is based on Active MQ, Kafka MQ, Rabbit MQ and realizes.
In the step 1, the configuration process of message queue connector is:
S100:Configure Message Queuing Services connection;
S101:It configures message queue and sends message interface;
S102:It configures message queue and receives message interface;
S103:It configures message queue and monitors service;
S104:Configure message queue management service.
In the step s 100, configuration Message Queuing Services connection.It further illustrates, Message Queuing Services connection includes messageThe information such as queue Broker server address, port numbers, connection type, connection description, support registration is multiple, a plurality of types of to disappearCease queue service.
In step S101, configuration message queue sends message interface.It further illustrates, message queue sends message and connectsMouthful, including the information such as transmission message interface procedure set, class name, method name and parameter declaration of message queue offer.
In step s 102, configuration message queue receives message interface.It further illustrates, message queue receives message and connectsMouthful, including the information such as reception message interface procedure set, class name, method name and parameter declaration of message queue offer.
In step s 103, configuration message queue monitors service.It further illustrates, message queue monitors service, including disappearsCease the information such as monitoring service routine collection, class name, method name and the parameter declaration that queue provides.
In step S104, message queue management service is configured.It further illustrates, message queue management service, including disappearsCease the information such as supervisor services collection, class name, method name and the parameter declaration that queue provides.
In step 2, message queue connector provides common message handling services.It further illustrates, message queue connectsDevice is connect to provide according to configuration and send message, receive the services such as message, message monitoring, message management monitoring.
Embodiment explanation:The present invention realizes the service by registration message queue Broker and its offer, ERP systemThe service that message queue connection provides is called to realize that sales order connects with the asynchronous communication of order, ERP system, message queue is producedThe logical relation connect between device, message queue is as shown in Figure 1.
The service of registration message queue Broker and its offer first, registration configuration structure are as shown in Figure 2.FurtherlyIt is bright, include the following steps:
Configure message queue connection;
It configures message queue and sends message interface;
It configures message queue and receives message interface;
It configures message queue and monitors service;
Configure message queue message management services.
Then, it calls the service that message queue connector provides to realize asynchronous communication, further illustrates, including following stepSuddenly:
The message transmission interface that sales order calls message queue connector to provide carries out transmission order information;
The message sink interface that order calls message queue connector to provide is produced, the generation production of sales order information is received and ordersIt is single;
Finally, the management service for calling message queue to provide, the transmission of monitoring message or reception condition.
The technical personnel in the technical field can readily realize the present invention with the above specific embodiments,.But it answersWork as understanding, the present invention is not limited to above-mentioned specific implementation modes.On the basis of the disclosed embodiments, the technical fieldTechnical staff can arbitrarily combine different technical features, to realize different technical solutions.
It is the known technology of those skilled in the art in addition to the technical characteristic described in specification.

Claims (9)

CN201810455605.8A2018-05-142018-05-14A kind of implementation method for supporting a variety of message queuesPendingCN108762945A (en)

Priority Applications (1)

Application NumberPriority DateFiling DateTitle
CN201810455605.8ACN108762945A (en)2018-05-142018-05-14A kind of implementation method for supporting a variety of message queues

Applications Claiming Priority (1)

Application NumberPriority DateFiling DateTitle
CN201810455605.8ACN108762945A (en)2018-05-142018-05-14A kind of implementation method for supporting a variety of message queues

Publications (1)

Publication NumberPublication Date
CN108762945Atrue CN108762945A (en)2018-11-06

Family

ID=64010519

Family Applications (1)

Application NumberTitlePriority DateFiling Date
CN201810455605.8APendingCN108762945A (en)2018-05-142018-05-14A kind of implementation method for supporting a variety of message queues

Country Status (1)

CountryLink
CN (1)CN108762945A (en)

Cited By (5)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN110399236A (en)*2019-07-252019-11-01泰康保险集团股份有限公司Adaptation method, device, medium and the electronic equipment of message queue
CN110417913A (en)*2019-08-092019-11-05浪潮云信息技术有限公司A kind of asynchronous creation method of Cloud Server based on Rabbit MQ
CN113419882A (en)*2021-08-242021-09-21成都特维思科技有限公司Method for dynamically switching message queue
CN113923248A (en)*2021-09-302022-01-11深圳海智创科技有限公司 A general MQ interaction method, system, device and storage medium
CN114119220A (en)*2021-11-122022-03-01上海金仕达软件科技有限公司 A kind of precious metal intelligent quotation method and device

Citations (9)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
US7152094B1 (en)*2001-07-312006-12-19Sprint Communications Company L.P.Middleware brokering system adapter
CN101078995A (en)*2007-06-082007-11-28北京大学Method for accessing information service in component operation support platform
US20080115147A1 (en)*2006-11-152008-05-15Ricoh Corporation Ltd.Device architecture to support multiple protocols
CN101651631A (en)*2008-08-122010-02-17新奥特(北京)视频技术有限公司Method for message access in system integration of global station network of television station
US7937433B1 (en)*2003-09-232011-05-03Embarq Holdings Company, LlcQueuing connector to promote message servicing
CN102714634A (en)*2009-10-022012-10-03杰出网络公司Real-time message queuing for a processing ring
CN103843290A (en)*2011-09-292014-06-04甲骨文国际公司 System and method for supporting disparate message queues in a transactional middleware machine environment
US9590885B1 (en)*2013-03-132017-03-07Sprint Communications Company L.P.System and method of calculating and reporting of messages expiring from a queue
CN106933589A (en)*2017-03-132017-07-07车智互联(北京)科技有限公司A kind of message queue component based on configuration and its integrated method

Patent Citations (9)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
US7152094B1 (en)*2001-07-312006-12-19Sprint Communications Company L.P.Middleware brokering system adapter
US7937433B1 (en)*2003-09-232011-05-03Embarq Holdings Company, LlcQueuing connector to promote message servicing
US20080115147A1 (en)*2006-11-152008-05-15Ricoh Corporation Ltd.Device architecture to support multiple protocols
CN101078995A (en)*2007-06-082007-11-28北京大学Method for accessing information service in component operation support platform
CN101651631A (en)*2008-08-122010-02-17新奥特(北京)视频技术有限公司Method for message access in system integration of global station network of television station
CN102714634A (en)*2009-10-022012-10-03杰出网络公司Real-time message queuing for a processing ring
CN103843290A (en)*2011-09-292014-06-04甲骨文国际公司 System and method for supporting disparate message queues in a transactional middleware machine environment
US9590885B1 (en)*2013-03-132017-03-07Sprint Communications Company L.P.System and method of calculating and reporting of messages expiring from a queue
CN106933589A (en)*2017-03-132017-07-07车智互联(北京)科技有限公司A kind of message queue component based on configuration and its integrated method

Non-Patent Citations (1)

* Cited by examiner, † Cited by third party
Title
卢鹏: "基于JMS的消息中间件的轻量级设计与整合", 《中国优秀硕士学位论文全文数据库 信息科技辑》*

Cited By (5)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN110399236A (en)*2019-07-252019-11-01泰康保险集团股份有限公司Adaptation method, device, medium and the electronic equipment of message queue
CN110417913A (en)*2019-08-092019-11-05浪潮云信息技术有限公司A kind of asynchronous creation method of Cloud Server based on Rabbit MQ
CN113419882A (en)*2021-08-242021-09-21成都特维思科技有限公司Method for dynamically switching message queue
CN113923248A (en)*2021-09-302022-01-11深圳海智创科技有限公司 A general MQ interaction method, system, device and storage medium
CN114119220A (en)*2021-11-122022-03-01上海金仕达软件科技有限公司 A kind of precious metal intelligent quotation method and device

Similar Documents

PublicationPublication DateTitle
CN108762945A (en)A kind of implementation method for supporting a variety of message queues
EP3662620B1 (en)Data sharing between participants using disparate message formats
US7596599B1 (en)Management capabilities for real-time messaging networks
WO2005036798A3 (en)Switchboard for interactive voice response (ivr) services
CN100559403C (en)Bank client note numbering queueing method
CN105357286B (en) A Web-based Real-time Message Directional Push Method
CN109684111A (en)Information push method, message push system and computer readable storage medium
CN104796561B (en)Distribute the system that method, CTI equipment, terminal and the distribution attended a banquet are attended a banquet
US8644491B2 (en)Mechanism for multisite service state description
CN104486440A (en)Message bus-based cloud computing management software interaction method
CA2979824C (en)Method and system for transferring messages between messaging systems
CN106302647B (en)Message distribution method and server
CN103534978B (en)A kind of packet information packet transmission method and equipment
CN107592215A (en)A kind of method for managing message-oriented middleware
CN101795222A (en)Multi-stage forward service system and method
CN102148905A (en)Method and device for queuing calls
CN109067669A (en)Synchronization call method and application based on asynchronous interface
CN106789566A (en)Different IM application messages sharing methods and system based on mobile phone operating system
CN103079178B (en)The message management method of a kind of NGCRM second filial generation CRM system and system
CN109710435A (en)A kind of message delivery method based on the more message queues of support
CN101339520B (en) A Method of Connecting EJB to Enterprise Service Bus
CN105827671A (en)System platform characterized by distributed use and centralized management and portal server
CN105005469B (en)A kind of Non-blocking call method based on Zookeeper and RabbitMQ
CN110417875B (en)Method, system, equipment and storage medium for docking between cloud servers
CN107911462A (en)High-volume method of data synchronization based on ActiveMQ

Legal Events

DateCodeTitleDescription
PB01Publication
PB01Publication
SE01Entry into force of request for substantive examination
SE01Entry into force of request for substantive examination
RJ01Rejection of invention patent application after publication
RJ01Rejection of invention patent application after publication

Application publication date:20181106


[8]ページ先頭

©2009-2025 Movatter.jp