CN110362721B - Message track information processing method, system and device and electronic equipment - Google Patents
Message track information processing method, system and device and electronic equipment Download PDFInfo
- Publication number
- CN110362721B CN110362721B CN201810306566.5A CN201810306566A CN110362721B CN 110362721 B CN110362721 B CN 110362721B CN 201810306566 A CN201810306566 A CN 201810306566A CN 110362721 B CN110362721 B CN 110362721B
- Authority
- CN
- China
- Prior art keywords
- message
- trace
- track
- information
- storage
- 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.)
- Active
Links
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/90—Details of database functions independent of the retrieved data types
- G06F16/903—Querying
Landscapes
- Engineering & Computer Science (AREA)
- Databases & Information Systems (AREA)
- Theoretical Computer Science (AREA)
- Computational Linguistics (AREA)
- Data Mining & Analysis (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Management, Administration, Business Operations System, And Electronic Commerce (AREA)
- Debugging And Monitoring (AREA)
Abstract
The invention provides a method, a system and a device for processing message track information and electronic equipment. The method comprises the following steps: the message producer sends a first track trace message to a message storage, wherein the first track trace message comprises track information of the message in a sending stage and a trace serial number of the message; the message storage stores a first track trace message and a second track trace message, wherein the second track trace message comprises track information of the message in a storage stage and a trace serial number of the message; the message consumer sends a third trace message comprising trace information of the message at the consuming stage and a trace sequence number of the message to a message storage for storage. The method, the system, the device and the electronic equipment for processing the information track information realize the tracking of the complete track information of each stage of the whole life cycle from production to consumption of the information on the premise of not invading a user of the information, not occupying a local storage space and not depending on external data storage.
Description
Technical Field
The present invention relates to the field of computer technologies, and in particular, to a method, a system, an apparatus, and an electronic device for processing message track information.
Background
The messaging system typically includes the following components: message Producer, message Consumer, and message store Broker. Each message is produced by a message Producer and then sent to a message store Broker for storage, and then pushed by the message store Broker to a plurality of message Consumer consumers. At each stage in the above process, information such as time, place, state, etc. of the message flowing between the components is called track information of the message. The track information of the message can help the user (i.e. the user of the message) to judge the state of the business process.
In the prior art, in order to acquire track information of a message, the following manner is generally adopted: as shown in fig. 1, by adding a log printing mode in service logic (i.e. a service layer), track information of messages corresponding to each component (including a message Producer, a message Consumer and a message storage Broker) in a message system is recorded into a local log file by a disk writing mode, and then the log files of each component are collected by a manual or other program importing mode and stored into an external storage system. If the user (i.e. the user of the message) needs to inquire the state of a certain message, the user needs to search the log file in the external storage system for searching the service, and acquire the track information of the message.
In the process of implementing the present invention, the inventors have found that at least the following drawbacks exist in the prior art: 1) The service codes of all components in the message system, including the message Producer, the message Consumer and the message store Broker, need to be modified to record the track information of the message in a local log file, i.e. to invade the service logic (i.e. the service level), which is not user friendly for the message. 2) And recording the track information of the message into a local log file in a disk writing mode, so that the local storage space is occupied. 3) The log files of each component are collected and stored in an external storage system, and the external data storage is relied on.
Disclosure of Invention
The invention provides a method, a system, a device and electronic equipment for processing information of a message track, which are used for tracking the complete track information of each stage of the whole life cycle from production to consumption of the message on the premise of not invading a user of the message, not occupying a local storage space and not relying on external data storage.
In order to achieve the above purpose, the invention adopts the following technical scheme:
in one aspect, the present invention provides a method for processing message track information, including:
a message producer sends a first track trace message to a message storage, wherein the first track trace message comprises track information of the message in a sending stage of the message producer and a trace serial number of the message;
the message storage stores the first track trace message and a second track trace message, wherein the second track trace message comprises track information of the message in the storage stage of the message storage and a trace serial number of the message;
a message consumer sends a third trace message to the message store, wherein the third trace message comprises trace information of the message at the consumption stage of the message consumer and a trace serial number of the message;
the message store stores the third trace message.
On the other hand, the invention also provides a processing system of the information track information, which comprises the following steps:
a message producer for sending a first trace message to a message store, the first trace message comprising trace information of a message at a sending stage of the message producer and a trace sequence number of the message;
the message storage is used for storing the first track trace message, a second track trace message and a third track trace message, wherein the second track trace message comprises track information of the message in the storage stage of the message storage and a trace serial number of the message;
and the message consumer is used for sending the third trace message to the message storage, wherein the third trace message comprises trace information of the message at the consumption stage of the message consumer and a trace serial number of the message.
In another aspect, the present invention also provides an electronic device, including:
a memory for storing a program;
a processor coupled to the memory for executing the program for:
controlling a message producer to send a first trace message to a message store, the first trace message comprising trace information of a message at a sending stage of the message producer and a trace sequence number of the message;
controlling the message storage to store the first track trace message, a second track trace message and a third track trace message, wherein the second track trace message comprises track information of the message in the storage stage of the message storage and a trace serial number of the message;
and controlling a message consumer to send the third trace message to the message storage, wherein the third trace message comprises trace information of the message at the consumption stage of the message consumer and a trace serial number of the message.
On the other hand, the invention also provides a processing method of the information track information, which comprises the following steps:
acquiring input query conditions, wherein the query conditions comprise the category of the message as a tracking message and a tracking sequence number of the message;
inquiring and acquiring the track trace information corresponding to the inquiring condition.
On the other hand, the invention also provides a processing device of the information track information, which comprises the following steps:
the acquisition module is used for acquiring input query conditions, wherein the query conditions comprise the category of the message as a tracking message and a tracking sequence number of the message;
and the query module is used for querying and acquiring the track tracking message corresponding to the query condition.
In another aspect, the present invention also provides an electronic device, including:
a memory for storing a program;
a processor coupled to the memory for executing the program for:
acquiring input query conditions, wherein the query conditions comprise the category of the message as a tracking message and a tracking sequence number of the message;
inquiring and acquiring the track trace information corresponding to the inquiring condition.
The method, the system, the device and the electronic equipment for processing the track information of the message, provided by the invention, store the track information generated by each component of the message system in the message storage based on the tracking sequence number of the message, and acquire the track information generated by each component of the message system by inquiring the tracking sequence number of the message, thereby realizing the tracking of the complete track information of each stage of the whole life cycle from production to consumption of the message on the premise of not invading a user of the message, occupying no local storage space and not depending on external data storage.
The foregoing description is only an overview of the present invention, and is intended to be implemented in accordance with the teachings of the present invention in order that the same may be more clearly understood and to make the same and other objects, features and advantages of the present invention more readily apparent.
Drawings
Various other advantages and benefits will become apparent to those of ordinary skill in the art upon reading the following detailed description of the preferred embodiments. The drawings are only for purposes of illustrating the preferred embodiments and are not to be construed as limiting the invention. Also, like reference numerals are used to designate like parts throughout the figures. In the drawings:
FIG. 1 is a schematic diagram of a scenario in the prior art for obtaining track information of a message;
FIG. 2 is a schematic diagram of an application scenario of a message system in the related art;
fig. 3 is a schematic diagram of a working principle of a method for processing message track information according to the present invention;
fig. 4 is a second schematic diagram of a working principle of the method for processing message track information provided by the present invention;
FIG. 5 is a flowchart illustrating an embodiment of a method for processing message track information according to the present invention;
FIG. 6 is a flowchart illustrating a method for processing message track information according to another embodiment of the present invention;
FIG. 7 is a schematic diagram of a message sequence number tracking procedure in a message system;
FIG. 8 is a schematic diagram illustrating an embodiment of a message track information processing system according to the present invention;
FIG. 9 is a flowchart illustrating a method for processing message track information according to another embodiment of the present invention;
FIG. 10 is a schematic diagram illustrating an embodiment of a message track information processing apparatus according to the present invention;
fig. 11 is a schematic structural diagram of an embodiment of an electronic device provided by the present invention.
Detailed Description
Exemplary embodiments of the present disclosure will be described in more detail below with reference to the accompanying drawings. While exemplary embodiments of the present disclosure are shown in the drawings, it should be understood that the present disclosure may be embodied in various forms and should not be limited to the embodiments set forth herein. Rather, these embodiments are provided so that this disclosure will be thorough and complete, and will fully convey the scope of the disclosure to those skilled in the art.
Description of related terms:
the message Producer, the party that produces or generates the message, may be a module in a server, may be another server, may be a user terminal that has a message interaction with the server, or the like, as one of the components of the message system.
The message storage Broker, the party storing the message, may be a certain module in the server, may be another server, may be a user terminal having a message interaction with the server, etc. as one of the components of the message system.
The message Consumer, the party consuming the message, may be a module in a server, may be another server, may be a user terminal having a message interaction with a server, or the like, as one of the components of the message system.
Track information of messages, information such as time, place, state and the like of the message flowing among the components at each stage of message production, storage and consumption is called track information of the message.
The user of the message, that is, the user, who uses the message may be a module in the server, may be another server, may be a user terminal having a message interaction with the server, or the like. The usage mode can be simply read, or the message itself is further processed or the track information of the message is obtained based on the message, so as to judge the state of the business process.
The technical principle of the invention is described below:
fig. 2 is a schematic diagram of an application scenario of a message system in the related art. As shown in fig. 2, the message Producer produces a message, and sends the produced message to the message store Broker for storage, and the message store Broker pushes the message to a plurality of message consumers for consumption. The user of the message uses the message, specifically, the use mode can be simple reading, further processing the message itself or based on the message, or obtaining track information of the message to judge the state of the business process.
Fig. 3 and fig. 4 are schematic diagrams of the working principle of the processing method of the message track information provided by the present invention. In which fig. 3 depicts a schematic diagram of a message track information collection flow, as shown in fig. 3, a message Producer produces a tracking sequence number TraceId for uniquely identifying each message produced, and sends the tracking sequence number TraceId of the message and the message together as a service message to a message storage Broker, which stores the received service message and pushes the service message to a message Consumer, thereby implementing the transfer of the tracking sequence number TraceId of the message to each component of the message system through the service message.
In addition, the message Producer sends the track information of the message at the sending stage of the message Producer and the track sequence number TraceId of the message together as a first track trace message to the message storage Broker. The message storage Broker stores the received first trace information and stores the trace information of the message in the storage stage of the message storage together with the trace serial number TraceId of the message as a second trace information. The message Consumer Consumer sends the track information of the message in the consumption stage of the message Consumer and the track sequence number TraceId of the message together as a third track tracking message to a message storage Broker, and the message storage Broker stores the received third track tracking message, so that the track information generated by the message in each component is stored in the message storage Broker based on the track sequence number TraceId of the message, the tracking of the complete track information of each stage of the whole life cycle from production to consumption of the message is realized, and the method has no invasion to a user of the message, does not occupy a local storage space and does not depend on external data storage.
Fig. 4 is a schematic diagram illustrating a query flow of message track information, as shown in fig. 4, a message storage Broker obtains query conditions input by a message user, where the query conditions include a message type=track and a track serial number TraceId (e.g. traceid=001) of a message to be queried, queries and obtains track Trace messages corresponding to the query conditions in the message stored in the message storage Broker, sorts the obtained track Trace messages according to a sequence, obtains complete track information of the message, and outputs the complete track information to the message user. The message storage Broker may also directly output the obtained plurality of track trace messages to the message user, where the message user sorts the track trace messages according to a sequence, so as to obtain complete track information of the message.
The foregoing embodiments are illustrative of the principles of embodiments of the present invention, and the invention will be described in detail below with reference to the accompanying drawings and specific embodiments thereof, so that those skilled in the art can clearly and accurately understand the technical solutions of the present invention.
Example 1
Fig. 5 is a flow chart of an embodiment of a method for processing message track information according to the present invention. The processing method of the message track information can be applied to a message system. As shown in fig. 5, the method for processing message track information according to the embodiment of the present invention specifically may include:
s501, the message producer sends a first trace message to the message store, the first trace message including trace information of the message at the message producer sending stage and a trace sequence number of the message.
In particular, the track information of the message in the sending stage of the message producer may specifically include: information about the time, place, success or not of the message at the time of the message producer sending phase, etc. The message producer generates a first track trace message according to the trace sequence number of the message and the track information of the message in the production stage of the message producer, and sends the first track trace message to the message storage.
S502, the message storage stores a first track trace message and a second track trace message, wherein the second track trace message comprises track information of the message in the storage stage of the message storage and a trace serial number of the message.
In particular, the track information of the message in the message storage stage may specifically include: message store processing information. The message store receives and stores the first trace message sent by the message producer. And the message storage generates and stores a second track tracking message according to the track sequence number of the message and track information of the message in the storage stage of the message storage.
S503, the message consumer sends a third trace message to the message store, wherein the third trace message includes trace information of the message at the consumption stage of the message consumer and a trace sequence number of the message.
In particular, the track information of the message at the consumption stage of the message consumer may specifically include: information such as the consumption status of the message by the message consumer. And the message consumer generates a third trace message according to the trace sequence number of the message and the trace information of the message at the consumption stage of the message consumer, and sends the third trace message to the message storage.
S504, the message store stores the third trace message.
Specifically, the message store receives a third trace message sent by the message consumer and stores the third trace message.
In the embodiment of the invention, the track information generated by the information in each component (the information producer, the information storage and the information consumer) of the information system is stored in the information storage as the track tracking information (the first track tracking information, the second track tracking information and the third track tracking information) together with the track serial number of the information, so that the tracking of the complete track information of each stage of the whole life cycle from production to consumption of the information is realized on the premise of not invading the user of the information, not occupying the local storage space and not depending on external data storage.
The processing method of the message track information in the embodiment of the invention stores the track information generated by the message in each component of the message system in the message storage based on the tracking sequence number of the message, thereby realizing the tracking of the complete track information of each stage of the whole life cycle from production to consumption of the message on the premise of not invading a user of the message, not occupying a local storage space and not depending on external data storage.
Example two
Fig. 6 is a flowchart of another embodiment of a method for processing message track information according to the present invention. The method for processing the message track information according to the embodiment of the present invention can be applied to a message system, and the method for processing the message track information according to the embodiment of the present invention is a feasible implementation of the method for processing the message track information shown in fig. 5. As shown in fig. 6, on the basis of the embodiment shown in fig. 5, the method for processing message track information according to the embodiment of the present invention specifically includes:
s601, the message producer sends a service message to the message store, the service message including the message and a tracking sequence number of the message.
Specifically, the tracking sequence number of the message may be generated by the message producer for the message, which is used to uniquely identify the message, e.g., 001, 002, etc. The message producer sends the tracking sequence number of the message to the message store along with the message as a business message.
S602, the message producer transmits a first trace message to the message store, the first trace message including trace information of the message at the message producer transmission stage and a trace sequence number of the message.
Specifically, the step S602 is the same as the step S501 in the embodiment shown in fig. 5, and will not be described here again. The message producer generates a first trace message according to the trace sequence number of the message and sends the first trace message to the message storage.
S603, the message store stores the service message.
Specifically, the message storage receives the service message sent by the message producer, stores the service message, and acquires the tracking sequence number of the message in the service message.
S604, the message store stores a first trace message and a second trace message, the second trace message including trace information of the message at the message store storage stage and a trace sequence number of the message.
Specifically, the step S604 is the same as the step S502 in the embodiment shown in fig. 5, and will not be described here again. The message storage receives the first track trace message sent by the message producer and stores the first track trace message, and generates a second track trace message according to the trace serial number of the message obtained from the service message and stores the second track trace message.
S605, the message store pushes the business message to the message consumer.
Specifically, the message store pushes the received business message to each message consumer.
S606, the message consumer sends a third trace message to the message store, the third trace message including trace information for the message at the message consumer' S consumption stage and a trace sequence number for the message.
Specifically, the step S606 is the same as the step S503 in the embodiment shown in fig. 5, and will not be described here again. The message consumer receives the service message sent by the message storage and stores the service message, acquires the tracking sequence number of the message in the service message, generates a third tracking message according to the tracking sequence number of the message acquired from the service message, and sends the third tracking message to the message storage.
S607, the message store stores the third trace message.
Specifically, the step S606 is the same as the step S504 in the embodiment shown in fig. 5, and will not be described here again. The message store receives a third trace message sent by the message consumer and stores the third trace message.
In summary, the trace sequence number of a message is transferred to each component of the message system through a service message, as shown in fig. 7, the message Producer generates the trace sequence number of the corresponding message for each of the two generated messages, for example, one message has a trace sequence number of 001, i.e. traceid=001, the other message has a trace sequence number of 002, i.e. traceid=002, and both messages together with the respective trace sequence numbers are sent as a service message to the message storage Broker, which sends the service message with the trace sequence number of 001 to one message Consumer Consumer1, and sends the service message with the trace sequence number of 002 to the other message Consumer Consumer2.
Further, the first track Trace message, the second track Trace message, or the third track Trace message may further include a category of the message as a Trace message, for example, type=trace. The service message may further include a standard message, for example, type=normal, as a message category.
The above describes the process of collecting the information of the message track, and the specific working principle can be referred to the schematic diagram of the working principle shown in fig. 3.
Further, the method for processing message track information in the embodiment of the present invention may further include a query process of the message track information, as shown in fig. 4, and specifically includes the following steps: the message storage obtains input query conditions, wherein the query conditions comprise the types of the messages, namely tracking messages and tracking serial numbers of the messages; the message store queries and obtains the trace information corresponding to the query conditions.
Specifically, assuming that the query condition is that the Type of the message is track message, i.e., type=track, and the track sequence number of the message is 001, i.e., traceid=001, then the track message corresponding to the query condition "type=track, traceid=001" is queried and obtained in the message storage.
Further, the method for processing the message track information according to the embodiment of the present invention may further include the following steps: and the message storage unit sorts the acquired track trace messages according to the sequence to obtain the complete track information of the messages.
Specifically, the message storage may sort the acquired plurality of track trace messages according to the sequence, obtain the complete track information of the message, and output the complete track information of the message to the message user, or directly output the acquired plurality of track trace messages to the message user, where the message user sorts the plurality of track trace messages according to the sequence, so as to obtain the complete track information of the message.
The processing method of the message track information in the embodiment of the invention stores the track information generated by the message in each component of the message system in the message storage based on the tracking sequence number of the message, thereby realizing the tracking of the complete track information of each stage of the whole life cycle from production to consumption of the message on the premise of not invading a user of the message, not occupying a local storage space and not depending on external data storage.
Example III
Fig. 8 is a schematic structural diagram of an embodiment of a processing system for message track information according to the present invention. The processing system of message track information in the embodiment of the invention can be used for executing the processing method of message track information in the first embodiment or the second embodiment. As shown in fig. 8, the processing system for message track information according to the embodiment of the present invention may specifically include: message producer 81, message store 82, and message consumer 83.
A message producer 81 for transmitting a first trace message to the message store 82, the first trace message including trace information of the message at the stage of transmission by the message producer 82 and a trace sequence number of the message.
A message store 82 for storing a first trace message, a second trace message, and a third trace message, the second trace message including trace information of the message at a stage of storage by the message store 82 and a trace sequence number of the message.
A message consumer 83 for sending a third trace message to the message store 82, the third trace message comprising trace information for the message at the stage of consumption by the message consumer 83 and a trace sequence number for the message.
Further, the message producer 81 may be further configured to: sending a service message to the message store 82, the service message including the message and a tracking sequence number of the message;
the message store 82 is also for: store the business message and push the business message to the message consumer 83.
Further, the message producer 81 may be further configured to: a tracking sequence number of the message is generated for the message, the tracking sequence number of the message being used to uniquely identify the message.
Further, the first track trace message, the second track trace message, or the third track trace message may further include a category of the message as a trace message; the service message may also include a standard message for the category of the message.
Further, the message store 82 is also configured to: acquiring input query conditions, wherein the query conditions comprise the types of the messages as tracking messages and tracking serial numbers of the messages; and inquiring and acquiring the track trace message corresponding to the inquiring condition.
Further, the message store 82 is also configured to: and sequencing the acquired track trace messages according to the sequence to obtain the complete track information of the messages.
In particular, the specific process of implementing the functions of each component (the message producer, the message storage and the message consumer) in the embodiments of the present invention may be referred to the related description in the first embodiment or the second embodiment, and will not be repeated here.
The processing system of the information track information of the embodiment of the invention stores the track information generated by the information in each component of the information system in the information storage based on the tracking serial number of the information, thereby realizing the tracking of the complete track information of each stage of the whole life cycle from production to consumption of the information on the premise of not invading the user of the information, not occupying the local storage space and not depending on external data storage.
Example IV
Fig. 9 is a flowchart of another embodiment of a method for processing message track information according to the present invention. The processing method of the message track information can be applied to a message storage. As shown in fig. 9, the method for processing message track information according to the embodiment of the present invention specifically may include:
s901, acquiring input query conditions, wherein the query conditions comprise the types of the messages, namely tracking messages and tracking serial numbers of the messages.
S902, inquiring and acquiring a track trace message corresponding to the inquiring condition.
Specifically, the embodiment of the invention describes a query process of message track information. The track trace information generated by each component of the message system is stored in the message storage through the collection process of the track information of the message, and the track trace information comprises the track information of the type of the message, the track serial number of the message and the track information generated by each component of the message system.
When a user wants to inquire track information of a certain message, an inquiry condition can be input in a message storage, wherein the inquiry condition comprises the category of the message as a tracking message and a tracking serial number of the message. The message store obtains the query condition input by the user, as shown in fig. 4, if the query condition is that the category of the message is track message, i.e. type=track, and the track sequence number of the message is 001, i.e. track id=001, then the track message corresponding to the query condition "type=track, track id=001" is queried and obtained in the message store.
As a possible embodiment, the message storage may sort the acquired plurality of trace information according to a sequence, obtain complete trace information of the message, and output the complete trace information to the message user.
As another possible embodiment, the message storage may directly output the acquired plurality of track trace messages to the message user, where the message user sorts the track trace messages according to a sequence order, so as to obtain complete track information of the message.
The processing method of the information track information of the embodiment of the invention obtains the track information generated by the information in each component of the information system by inquiring the track sequence number of the information, thereby realizing the track of the complete track information of each stage of the whole life cycle from production to consumption of the information on the premise of not invading the user of the information, not occupying the local storage space and not depending on external data storage.
Example five
Fig. 10 is a schematic structural diagram of an embodiment of a processing apparatus for message track information provided by the present invention. The processing device of the message track information in the embodiment of the invention can be arranged in a message storage for executing the processing method of the message track information in the fourth embodiment. As shown in fig. 10, the processing apparatus for message track information according to the embodiment of the present invention may specifically include: an acquisition module 101 and a query module 102.
The obtaining module 101 is configured to obtain an input query condition, where the query condition includes a message type that is a trace message and a trace sequence number of the message.
And the query module 102 is used for querying and acquiring the track trace message corresponding to the query condition.
Further, the processing device for message track information according to the embodiment of the present invention may further include: the sequencing module is used for sequencing the acquired track trace messages according to the sequence to obtain the complete track information of the messages.
Specifically, the specific process of each module in the embodiment of the present invention to implement its function may be referred to the related description in the fourth embodiment, which is not repeated here.
The processing device of the information track information of the embodiment of the invention acquires the track information generated by the information in each component of the information system by inquiring the tracking sequence number of the information, thereby realizing the tracking of the complete track information of each stage of the whole life cycle from production to consumption of the information on the premise of not invading a user of the information, not occupying a local storage space and not depending on external data storage.
Example six
The internal functions and structures of the processing system and the device for message track information are described above, and fig. 11 is a schematic structural diagram of an electronic device according to an embodiment of the present invention, as shown in fig. 11, where in practice, the processing system and the device for message track information in the foregoing embodiments may be implemented as an electronic device, and may include: a memory 111 and a processor 112.
A memory 111 for storing a program.
In addition to the programs described above, the memory 111 may also be configured to store other various data to support operations on the electronic device. Examples of such data include instructions for any application or method operating on the electronic device, such as an online shopping platform, an online e-commerce platform, phonebook data, messages, pictures, videos, and so forth.
The memory 111 may be implemented by any type of volatile or non-volatile memory device or combination thereof, such as Static Random Access Memory (SRAM), electrically erasable programmable read-only memory (EEPROM), erasable programmable read-only memory (EPROM), programmable read-only memory (PROM), read-only memory (ROM), magnetic memory, flash memory, magnetic or optical disk.
A processor 112 is coupled to the memory 111 for executing the programs in the memory 111.
In one possible implementation, the program may be used to:
controlling a message producer to send a first trace message to a message storage, wherein the first trace message comprises trace information of the message in a sending stage of the message producer and a trace serial number of the message;
the control message storage stores a first track trace message, a second track trace message and a third track trace message, wherein the second track trace message comprises track information of the message in the storage stage of the message storage and a trace serial number of the message;
the control message consumer sends a third trace message to the message store, the third trace message including trace information for the message at the message consumer's consumption stage and a trace sequence number for the message.
In another possible implementation, the program may be for:
acquiring input query conditions, wherein the query conditions comprise the types of the messages as tracking messages and tracking serial numbers of the messages;
and inquiring and acquiring the track trace message corresponding to the inquiring condition.
The specific processing operations described above have been described in detail in the previous embodiments, and are not repeated here.
Further, as shown in fig. 11, the electronic device may further include: communication component 113, power component 114, audio component 115, display 116, and other components. Only some of the components are schematically shown in fig. 11, which does not mean that the electronic device only comprises the components shown in fig. 11.
The communication component 113 is configured to facilitate communication between the electronic device and other devices, either wired or wireless. The electronic device may access a wireless network based on a communication standard, such as WiFi,2G, or 3G, or a combination thereof. In one exemplary embodiment, the communication component 113 receives a broadcast signal or broadcast-related information from an external broadcast management system via a broadcast channel. In one exemplary embodiment, the communication component 113 further includes a Near Field Communication (NFC) module to facilitate short range communications. For example, the NFC module may be implemented based on Radio Frequency Identification (RFID) technology, infrared data association (IrDA) technology, ultra Wideband (UWB) technology, bluetooth (BT) technology, and other technologies.
A power supply assembly 114 provides power to the various components of the electronic device. The power components 114 may include a power management system, one or more power supplies, and other components associated with generating, managing, and distributing power for electronic devices.
The audio component 115 is configured to output and/or input audio signals. For example, the audio component 115 includes a Microphone (MIC) configured to receive external audio signals when the electronic device is in an operational mode, such as a call mode, a recording mode, and a voice recognition mode. The received audio signals may be further stored in the memory 111 or transmitted via the communication component 113. In some embodiments, audio component 115 further comprises a speaker for outputting audio signals.
The display 116 includes a screen, which may include a Liquid Crystal Display (LCD) and a Touch Panel (TP). If the screen includes a touch panel, the screen may be implemented as a touch screen to receive input signals from a user. The touch panel includes one or more touch sensors to sense touches, swipes, and gestures on the touch panel. The touch sensor may sense not only the boundary of a touch or sliding action, but also the duration and pressure associated with the touch or sliding operation.
Those of ordinary skill in the art will appreciate that: all or part of the steps for implementing the method embodiments described above may be performed by hardware associated with program instructions. The foregoing program may be stored in a computer readable storage medium. The program, when executed, performs steps including the method embodiments described above; and the aforementioned storage medium includes: various media that can store program code, such as ROM, RAM, magnetic or optical disks.
Finally, it should be noted that: the above embodiments are only for illustrating the technical solution of the present invention, and not for limiting the same; although the invention has been described in detail with reference to the foregoing embodiments, it will be understood by those of ordinary skill in the art that: the technical scheme described in the foregoing embodiments can be modified or some or all of the technical features thereof can be replaced by equivalents; such modifications and substitutions do not depart from the spirit of the invention.
Claims (13)
1. A method for processing message track information, comprising:
a message producer sends a first track trace message to a message storage, wherein the first track trace message comprises track information of the message in a sending stage of the message producer and a trace serial number of the message;
the message storage stores the first track trace message and a second track trace message, wherein the second track trace message comprises track information of the message in the storage stage of the message storage and a trace serial number of the message;
a message consumer sends a third trace message to the message store, wherein the third trace message comprises trace information of the message at the consumption stage of the message consumer and a trace serial number of the message;
the message store stores the third trace message.
2. The method of processing according to claim 1, further comprising:
the message producer sending a service message to the message store, the service message comprising the message and a tracking sequence number of the message;
the message store stores the service message and pushes the service message to the message consumer.
3. A method of processing according to claim 1 or 2, further comprising:
the message producer generates a tracking sequence number of the message for the message, the tracking sequence number of the message being used to uniquely identify the message.
4. The processing method of claim 2, wherein the first trace message, the second trace message, or the third trace message further comprises a category of message as a trace message;
the service message also includes a standard message of the message category.
5. The method of processing according to claim 4, further comprising:
the message storage obtains input query conditions, wherein the query conditions comprise the tracking sequence numbers of the tracking messages and the messages in the category of the messages;
the message storage inquires and acquires a track trace message corresponding to the inquired condition.
6. The method of processing according to claim 5, further comprising:
and the message storage unit sorts the acquired plurality of track trace messages according to the sequence to obtain the complete track information of the messages.
7. A system for processing message track information, comprising:
a message producer for sending a first trace message to a message store, the first trace message comprising trace information of a message at a sending stage of the message producer and a trace sequence number of the message;
the message storage is used for storing the first track trace message, a second track trace message and a third track trace message, wherein the second track trace message comprises track information of the message in the storage stage of the message storage and a trace serial number of the message;
and the message consumer is used for sending the third trace message to the message storage, wherein the third trace message comprises trace information of the message at the consumption stage of the message consumer and a trace serial number of the message.
8. The processing system of claim 7, wherein the message producer is further configured to: transmitting a service message to the message store, the service message including the message and a tracking sequence number of the message;
the message store is further configured to: storing the service message and pushing the service message to the message consumer.
9. The processing system of claim 7 or 8, wherein the message producer is further configured to:
a tracking sequence number of the message is generated for the message, the tracking sequence number of the message being used to uniquely identify the message.
10. The processing system of claim 8, wherein the first trace message, the second trace message, or the third trace message further comprises a category of message as a trace message;
the service message also includes a standard message of the message category.
11. The processing system of claim 10, wherein the message store is further configured to:
acquiring input query conditions, wherein the query conditions comprise the tracking sequence numbers of the tracking messages and the messages in the category of the messages;
inquiring and acquiring the track trace information corresponding to the inquiring condition.
12. The processing system of claim 11, wherein the message store is further configured to:
and sequencing the acquired track trace messages according to the sequence to obtain the complete track information of the messages.
13. An electronic device, comprising:
a memory for storing a program;
a processor coupled to the memory for executing the program for:
controlling a message producer to send a first trace message to a message store, the first trace message comprising trace information of a message at a sending stage of the message producer and a trace sequence number of the message;
controlling the message storage to store the first track trace message, a second track trace message and a third track trace message, wherein the second track trace message comprises track information of the message in the storage stage of the message storage and a trace serial number of the message;
and controlling a message consumer to send the third trace message to the message storage, wherein the third trace message comprises trace information of the message at the consumption stage of the message consumer and a trace serial number of the message.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201810306566.5A CN110362721B (en) | 2018-04-08 | 2018-04-08 | Message track information processing method, system and device and electronic equipment |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201810306566.5A CN110362721B (en) | 2018-04-08 | 2018-04-08 | Message track information processing method, system and device and electronic equipment |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN110362721A CN110362721A (en) | 2019-10-22 |
| CN110362721B true CN110362721B (en) | 2023-06-09 |
Family
ID=68213688
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201810306566.5A Active CN110362721B (en) | 2018-04-08 | 2018-04-08 | Message track information processing method, system and device and electronic equipment |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN110362721B (en) |
Families Citing this family (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112751893A (en) * | 2019-10-30 | 2021-05-04 | 中移(苏州)软件技术有限公司 | Message track data processing method and device and electronic equipment |
| CN114201659A (en) * | 2021-11-18 | 2022-03-18 | 广西北投信创科技投资集团有限公司 | A message track transmission query method, device and system |
| CN114398003A (en) * | 2021-12-07 | 2022-04-26 | 广西北投信创科技投资集团有限公司 | Information processing method and device message server |
Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20070255823A1 (en) * | 2006-05-01 | 2007-11-01 | International Business Machines Corporation | Method for low-overhead message tracking in a distributed messaging system |
| CN106301948A (en) * | 2016-08-31 | 2017-01-04 | 北京奇艺世纪科技有限公司 | A kind of message circulation visualization and monitoring method and system |
| CN107465549A (en) * | 2017-08-18 | 2017-12-12 | 北京奇艺世纪科技有限公司 | A kind of distributed message processing method and system |
-
2018
- 2018-04-08 CN CN201810306566.5A patent/CN110362721B/en active Active
Patent Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20070255823A1 (en) * | 2006-05-01 | 2007-11-01 | International Business Machines Corporation | Method for low-overhead message tracking in a distributed messaging system |
| CN106301948A (en) * | 2016-08-31 | 2017-01-04 | 北京奇艺世纪科技有限公司 | A kind of message circulation visualization and monitoring method and system |
| CN107465549A (en) * | 2017-08-18 | 2017-12-12 | 北京奇艺世纪科技有限公司 | A kind of distributed message processing method and system |
Also Published As
| Publication number | Publication date |
|---|---|
| CN110362721A (en) | 2019-10-22 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| KR102208362B1 (en) | Method and apparatus for managing message of electronic device | |
| US9070099B2 (en) | Developing and executing workflow processes associated with data-encoded tags | |
| CN109656980A (en) | Data processing method, electronic equipment, device and readable storage medium storing program for executing | |
| CN108572789B (en) | Disk storage method and device, message pushing method and device and electronic equipment | |
| CN110362721B (en) | Message track information processing method, system and device and electronic equipment | |
| CN104079962A (en) | Method and device for pushing recommendation information | |
| KR101347804B1 (en) | System and method for controlling avn for vehicle using nfc | |
| CN105159524A (en) | Interface display method and apparatus | |
| WO2019201197A1 (en) | Image desensitization method, electronic device and storage medium | |
| US20150379471A1 (en) | Management system for transmission of electronic business card based on telephone number linkage and method therefor | |
| CN104462296A (en) | File managing method and device and terminal | |
| CN101360300A (en) | Information record searching method and apparatus | |
| CN105528403A (en) | Target data identification method and apparatus | |
| CN104539812A (en) | Recommendation information acquisition method, terminal and server | |
| CN105554064A (en) | Method and device for setting head portrait | |
| CN109857967B (en) | Report subscription method and system based on big data | |
| US8289139B2 (en) | Electronic device, media management system and method thereof | |
| CN109299354A (en) | The searching method and device of online document | |
| CN105094510A (en) | Text processing method, device and system | |
| CN111104575B (en) | Data grabbing method and device and electronic equipment | |
| CN105450507A (en) | Method and device for sharing information in social network | |
| CN104216919A (en) | Method and system for perfecting electronic map data | |
| CN111459896B (en) | Data recovery system and method, electronic device, and computer-readable storage medium | |
| CN106411699A (en) | Method and device for controlling message display in social network application | |
| CN105573600A (en) | Notification bar operation method and 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 |