Distributed message processing method and system
A message processing and distributed technology, applied in the direction of electrical digital data processing, communication between programs, instruments, etc., can solve problems such as high cost, high cost, and inability to guarantee the order of message delivery
- Summary
- Abstract
- Description
- Claims
- Application Information
AI Technical Summary
Problems solved by technology
Method used
Image
Examples
Embodiment 1
[0049] Embodiment 1. A distributed message processing method, such as figure 1 shown, including the following steps:
[0050] S100. Receive a message sending request sent by the client 200, generate a message including a sending time stamp according to the message sending request, and add the message to a corresponding message queue, where the sending time stamp is unique in the message queue , arranging the messages in the message queue based on the sending timestamp;
[0051] In this embodiment, the message line is written in the corresponding message queue based on the message sending request in advance, and then the corresponding timestamp management node 300 is requested to send the timestamp, and the obtained sending timestamp is inserted into the message line to complete the generation of the message. mark it as sent, so that the sending of the message is completed based on the message sending request, and this process is implemented based on the atomic method.
[005...
Embodiment 2
[0095] Embodiment 2. A distributed message processing system, such as figure 2 As shown, it is connected to the distributed file system 400, including several message management nodes 100, several time stamp management nodes 300 and several clients 200;
[0096] The message management node 100 includes:
[0097] The message publishing module is configured to receive a message sending request sent by the client 200, generate a message including a sending time stamp according to the message sending request, and add the message to a corresponding message queue, and the sending time stamp is determined by the corresponding time stamp Issued by the management node 300, the sending time stamp is unique in the message queue; the message publishing module 110 is also configured to arrange the messages in the message queue based on the sending time stamp;
[0098] Overtime judging module, for judging whether the message is overtime, marking the overtime message according to the judgm...
PUM
Abstract
Description
Claims
Application Information
- R&D Engineer
- R&D Manager
- IP Professional
- Industry Leading Data Capabilities
- Powerful AI technology
- Patent DNA Extraction
Browse by: Latest US Patents, China's latest patents, Technical Efficacy Thesaurus, Application Domain, Technology Topic, Popular Technical Reports.
© 2024 PatSnap. All rights reserved.Legal|Privacy policy|Modern Slavery Act Transparency Statement|Sitemap|About US| Contact US: help@patsnap.com