CN109933439A - Method for message transmission, device, computer equipment and storage medium - Google Patents
Method for message transmission, device, computer equipment and storage medium Download PDFInfo
- Publication number
- CN109933439A CN109933439A CN201910119555.0A CN201910119555A CN109933439A CN 109933439 A CN109933439 A CN 109933439A CN 201910119555 A CN201910119555 A CN 201910119555A CN 109933439 A CN109933439 A CN 109933439A
- Authority
- CN
- China
- Prior art keywords
- message
- transmitted
- management part
- sent
- subject identification
- 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.)
- Granted
Links
- 230000005540 biological transmission Effects 0.000 title claims abstract description 47
- 238000000034 method Methods 0.000 title claims abstract description 39
- 238000003860 storage Methods 0.000 title claims abstract description 19
- 238000004519 manufacturing process Methods 0.000 claims abstract description 78
- 238000004590 computer program Methods 0.000 claims description 29
- 238000012545 processing Methods 0.000 claims description 20
- 238000007726 management method Methods 0.000 description 166
- 238000010586 diagram Methods 0.000 description 5
- 238000005516 engineering process Methods 0.000 description 4
- 239000000203 mixture Substances 0.000 description 4
- 230000008569 process Effects 0.000 description 4
- 230000002159 abnormal effect Effects 0.000 description 2
- 238000001514 detection method Methods 0.000 description 2
- 238000011161 development Methods 0.000 description 2
- 238000004364 calculation method Methods 0.000 description 1
- 238000004891 communication Methods 0.000 description 1
- 238000013461 design Methods 0.000 description 1
- 238000009826 distribution Methods 0.000 description 1
- 230000002708 enhancing effect Effects 0.000 description 1
- 230000006870 function Effects 0.000 description 1
- 239000003999 initiator Substances 0.000 description 1
- 230000000977 initiatory effect Effects 0.000 description 1
- 230000007246 mechanism Effects 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 230000000737 periodic effect Effects 0.000 description 1
- 238000004321 preservation Methods 0.000 description 1
- 230000003068 static effect Effects 0.000 description 1
- 230000001360 synchronised effect Effects 0.000 description 1
Landscapes
- Information Transfer Between Computers (AREA)
Abstract
This application involves a kind of method for message transmission, device, computer equipment and storage mediums.Method includes: that message management part obtains the message to be transmitted that the manufacturing side is sent, and the message to be transmitted carries subject identification；The message to be transmitted is sent to message-oriented middleware corresponding with the subject identification by the message management part；The message management part is obtained through the message-oriented middleware treated the message to be transmitted, treated that the message to be transmitted is sent to and corresponding consumption terminal by described, by way of introducing message management part, so that the manufacturing side is directly to be interacted with message management part with consumption terminal, so as to be effectively managed collectively by message management part to message-oriented middleware, the resource consumption of message communicating is reduced.
Description
Technical field
This application involves field of computer technology, more particularly to a kind of method for message transmission, device, computer equipment and
Storage medium.
Background technique
With the development of computer technology, internet industry is also more and more extensive for the utilization of message, in traditional technology,
Processing mode using mq (Message Queue, message queue are a kind of communication means of application program to application program) is
Each client and mq establish connection, by the duplicate message technology logic of each client process and undertake the money communicated with mq
Source consumption.But the processing mode and its inconvenience of this mq, it is also each among each mq to have oneself a set of message processing logic by oneself,
Mq middleware can not be managed collectively.
Summary of the invention
Based on this, it is necessary in view of the above technical problems, provide one kind and can facilitate and be managed collectively to mq middleware
Method for message transmission, device, computer equipment and storage medium.
A kind of method for message transmission, which comprises
Message management part obtains the message to be transmitted that the manufacturing side is sent, and the message to be transmitted carries subject identification；
The message to be transmitted is sent to message-oriented middleware corresponding with the subject identification by the message management part；
The message management part is obtained by the message-oriented middleware treated the message to be transmitted, by the processing
The message to be transmitted afterwards is sent to and corresponding consumption terminal.
A kind of massage transmission device, which is characterized in that described device includes:
Message transmission module obtains the message to be transmitted that the manufacturing side is sent, the message to be transmitted for message management part
Carry subject identification；
The message to be transmitted is sent to and the subject identification pair by message transmitting module for the message management part
The message-oriented middleware answered；
Message processing module, obtains that treated is described to be passed by the message-oriented middleware for the message management part
Defeated message, treated that the message to be transmitted is sent to and corresponding consumption terminal by described.
A kind of computer equipment, including memory, processor, the memory are stored with computer program, the processing
Device performs the steps of when executing the computer program
Message management part obtains the message to be transmitted that the manufacturing side is sent, and the message to be transmitted carries subject identification；
The message to be transmitted is sent to message-oriented middleware corresponding with the subject identification by the message management part；
The message management part is obtained by the message-oriented middleware treated the message to be transmitted, by the processing
The message to be transmitted afterwards is sent to and corresponding consumption terminal.
A kind of computer readable storage medium, is stored thereon with computer program, and the computer program is held by processor
It is performed the steps of when row
Message management part obtains the message to be transmitted that the manufacturing side is sent, and the message to be transmitted carries subject identification；
The message to be transmitted is sent to message-oriented middleware corresponding with the subject identification by the message management part；
The message management part is obtained by the message-oriented middleware treated the message to be transmitted, by the processing
The message to be transmitted afterwards is sent to and corresponding consumption terminal.
A kind of method for message transmission, which comprises
Consumption terminal, which is sent, subscribes to message to message management part, and the subscription message carries subject identification；
The manufacturing side sends message to be transmitted to the message management part, and the message to be transmitted carries subject identification；
The message to be transmitted is sent to message-oriented middleware corresponding with the subject identification by the message management part；
The message-oriented middleware is handled the message to be transmitted according to the subject identification, described in treated
Message to be transmitted is sent to the message management part；
Treated that message to be transmitted is sent to the consumption terminal by described for the message management part.
A kind of computer equipment, including memory, processor, the memory are stored with computer program, the processing
Device performs the steps of when executing the computer program
Consumption terminal, which is sent, subscribes to message to message management part, and the subscription message carries subject identification；
The manufacturing side sends message to be transmitted to the message management part, and the message to be transmitted carries subject identification；
The message to be transmitted is sent to message-oriented middleware corresponding with the subject identification by the message management part；
The message-oriented middleware is handled the message to be transmitted according to the subject identification, described in treated
Message to be transmitted is sent to the message management part；
Treated that message to be transmitted is sent to the consumption terminal by described for the message management part.
A kind of computer readable storage medium, is stored thereon with computer program, and the computer program is held by processor
It is performed the steps of when row
Consumption terminal, which is sent, subscribes to message to message management part, and the subscription message carries subject identification；
The manufacturing side sends message to be transmitted to the message management part, and the message to be transmitted carries subject identification；
The message to be transmitted is sent to message-oriented middleware corresponding with the subject identification by the message management part；
The message-oriented middleware is handled the message to be transmitted according to the subject identification, described in treated
Message to be transmitted is sent to the message management part；
Treated that message to be transmitted is sent to the consumption terminal by described for the message management part.
Above-mentioned method for message transmission, device, computer equipment and storage medium obtain manufacturing side hair by message management part
Message to be transmitted is sent to message-oriented middleware corresponding with subject identification by message management part by the message to be transmitted sent, and is obtained
By message-oriented middleware treated message to be transmitted, and will treated message to be transmitted is sent to corresponding consumption terminal,
By way of introducing message management part so that the manufacturing side be with consumption terminal directly interacted with message management part, thus
Message-oriented middleware can be effectively managed collectively by message management part, reduce the resource consumption of message communicating.
Detailed description of the invention
Fig. 1 is the applied environment figure of method for message transmission in one embodiment；
Fig. 2 is the flow diagram of method for message transmission in one embodiment；
Fig. 3 is message transmission frame composition in one embodiment；
Fig. 4 is the flow diagram of method for message transmission in another embodiment；
Fig. 5 is the structural block diagram of massage transmission device in one embodiment；
Fig. 6 is the structural block diagram of massage transmission device in another embodiment；
Fig. 7 is the internal structure chart of computer equipment in one embodiment.
Specific embodiment
It is with reference to the accompanying drawings and embodiments, right in order to which the objects, technical solutions and advantages of the application are more clearly understood
The application is further elaborated.It should be appreciated that specific embodiment described herein is only used to explain the application, not
For limiting the application.
Method for message transmission provided by the present application can be applied in application environment as shown in Figure 1.Wherein, the manufacturing side
102, consumption terminal 104 is communicated with message server 106 by network by network, includes in message server 106
Message management part 108 and message-oriented middleware 110, wherein the message of production is sent to message management by network by the manufacturing side 102
Part 108, message management part 108 are sent a message to after message-oriented middleware 110 handled by network, then message are transmitted to
Consumption terminal 104 carries out message, i.e. progress business logic processing.Wherein, the manufacturing side 102 refers to the initiator of business, is responsible for life
The terminal of information and sending to message server 106 is produced, consumption terminal 104 refers to the processing side of business, is responsible for from messaging service
Device 106 obtains message and carries out the terminal of business logic processing.The manufacturing side 102 and consumption terminal 104 can be, but not limited to be various
Personal computer, laptop, smart phone, tablet computer and portable wearable device.Message server 106 refers to use
In providing the server of message core service, the server cluster of the either multiple server compositions of independent server can be used
To realize.Message management part 108 refers to for directly being communicated with the manufacturing side 102 and consumption terminal 104, and to message-oriented middleware
The 110 management components being managed.Message-oriented middleware 110 refers to the intermediate member to the distribution of message logical process.
In one embodiment, as shown in Fig. 2, providing a kind of method for message transmission, it is applied in Fig. 1 in this way
It is illustrated for message server 106, comprising the following steps:
Step 202, message management part obtains the message to be transmitted that the manufacturing side is sent, and message to be transmitted carries theme mark
Know.
Message to be transmitted refers to the message for being produced by the manufacturing side and being sent to message server.Include in message server
The quantity of at least one message management part and at least one message-oriented middleware, message management part and message-oriented middleware can be according to reality
Border situation is increased.The manufacturing side produces message to be transmitted according to service logic, and message to be transmitted is sent to messaging service
Message management part in device is got the message to be transmitted of manufacturing side transmission by message management part.Wherein, message to be transmitted carries
There is subject identification, subject identification is identified correspondingly with the type of theme of storage configuration in message server.It is taken in message
It is engaged in device, storage configuration has multiple themes that can be subscribed to by the manufacturing side and consumption terminal, and the manufacturing side can be sent to message server
Master corresponding with each type of theme can be carried in the message to be transmitted that the message of different themes type, the i.e. manufacturing side are sent
Topic mark.
Step 204, message to be transmitted is sent to message-oriented middleware corresponding with subject identification by message management part.
Step 206, message management part is obtained through message-oriented middleware treated message to be transmitted, will that treated is to be passed
Defeated message is sent to and corresponding consumption terminal.
For message management part after the message to be transmitted for receiving manufacturing side transmission, message management part sends message to be transmitted
To message-oriented middleware corresponding with subject identification, message to be transmitted is handled by message-oriented middleware, and by treated
Message to be transmitted is sent to message management part, and by message management part, by treated, message to be transmitted is sent to corresponding consumption
End.
That is, what is finally interacted with the manufacturing side and consumption terminal is message management part, message-oriented middleware be then not necessarily to it is each
A manufacturing side and consumption terminal interact, but interact with message management part, and such implementation can be by institute
There are the manufacturing side and consumption terminal and the pressure of message-oriented middleware to focus on message management part, the details of each message transmission can also be by
Message-oriented middleware is completed, and the manufacturing side and consumption terminal are then not necessarily to consider that parameters and details of the message when interacting are considered,
Development efficiency can significantly be increased.
In one embodiment, above-mentioned method for message transmission further include: message management part obtains the subscription of consumption terminal triggering
Message subscribes to message and carries subject identification.By treated, message to be transmitted is sent to and corresponding consumption terminal, comprising: will
Message to be transmitted that treated is sent to the consumption terminal that message is subscribed in triggering.
Different consumption terminals can choose the message of processing different themes type, and therefore, consumption terminal can send in advance and order
Message management part of the message into message server is read, after subscribing to successfully corresponding theme, which can handle corresponding class
The message to be transmitted of type.The subscription message of triggering can be sent to message management part when initiating message subscribing by consumption terminal, be subscribed to
The subject identification that the consumption terminal needs to subscribe to is carried in message.Subject identification can have multiple, that is, consumption terminal is carrying out theme
When subscription, multiple themes can be disposably subscribed to, each consumption terminal can also subscribe to the message of multiple themes.
When consumption terminal, which has sent, subscribes to message to the one or more type of theme of message management part successful subscription, then say
The bright consumption terminal can be handled the message of the type of theme of subscription.That is, message management part is handled by message-oriented middleware
, can be according to each consumption terminal to the subscription situation of type of theme when message to be transmitted afterwards is sent to consumption terminal and is handled, it will
Message to be transmitted is sent to the consumption terminal for triggering the subscription message of the type of theme, which is disappeared to be transmitted
Breath performs corresponding processing.
Message transmission frame composition as shown in Figure 3, the manufacturing side and consumption terminal can have one or more.Wherein, message takes
It is engaged in device including message management part cluster and message-oriented middleware cluster, includes multiple message managements in message management part cluster
Part, such as message management part 1, message management part 2 ..., message management part n.It include in multiple message in message-oriented middleware cluster
Between part, such as message-oriented middleware 1, message-oriented middleware 2 ..., message-oriented middleware n.The manufacturing side 1, the manufacturing side 2 send message to be transmitted extremely
In message management part cluster, specifically, message to be transmitted is sent in message management part cluster in good for use by the manufacturing side
Message to be transmitted is sent in message-oriented middleware cluster in shape good for use by the message management part of state by message management part
The message-oriented middleware of state, message-oriented middleware again will treated that message is back to message management part, by message management part by message
It is sent to consumption terminal to be handled, realizes the load balancing of message transmission.Subscribing to message is initiated by consumption terminal, and consumption is worked as
When end needs to subscribe to the message of certain a kind of type of theme, it can be transmitted and subscribe to message into message management part cluster in good for use
The message management part of state, similarly, message management part forwards the messages to message-oriented middleware, by message-oriented middleware to message into
Be back to message management part after row processing, message management part sends a message to consumption terminal again, such as notice consumption terminal subscribe at
Function etc..
Above-mentioned method for message transmission obtains the message to be transmitted that the manufacturing side is sent by message management part, by message management
Message to be transmitted is sent to message-oriented middleware corresponding with subject identification by part, obtains that treated is to be passed by message-oriented middleware
Defeated message, and will treated that message to be transmitted is sent to is made by way of introducing message management part with corresponding consumption terminal
The manufacturing side be directly to be interacted with message management part with consumption terminal, so as to pass through message management part to message among
Part is effectively managed collectively, and the resource consumption of message communicating is reduced.
In one embodiment, after the subscription message that message management part obtains consumption terminal triggering, further includes: message pipe
Reason part saves the corresponding user identifier of consumption terminal and subject identification to database；Database by user identifier and subject identification into
Row association.
After consumption terminal sends and subscribes to message management part of the message into message server, i.e., disappear in the acquisition of message management part
After the subscription message of Fei Duan triggering, message management part the corresponding user identifier of consumption terminal and can will subscribe to the master that carry in message
Topic mark is saved to database, meanwhile, the user identifier and subject identification can be associated preservation by database.Subsequent lookup
When, the user identifier can be found by user identifier and subscribes to successful subject identification, can also be searched according to subject identification
To the user identifier for subscribing to the subject identification.
When consumption terminal, which triggers subscription message, is sent to message management part, message management part, which can will subscribe to message and be forwarded to, to disappear
Middleware is ceased, message-oriented middleware can then know the subscription situation of subject identification, i.e. message-oriented middleware will also realize that each user
The corresponding subject identification subscribed to of mark.Thus after message to be transmitted is sent to message-oriented middleware by message management part, in message
Between part message to be transmitted corresponding with subject identification can be back to by message according to the subject identification carried in message to be transmitted
Manage part, message management part then can message to be transmitted be sent to has subscribed the consumption terminal of the type of theme and carry out by treated
Processing.
In one embodiment, above-mentioned method for message transmission further include: when message management part detects theme in database
When to identify associated user identifier be empty, subject identification is deleted.
Message management part can carry out periodic detection to the subject data stored in database, when message management part detects number
When according to there are the associated user identifier of some subject identification being empty in library, i.e., deposited when message management part detects in database
When some subject identification of storage does not have any one user to subscribe to, then the subject identification can be deleted.
In one embodiment, message management part obtains the message to be transmitted that the manufacturing side is sent, comprising: message management part obtains
Take the manufacturing side that messaging service interface is called to obtain the server address of message management part from database, the manufacturing side is according to server
The message to be transmitted that address is sent.
The manufacturing side can call messaging service interface to obtain from database when sending message to be transmitted to message management part
The server address of message management part is got, to send message to be transmitted to the corresponding message server of the server address.
When the server address for having message server is deposited when abnormal, message management part can delete abnormal server address,
Ensure the manufacturing side when obtaining server address, what is got is all the server address that can be called.
In one embodiment, as shown in figure 4, also providing a kind of method for message transmission, it is applied in Fig. 1 in this way
Message server 106 for be illustrated, comprising the following steps:
Step 402, consumption terminal, which is sent, subscribes to message to message management part, subscribes to message and carries subject identification.
Step 404, the manufacturing side sends message to be transmitted to message management part, and message to be transmitted carries subject identification.
Step 406, message to be transmitted is sent to message-oriented middleware corresponding with subject identification by message management part.
Step 408, message-oriented middleware is handled message to be transmitted according to subject identification, will treated to be transmitted disappears
Breath is sent to message management part.
Step 410, by treated, message to be transmitted is sent to consumption terminal to message management part.
When consumption terminal needs to handle the message of a certain type of theme, subscription message to message management part can be sent and led
The subscription of topic, after subscribing to successfully, the message of the type of theme can be then sent to consumption terminal and handled by message management part.This
Mechanism is similar to news subscription.For example, can then initiate to order financial and economic news when user A wishes to read finance and economic news
It reads, it is subsequent when finance and economic news has update, then user A can be pushed to immediately, facilitate the reading of user A, and not for user A
The entertainment news of subscription, server then will not be by amusement class news push to user A.In the subscription message that consumption terminal is sent, take
With subject identification, convenient for the database in message server by the user identifier of login account in consumption terminal and subject identification into
Row associated storage.
In one embodiment, the manufacturing side sends message to be transmitted to message management part, comprising: the manufacturing side calls message clothes
Business interface passes through messaging service interface and obtains the server address for being in normal condition message management part；The manufacturing side sends to be passed
Defeated message is to the server address for being in normal condition message management part.
The manufacturing side can send message to be transmitted to message management part according to business demand, and the manufacturing side is sending message to be transmitted
When, messaging service interface can be called to get the corresponding column of server address for being completely in the message management part of normal condition
Table gets the server address of the message management part in normal condition, and message to be transmitted is sent in normal
The server address of status message management part.
Subject identification is carried in message to be transmitted, message management part, can will be to be passed after receiving message to be transmitted
Defeated message is forwarded to message-oriented middleware corresponding with subject identification.The message to be transmitted of different themes type is by different message
Between part handled, will treated to be transmitted disappears after message-oriented middleware is handled message to be transmitted according to subject identification
Breath is sent to message management part, then by this, treated that message to be transmitted is sent to consumption terminal by message management part, by consumption terminal
Message is handled.
This Message Processing transmission method, introduces message management part, and the manufacturing side and consumption terminal are and message management part
Directly interact, so as to be effectively managed collectively by message management part to message-oriented middleware, it is logical to reduce message
The resource consumption of letter.
It should be understood that although each step in the flow chart of Fig. 2-4 is successively shown according to the instruction of arrow,
These steps are not that the inevitable sequence according to arrow instruction successively executes.Unless expressly stating otherwise herein, these steps
Execution there is no stringent sequences to limit, these steps can execute in other order.Moreover, at least one in Fig. 2-4
Part steps may include that perhaps these sub-steps of multiple stages or stage are not necessarily in synchronization to multiple sub-steps
Completion is executed, but can be executed at different times, the execution sequence in these sub-steps or stage is also not necessarily successively
It carries out, but can be at least part of the sub-step or stage of other steps or other steps in turn or alternately
It executes.
In one embodiment, as shown in figure 5, providing a kind of massage transmission device, comprising:
Message transmission module 502 obtains the message to be transmitted that the manufacturing side is sent for message management part, and message to be transmitted is taken
With subject identification.
Message to be transmitted is sent to message corresponding with subject identification for message management part by message transmitting module 504
Middleware.
Message processing module 506 is obtained for message management part through message-oriented middleware treated message to be transmitted, will
Message to be transmitted that treated is sent to and corresponding consumption terminal.
In one embodiment, message transmission module 502 is also used to message management part and obtains manufacturing side calling messaging service
Interface obtains the server address of message management part from database, and the manufacturing side to be transmitted disappears according to what server address was sent
Breath.
In one embodiment, above-mentioned massage transmission device further includes subscribing module (not shown), is used for message pipe
The subscription message that part obtains consumption terminal triggering is managed, message is subscribed to and carries subject identification.Message processing module 506 is also used to locate
Message to be transmitted after reason is sent to the consumption terminal that message is subscribed in triggering.
In one embodiment, above-mentioned subscribing module is also used to message management part for the corresponding user identifier of consumption terminal and master
Topic mark is saved to database；User identifier and subject identification are associated by database.
In one embodiment, above-mentioned massage transmission device further includes data detection module (not shown), for working as
When message management part detects that the associated user identifier of subject identification is empty in database, subject identification is deleted.
In one embodiment, as shown in fig. 6, also providing a kind of massage transmission device, comprising:
Message subscribing module 602 sends for consumption terminal and subscribes to message to message management part, subscribes to message and carry theme
Mark.
First message transmission module 604 sends message to be transmitted to message management part for the manufacturing side, and message to be transmitted is taken
With subject identification；Message to be transmitted is sent to message-oriented middleware corresponding with subject identification by message management part；
Second message transmission module 606 is handled message to be transmitted according to subject identification for message-oriented middleware, will
Treated, and message to be transmitted is sent to message management part；By treated, message to be transmitted is sent to consumption to message management part
End.
In one embodiment, first message transmission module 604 is also used to the manufacturing side and calls messaging service interface, by disappearing
It ceases service interface and obtains the server address for being in normal condition message management part；The manufacturing side sends message to be transmitted to being in just
The server address of normal status message management part.
Specific about massage transmission device limits the restriction that may refer to above for method for message transmission, herein not
It repeats again.Modules in above-mentioned massage transmission device can be realized fully or partially through software, hardware and combinations thereof.On
Stating each module can be embedded in the form of hardware or independently of in the processor in computer equipment, can also store in a software form
In memory in computer equipment, the corresponding operation of the above modules is executed in order to which processor calls.
In one embodiment, a kind of computer equipment is provided, which can be server, internal junction
Composition can be as shown in Figure 7.The computer equipment include by system bus connect processor, memory, network interface and
Database.Wherein, the processor of the computer equipment is for providing calculating and control ability.The memory packet of the computer equipment
Include non-volatile memory medium, built-in storage.The non-volatile memory medium is stored with operating system, computer program and data
Library.The built-in storage provides environment for the operation of operating system and computer program in non-volatile memory medium.The calculating
The database of machine equipment is for storing message transmission, subject identification, the data such as user identifier.The network interface of the computer equipment
For being communicated with external terminal by network connection.To realize a kind of message transmission when the computer program is executed by processor
Method.
It will be understood by those skilled in the art that structure shown in Fig. 7, only part relevant to application scheme is tied
The block diagram of structure does not constitute the restriction for the computer equipment being applied thereon to application scheme, specific computer equipment
It may include perhaps combining certain components or with different component layouts than more or fewer components as shown in the figure.
In one embodiment, a kind of computer equipment, including memory and processor are provided, is stored in memory
Computer program, the processor execute computer program when perform the steps of message management part obtain the manufacturing side send to
Message is transmitted, message to be transmitted carries subject identification；Message to be transmitted is sent to corresponding with subject identification by message management part
Message-oriented middleware；Message management part is obtained through message-oriented middleware treated message to be transmitted, will that treated is to be transmitted
Message is sent to corresponding consumption terminal.
In one embodiment, the acquisition of message management part is also performed the steps of when processor executes computer program to disappear
The subscription message of Fei Duan triggering subscribes to message and carries subject identification.Will treated message to be transmitted is sent to it is corresponding
Consumption terminal, comprising: by the consumption terminal of treated message to be transmitted is sent to triggering subscribes to message.
In one embodiment, after the subscription message that message management part obtains consumption terminal triggering, processor executes meter
Message management part is also performed the steps of when calculation machine program to save the corresponding user identifier of consumption terminal and subject identification to data
Library；User identifier and subject identification are associated by database.
In one embodiment, it is also performed the steps of when processor executes computer program when message management part detects
When the associated user identifier of subject identification is empty into database, subject identification is deleted.
In one embodiment, message management part obtains the message to be transmitted that the manufacturing side is sent, comprising: message management part obtains
Take the manufacturing side that messaging service interface is called to obtain the server address of message management part from database, the manufacturing side is according to server
The message to be transmitted that address is sent.
In one embodiment, a kind of computer readable storage medium is provided, computer program is stored thereon with, is calculated
Machine program performs the steps of message management part and obtains the message to be transmitted that the manufacturing side is sent when being executed by processor, to be transmitted
Message carries subject identification；Message to be transmitted is sent to message-oriented middleware corresponding with subject identification by message management part；Disappear
Breath management part is obtained through message-oriented middleware treated message to be transmitted, will treated that message to be transmitted is sent to is corresponding
Consumption terminal.
In one embodiment, the acquisition of message management part is also performed the steps of when computer program is executed by processor
The subscription message of consumption terminal triggering subscribes to message and carries subject identification；Will treated message to be transmitted is sent to it is corresponding
Consumption terminal, comprising: by the consumption terminal of treated message to be transmitted is sent to triggering subscribes to message.
In one embodiment, after the subscription message that message management part obtains consumption terminal triggering, computer program quilt
Processor also performs the steps of message management part and saves the corresponding user identifier of consumption terminal and subject identification to number when executing
According to library；User identifier and subject identification are associated by database.
In one embodiment, it is also performed the steps of when computer program is executed by processor when message management part is examined
When to measure the associated user identifier of subject identification in database be empty, subject identification is deleted.
In one embodiment, message management part obtains the message to be transmitted that the manufacturing side is sent, comprising: message management part obtains
Take the manufacturing side that messaging service interface is called to obtain the server address of message management part from database, the manufacturing side is according to server
The message to be transmitted that address is sent.
In one embodiment, a kind of computer equipment, including memory and processor are provided, is stored in memory
Computer program, the processor perform the steps of consumption terminal and send subscription message to message management when executing computer program
Part subscribes to message and carries subject identification；The manufacturing side sends message to be transmitted to message management part, and message to be transmitted carries master
Topic mark；Message to be transmitted is sent to message-oriented middleware corresponding with subject identification by message management part；Message-oriented middleware according to
Subject identification handles message to be transmitted, and by treated, message to be transmitted is sent to message management part；Message management part
By treated, message to be transmitted is sent to consumption terminal.
In one embodiment, the manufacturing side sends message to be transmitted to message management part, comprising: the manufacturing side calls message clothes
Business interface passes through messaging service interface and obtains the server address for being in normal condition message management part；The manufacturing side sends to be passed
Defeated message is to the server address for being in normal condition message management part.
In one embodiment, a kind of computer readable storage medium is provided, computer program is stored thereon with, is calculated
Machine program performs the steps of consumption terminal and sends subscription message to message management part when being executed by processor, subscribe to message and carry
There is subject identification；The manufacturing side sends message to be transmitted to message management part, and message to be transmitted carries subject identification；Message management
Message to be transmitted is sent to message-oriented middleware corresponding with subject identification by part；Message-oriented middleware is according to subject identification to be transmitted
Message is handled, and by treated, message to be transmitted is sent to message management part；Message management part will that treated be to be transmitted
Message is sent to consumption terminal.
In one embodiment, the manufacturing side sends message to be transmitted to message management part, comprising: the manufacturing side calls message clothes
Business interface passes through messaging service interface and obtains the server address for being in normal condition message management part；The manufacturing side sends to be passed
Defeated message is to the server address for being in normal condition message management part.
Those of ordinary skill in the art will appreciate that realizing all or part of the process in above-described embodiment method, being can be with
Instruct relevant hardware to complete by computer program, computer program to can be stored in a non-volatile computer readable
It takes in storage medium, the computer program is when being executed, it may include such as the process of the embodiment of above-mentioned each method.Wherein, this Shen
Please provided by any reference used in each embodiment to memory, storage, database or other media, may each comprise
Non-volatile and/or volatile memory.Nonvolatile memory may include read-only memory (ROM), programming ROM
(PROM), electrically programmable ROM (EPROM), electrically erasable ROM (EEPROM) or flash memory.Volatile memory may include
Random access memory (RAM) or external cache.By way of illustration and not limitation, RAM is available in many forms,
Such as static state RAM (SRAM), dynamic ram (DRAM), synchronous dram (SDRAM), double data rate sdram (DDRSDRAM), enhancing
Type SDRAM (ESDRAM), synchronization link (Synchlink) DRAM (SLDRAM), memory bus (Rambus) direct RAM
(RDRAM), direct memory bus dynamic ram (DRDRAM) and memory bus dynamic ram (RDRAM) etc..
Each technical characteristic of above embodiments can be combined arbitrarily, for simplicity of description, not to above-described embodiment
In each technical characteristic it is all possible combination be all described, as long as however, the combination of these technical characteristics be not present lance
Shield all should be considered as described in this specification.
Above embodiments only express the several embodiments of the application, and the description thereof is more specific and detailed, but can not
Therefore it is construed as limiting the scope of the patent.It should be pointed out that for those of ordinary skill in the art,
Under the premise of not departing from the application design, various modifications and improvements can be made, these belong to the protection scope of the application.
Therefore, the scope of protection shall be subject to the appended claims for the application patent.
Claims (10)
1. a kind of method for message transmission, which comprises
Message management part obtains the message to be transmitted that the manufacturing side is sent, and the message to be transmitted carries subject identification；
The message to be transmitted is sent to message-oriented middleware corresponding with the subject identification by the message management part；
The message management part is obtained through the message-oriented middleware treated the message to be transmitted, will described in treated
The message to be transmitted is sent to corresponding consumption terminal.
2. the method according to claim 1, wherein the method also includes:
The message management part obtains the subscription message of consumption terminal triggering, and the subscription message carries the subject identification；
Treated that the message to be transmitted is sent to and corresponding consumption terminal by described, comprising:
Treated that the message to be transmitted is sent to triggers the consumption terminal for subscribing to message by described.
3. according to the method described in claim 2, it is characterized in that, obtaining consumption terminal triggering in the message management part
After subscription message, further includes:
The message management part saves the corresponding user identifier of the consumption terminal and the subject identification to database；
The user identifier and the subject identification are associated by the database.
4. according to the method described in claim 3, it is characterized in that, the method also includes:
When the message management part detects that the associated user identifier of subject identification described in the database is empty, institute is deleted
State subject identification.
5. the method according to claim 1, wherein the message management part obtains the to be transmitted of manufacturing side transmission
Message, comprising:
The message management part obtains the clothes that the manufacturing side calls messaging service interface to obtain the message management part from database
Business device address, the message to be transmitted that the manufacturing side is sent according to the server address.
6. a kind of method for message transmission, which comprises
Consumption terminal, which is sent, subscribes to message to message management part, and the subscription message carries subject identification；
The manufacturing side sends message to be transmitted to the message management part, and the message to be transmitted carries subject identification；
The message to be transmitted is sent to message-oriented middleware corresponding with the subject identification by the message management part；
The message-oriented middleware is handled the message to be transmitted according to the subject identification, will that treated is described to be passed
Defeated message is sent to the message management part；
Treated that message to be transmitted is sent to the consumption terminal by described for the message management part.
7. according to the method described in claim 6, it is characterized in that, the manufacturing side sends message to be transmitted to the message pipe
Manage part, comprising:
The manufacturing side calls messaging service interface, and the clothes for being in normal condition message management part are obtained by the messaging service interface
Business device address；
The manufacturing side sends message to be transmitted to the server address in normal condition message management part.
8. a kind of massage transmission device, which is characterized in that described device includes:
Message transmission module obtains the message to be transmitted that the manufacturing side is sent for message management part, and the message to be transmitted carries
There is subject identification；
The message to be transmitted is sent to corresponding with the subject identification by message transmitting module for the message management part
Message-oriented middleware；
Message processing module, obtains that treated described to be transmitted disappears by the message-oriented middleware for the message management part
Breath, treated that the message to be transmitted is sent to and corresponding consumption terminal by described.
9. a kind of computer equipment, including memory and processor, the memory are stored with computer program, feature exists
In the step of processor realizes any one of claims 1 to 7 the method when executing the computer program.
10. a kind of computer readable storage medium, is stored thereon with computer program, which is characterized in that the computer program
The step of method described in any one of claims 1 to 7 is realized when being executed by processor.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201910119555.0A CN109933439B (en) | 2019-02-21 | 2019-02-21 | Message transmission method, device, computer equipment and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201910119555.0A CN109933439B (en) | 2019-02-21 | 2019-02-21 | Message transmission method, device, computer equipment and storage medium |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN109933439A true CN109933439A (en) | 2019-06-25 |
| CN109933439B CN109933439B (en) | 2024-06-11 |
Family
ID=66985600
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201910119555.0A Active CN109933439B (en) | 2019-02-21 | 2019-02-21 | Message transmission method, device, computer equipment and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN109933439B (en) |
Cited By (9)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111381986A (en) * | 2020-03-10 | 2020-07-07 | 北京奇艺世纪科技有限公司 | Message transmission method, system, device, electronic equipment and readable storage medium |
| CN112491998A (en) * | 2020-11-18 | 2021-03-12 | 平安消费金融有限公司 | Message pushing method and related equipment |
| CN112583933A (en) * | 2020-12-25 | 2021-03-30 | 高新现代智能系统股份有限公司 | Parameter operation method, device, equipment and storage medium |
| CN112788074A (en) * | 2019-11-07 | 2021-05-11 | 中兴通讯股份有限公司 | Data transmitting method, processing method, receiving method and equipment and storage medium |
| CN112788551A (en) * | 2020-12-30 | 2021-05-11 | 平安证券股份有限公司 | Message processing method and device, terminal equipment and storage medium |
| CN113641507A (en) * | 2020-04-27 | 2021-11-12 | 北京京东振世信息技术有限公司 | Message middleware access method, message processing method and device |
| CN115103018A (en) * | 2022-06-16 | 2022-09-23 | 珠海格力电器股份有限公司 | Data transmission method, device, system, electronic equipment and storage medium |
| CN116302599A (en) * | 2023-02-27 | 2023-06-23 | 中国人民财产保险股份有限公司 | Message processing method, device and system based on message middleware |
| CN117176840A (en) * | 2023-11-02 | 2023-12-05 | 成都汉度科技有限公司 | Communication protocol identification method and system |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20090006560A1 (en) * | 2007-06-27 | 2009-01-01 | Bhogal Kulvir S | Terminating An Application Message Subscription |
| CN103534988A (en) * | 2013-06-03 | 2014-01-22 | 华为技术有限公司 | Publish and subscribe messaging method and apparatus |
| CN105791082A (en) * | 2014-12-23 | 2016-07-20 | 阿里巴巴集团控股有限公司 | Message transmission method and device thereof based on message oriented middleware between computer clusters |
| CN108023807A (en) * | 2017-11-02 | 2018-05-11 | 东软集团股份有限公司 | Instant communicating method, server and message-oriented middleware |
| CN108965355A (en) * | 2017-05-18 | 2018-12-07 | 北京京东尚科信息技术有限公司 | Method, apparatus and computer readable storage medium for data transmission |
-
2019
- 2019-02-21 CN CN201910119555.0A patent/CN109933439B/en active Active
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20090006560A1 (en) * | 2007-06-27 | 2009-01-01 | Bhogal Kulvir S | Terminating An Application Message Subscription |
| CN103534988A (en) * | 2013-06-03 | 2014-01-22 | 华为技术有限公司 | Publish and subscribe messaging method and apparatus |
| CN105791082A (en) * | 2014-12-23 | 2016-07-20 | 阿里巴巴集团控股有限公司 | Message transmission method and device thereof based on message oriented middleware between computer clusters |
| CN108965355A (en) * | 2017-05-18 | 2018-12-07 | 北京京东尚科信息技术有限公司 | Method, apparatus and computer readable storage medium for data transmission |
| CN108023807A (en) * | 2017-11-02 | 2018-05-11 | 东软集团股份有限公司 | Instant communicating method, server and message-oriented middleware |
Non-Patent Citations (1)
| Title |
|---|
| 潘国伟;宋玮;王相南;曹厚继;: "发布/订阅模式消息中间件在SCADA系统中的应用", 电网技术, no. 18 * |
Cited By (15)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112788074B (en) * | 2019-11-07 | 2024-05-31 | 中兴通讯股份有限公司 | Data transmitting method, processing method, receiving method, apparatus thereof, and storage medium |
| CN112788074A (en) * | 2019-11-07 | 2021-05-11 | 中兴通讯股份有限公司 | Data transmitting method, processing method, receiving method and equipment and storage medium |
| CN111381986B (en) * | 2020-03-10 | 2024-04-16 | 北京奇艺世纪科技有限公司 | Message transmission method, system, device, electronic equipment and readable storage medium |
| CN111381986A (en) * | 2020-03-10 | 2020-07-07 | 北京奇艺世纪科技有限公司 | Message transmission method, system, device, electronic equipment and readable storage medium |
| CN113641507A (en) * | 2020-04-27 | 2021-11-12 | 北京京东振世信息技术有限公司 | Message middleware access method, message processing method and device |
| CN112491998B (en) * | 2020-11-18 | 2023-08-08 | 平安消费金融有限公司 | Message pushing method and related equipment |
| CN112491998A (en) * | 2020-11-18 | 2021-03-12 | 平安消费金融有限公司 | Message pushing method and related equipment |
| CN112583933B (en) * | 2020-12-25 | 2023-02-24 | 高新现代智能系统股份有限公司 | Parameter operation method, device, equipment and storage medium |
| CN112583933A (en) * | 2020-12-25 | 2021-03-30 | 高新现代智能系统股份有限公司 | Parameter operation method, device, equipment and storage medium |
| CN112788551A (en) * | 2020-12-30 | 2021-05-11 | 平安证券股份有限公司 | Message processing method and device, terminal equipment and storage medium |
| CN115103018A (en) * | 2022-06-16 | 2022-09-23 | 珠海格力电器股份有限公司 | Data transmission method, device, system, electronic equipment and storage medium |
| CN115103018B (en) * | 2022-06-16 | 2024-04-05 | 珠海格力电器股份有限公司 | Data transmission method, device and system, electronic equipment and storage medium |
| CN116302599A (en) * | 2023-02-27 | 2023-06-23 | 中国人民财产保险股份有限公司 | Message processing method, device and system based on message middleware |
| CN117176840A (en) * | 2023-11-02 | 2023-12-05 | 成都汉度科技有限公司 | Communication protocol identification method and system |
| CN117176840B (en) * | 2023-11-02 | 2024-03-12 | 成都汉度科技有限公司 | Communication protocol identification method and system |
Also Published As
| Publication number | Publication date |
|---|---|
| CN109933439B (en) | 2024-06-11 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN109933439A (en) | Method for message transmission, device, computer equipment and storage medium | |
| CN110351342A (en) | Service order processing method, device, computer equipment and storage medium | |
| CN103873692B (en) | Method, device and system for resource sharing | |
| GB2506470A (en) | Providing an indication to a first party that a second party will respond in a timely manner to a communication from the first party | |
| US11558322B2 (en) | Communication management system | |
| US9374689B1 (en) | Apparatus and method for supporting telephonic synthetic identities | |
| US11412026B2 (en) | Method for communication among a plurality of users provided with communication terminals, via a virtual communication space | |
| CN109492019A (en) | Service request response method, device, computer equipment and storage medium | |
| CN111343236A (en) | Method, device and communication system for communication between server and client | |
| CN109729005A (en) | Message treatment method, device, computer equipment and storage medium | |
| CN102467411A (en) | Workflow processing and workflow agent method, device and system | |
| CN110582998A (en) | Group communication method and device, computer storage medium and computer equipment | |
| CN110825441A (en) | Method for implementing asynchronous system, computer equipment and storage medium | |
| CN111464628B (en) | Multiplexing asynchronous processing system and method | |
| CN115951923A (en) | Subscription event management method and related product | |
| EP2434792A1 (en) | System and method for monitoring virtual agents | |
| CN115002690A (en) | System, method and device for rapidly acquiring user information based on 5G message | |
| CN105988795B (en) | Message processing method and device | |
| CN110855764A (en) | Network traffic scheduling method and device and electronic equipment | |
| CN103188289B (en) | The information communication method of a kind of client and service end | |
| CN104519062A (en) | Method and system for creating connection of multiple pairs of socket ports | |
| CN114244758B (en) | Network diagnosis method, storage medium, electronic equipment and system of android platform | |
| CN107959824A (en) | A kind of monitor video processing method, physical server and storage medium | |
| CN109474762A (en) | Processing method, device, computer equipment and the storage medium for task of making house calls | |
| CN107783722B (en) | Data transmission method and data forwarding device |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |