CN111031105B - Statistical method, device, device and storage medium for message frequency in autonomous driving - Google Patents

Abstract

The application discloses a statistical method, device, electronic device and storage medium of message frequency, which relate to the technical field of information flow and can be used in an operating system for automatic driving. The specific implementation scheme is: the statistical method of message frequency is executed by the statistical device of message frequency, and the statistical device of message frequency is set in a process; the statistical device of message frequency is located in the same process as the statistical device of message frequency after receiving the pre-subscribed message. In the process of sending multiple messages by the message sending module, the multiple receiving moments of the multiple messages are recorded; according to the multiple receiving moments within the preset time length, the frequency of sending messages by the message sending module is counted. The present application can overcome the technical problem of inaccurate frequency statistics in the prior art. Since the frequency statistics of the present application occur between the same processes, there is no inter-process communication delay, which can effectively improve the frequency statistics of messages sent by the message sending module. accuracy.

Description

Statistical method, device, device and storage medium for message frequency in autonomous driving

technical field

The present application relates to the field of computer technology, in particular to the processing of information flow, and in particular to a statistical method, device, electronic device and storage medium for message frequency, which can be used in an operating system for automatic driving.

Background technique

In an automatic driving system, the communication between two adjacent modules with a message transmission relationship, such as a sensor module, an obstacle recognition module, a planning module, etc., is realized by publishing and subscribing to topics (ie, message data). The topic publishing of each module is also periodic. If an exception occurs in a module, the output frequency of the topic of the module may be abnormal. Therefore, the statistics of the publishing frequency of the topic of the module is a very important task, and the staff can predict whether the module is normal based on the publishing frequency of the topic of the module.

However, the statistical solutions of the message frequencies of various modules provided in the prior art are not accurate enough to count the frequencies, and it is urgent to provide a solution that can accurately count the message frequencies.

SUMMARY OF THE INVENTION

In order to solve the above technical problems, the present application provides a method, device, electronic device and storage medium for statistics of message frequencies, which are used to provide a technical solution capable of accurately counting frequencies.

In one aspect, the present application provides a method for statistics of message frequencies, the method is performed by a device for statistics of message frequencies, the device for statistics of message frequencies is set in a process, and the method includes:

When receiving the pre-subscribed message sending modules that are in the same process as the message frequency statistics device in the process of sending the message, record the sending time when the multiple messages receive the message ;

According to the multiple receiving moments within the preset time length, the frequency of sending messages by the message sending module is counted.

Further optionally, in the above method, before receiving a plurality of pre-subscribed messages sent by a message sending module located in the same process as the frequency statistics device, the method further includes:

Determine the module identifier of the message sending module according to the process identifier of the process;

A subscription request for the message sent by the message sending module is sent to the message management module, where the subscription request includes the module identifier.

Further optionally, in the above method, after counting the frequency of messages sent by the message sending module, the method further includes:

According to the frequency of sending messages by the message sending module and a preset frequency threshold, it is detected whether the corresponding message sending module is abnormal.

Further optionally, in the above method, after counting the frequency of sending messages by the message sending module, the method further includes:

Receive the message frequency request sent by the frequency requester;

Send the frequency of the message sending module sending the message to the frequency requesting terminal, and the frequency of sending the message by the message sending module indicates whether the message sending module is abnormal.

On the other hand, the present application also provides a message frequency statistics device, the message frequency statistics device is set in a process, and the device includes:

a recording module, configured to record multiple reception times of the multiple messages in the process of receiving the multiple messages sent by the pre-subscribed message sending module located in the same process as the message frequency statistics device;

A statistics module, configured to count the frequency of messages sent by the message sending module according to the multiple receiving moments within a preset time length.

In another aspect, the application also provides an electronic device, comprising:

at least one processor; and

a memory communicatively coupled to the at least one processor; wherein,

The memory stores instructions executable by the at least one processor, the instructions being executed by the at least one processor to enable the at least one processor to perform the method of any of the above.

In yet another aspect, the present application also provides a non-transitory computer-readable storage medium storing computer instructions, the computer instructions being used to cause the computer to perform the method as described in any one of the above.

An embodiment in the above application has the following advantages or beneficial effects: a device for statistics of message frequencies in a process is provided, and the number of messages sent by a message sending module located in the same process as the device for statistics of message frequencies that are pre-subscribed is sent. In the process of each message, multiple receiving moments of multiple messages are recorded; according to multiple receiving moments within a preset time length, the frequency of messages sent by the message sending module is counted, which can overcome the inaccurate frequency statistics in the prior art. The problem is that since the frequency statistics in the embodiments of the present application occur between the same processes, there is no communication delay across processes, which can effectively improve the accuracy of the frequency statistics of messages sent by the message sending module.

Further, the technical solution of the present application can also detect whether the message sending module is abnormal based on the frequency of statistics, can automatically and effectively detect whether the message sending module is abnormal, and can also effectively expand the function and application of frequency statistics.

Further, the technical solution of the present application can also return to the frequency request segment the pre-statistical frequency of sending messages by the message sending module according to the message frequency request in the frequency request segment, without calculating the message sending frequency after receiving the message frequency request. The frequency of sending messages by the module can effectively ensure the accuracy of the returned frequency.

Other effects of the above-mentioned optional manners will be described below with reference to specific embodiments.

Description of drawings

The accompanying drawings are used for better understanding of the present solution, and do not constitute a limitation to the present application. in:

1 is a schematic diagram according to a first embodiment of the present application;

2 is a schematic diagram according to a second embodiment of the present application;

3 is a schematic diagram according to a third embodiment of the present application;

FIG. 4 is a block diagram of an electronic device used to implement the frequency statistics method according to the embodiment of the present application.

Detailed ways

Exemplary embodiments of the present application are described below with reference to the accompanying drawings, which include various details of the embodiments of the present application to facilitate understanding, and should be considered as exemplary only. Accordingly, those of ordinary skill in the art will recognize that various changes and modifications of the embodiments described herein can be made without departing from the scope and spirit of the present application. Also, descriptions of well-known functions and constructions are omitted from the following description for clarity and conciseness.

FIG. 1 is a flowchart of an embodiment of a frequency statistics method of the present application. As shown in FIG. 1 , the method for statistics of message frequencies in this embodiment is executed by a device for statistics of message frequencies. The device for statistics of message frequencies is set in a process, and the method may specifically include the following steps:

S101, in the process of receiving the pre-subscribed multiple messages sent by the message sending module located in the same process as the frequency statistics device, record multiple reception times of the multiple messages;

S102: Count the frequency of messages sent by the message sending module according to multiple receiving moments within a preset time length.

That is, the execution subject of the method for statistics of message frequencies in this embodiment is a device for statistics of message frequencies, and the device for statistics of message frequencies and the message sending module of the frequencies to be counted are set in the same process, so as to monitor the messages in the same process. The frequency of sending messages by the sending module is counted.

The method for statistics of message frequencies in this embodiment can be used to perform statistics on the frequencies of messages sent by any one of any two modules having information interaction in the information flow.

Optionally, the device for counting message frequencies in this embodiment may be an application-integrated software module, or may be extended to an electronic entity for monitoring message sending modules in the same process in business.

In this embodiment of the present application, an independent message frequency statistics module may also be used to implement cross-process statistics on the message frequencies in any other process. For example, if the message frequency statistics module is set in the first process , when the frequency of the message sending module in the second process is counted, when the message sending module of the second process publishes topic message data, the statistical module of the message frequency of the topic message data from the second process to the first process belongs to the cross-process operation, there is a time delay, so the statistics module of the message frequency in the first process records the moment when the message sending module in the second process publishes the topic message data itself is not accurate enough. In addition, when other modules need the frequency of the message sending module, it may also be cross-process requesting the frequency of the message sending module in the second process from the statistics module of the message frequency in the first process. The request itself also has a communication delay. After the statistics module of the message frequency of the first process obtains the request, it starts to count the frequency of the message sending module in the second process based on the current time, which will lead to the low accuracy of the frequency statistics of the message sending module.

In order to further improve the accuracy of message frequency statistics, in this embodiment, a message frequency statistics device may be set in each process to perform statistics on the frequencies of messages sent by message sending modules in the same process. Since the priority of information processing in the same process is the highest, which is far greater than that of inter-process information communication, this can effectively shorten the time delay and improve the accuracy of frequency statistics.

Specifically, in this embodiment, the message of the message sending module in the same process needs to be subscribed in advance. In this way, when the message sending module sends a message, the statistics device of the message frequency can receive the subscribed message, so as to record the information of the message. receive time. That is to say, although the device for statistics of message frequencies in this embodiment subscribes to messages of the message sending modules in the same process, it does not save the messages of the message sending modules, and only records the reception time of receiving the messages sent by the message sending modules.

In addition, in this embodiment, taking the time used for statistics as a preset time length as an example, when the device for statistics of message frequencies receives a pre-subscribed message sending module located in the same process within the preset time length, more In the process of each message, multiple receiving moments of the multiple messages are recorded, that is, each message corresponds to one receiving moment. In the same process, the time difference between the time when the message frequency statistics device receives each message and the time when the message sending module sends the message is very small. Therefore, in this embodiment, according to the preset time length, After receiving multiple reception times of the multiple messages sent by the message sending module, count the frequency of the messages sent by the message sending module. For example, the frequency of sending messages by the corresponding message sending module can be obtained by dividing the number of messages sent within the preset time length by the preset time length.

The preset time length in this embodiment may be set according to specific scene requirements in practical applications. For example, it can be 30s, 1min, or other length of time. For example, in a scenario with inaccurate frequency requirements, a longer preset time length can be set, and in a scenario with very precise frequency requirements, a relatively short preset time length can be set.

Optionally, outside the process, a message management module is provided for managing the message sending modules in each process, and specifically records information of multiple message sending modules in multiple processes. In practical applications, the message of the message sending module can be subscribed in the message management module. For example, the ID of the process where the current frequency statistics device is located is "10", and the message with the process ID of "10" can be subscribed in the message management module. Send the module's message. During specific implementation, the device for statistics of message frequency can determine the module identifier of the message sending module to be subscribed according to the process identifier of the process, and then send a subscription request for the message sent by the message sending module to the detailed management module, that is, in the subscription request Carry the identifier of the message sending module. In this way, a subscription relationship between the message frequency statistic device and the message sending module in the same process is established in the message management module, and the message sending module in the same process is notified that the message frequency statistic device subscribes to its message. In this way, when the message sending module in the same process sends message data, in addition to sending the message to the sender, it also needs to send a copy to the frequency statistics device according to the subscription relationship. The message frequency statistics device can receive and record in time the time of receiving the message sent by the message sending module. Since these operations are completed in the same process, the delay is very small. In this embodiment, the message frequency statistics device records The receiving time of the message sent by the message sending module is very accurate, and then the frequency of messages sent by the message sending module is more accurately counted subsequently.

In addition, in this embodiment, when no external frequency request is received, the frequency of the message sending module can be counted in real time according to the method of this embodiment, and when the frequency is required externally, the frequency can be directly acquired and returned. The frequency obtained in this way does not need to take a preset time length forward according to the moment when the frequency request is received to count the frequency of the message sending module, so as to ensure that the frequency of the statistics is not affected by the delay of the frequency request, and the frequency of the statistics is very accurate. Yes, it can accurately reflect the situation that the message sending module sends the message.

In the frequency statistics method of this embodiment, the frequency statistics device set in the process records multiple reception times of the multiple messages in the process of receiving the pre-subscribed multiple messages sent by the message sending modules in the same process; Counting the frequency of messages sent by the message sending module at multiple receiving moments within a preset time length can overcome the technical problem of inaccurate frequency statistics in the prior art. Since the frequency statistics in this embodiment occur in the same process, there is no The inter-process communication delay can effectively improve the accuracy of the frequency statistics of the messages sent by the message sending module.

FIG. 2 is a flowchart of another embodiment of the method for statistics of message frequencies of the present application. As shown in FIG. 2 , based on the above-mentioned embodiment shown in FIG. 1 , the method for counting message frequencies in this embodiment takes the example of including multiple message sending modules in the same process to introduce the technical solution of the present invention in detail. As shown in FIG. 2 , the method for statistics of message frequencies in this embodiment may specifically include the following steps:

S201, according to the current process identifier, from the message management module, subscribe to the message sent by the message sending module belonging to the same process;

For example, the information stored in the message management module of this embodiment may include the following contents in Table 1:

Table 1

For example, when subscribing specifically, the message frequency statistics device can first determine the identifier of the message sending module to be subscribed according to the identifier of the process in which it is located and in combination with the above Table 1; and then send the message carrying the message to be subscribed to the message management module. The subscription request of the identification of the module, the message management module establishes the subscription relationship between the statistical device of the message frequency and the message sending module to be subscribed, such as the subscription relationship adopts the identification of the statistical device of the message frequency and the identification of the message sending module. Subscription relationship to identify. Moreover, the message management module also needs to notify the message sending module of the subscription relationship, so that when the message sending module sends a message, the message can be simultaneously sent to the subscribed message frequency statistics device.

The difference between the frequency statistics method in this embodiment and the above-mentioned FIG. 1 is that in this embodiment, a process including multiple message sending modules is used as an example, and the messages of each message sending module are subscribed respectively to send messages to each message. The frequency of the module is counted. Or in practical applications, even if the same process includes multiple message sending modules, the frequency statistics device may only subscribe to the messages of some of the message sending modules that need to be focused on. The subscription in this case may require external participation in the selection. For example, the staff input the identifiers of some message sending modules that need to be subscribed in the same process, or input the characteristics of the message sending module, and then based on the characteristics of the message sending module The frequency statistics device in the process establishes a subscription relationship. At this time, correspondingly, information such as the characteristics of each message sending module needs to be recorded in the message management module.

S202, in the process of receiving each message sent by each message sending module in the same process of the subscription, record the receiving time of each message sent by the message sending module in the message time buffer corresponding to each message sending module;

In this embodiment, multiple message sending modules are included in the same process, and a message time buffer buffer can be configured for each message sending module to record the receiving time of the message sent by the corresponding message sending module, so as to ensure that the message is received. The receiving moments of the messages sent by the different message sending modules are not confused and recorded together.

S203. For each message sending module, based on the reception times of all messages recorded in the corresponding message time buffer, divide the number of receptions within the preset time length by the preset time length to obtain the corresponding message sending module's message sending rate. frequency;

The device for statistics of message frequencies in this embodiment may specifically create a service in the same process to calculate the sending frequencies of messages corresponding to each message sending module, as the frequency of the message sending module, that is, the working frequency.

S204. For each message sending module, according to the frequency of the message and a preset frequency threshold, detect whether the corresponding message sending module is abnormal.

In the communication link, most modules need to interact with other modules, such as message sending and message receiving. In this embodiment, the frequency at which the message sending module sends messages can also represent the working frequency of the message sending module to a certain extent. If the working frequency is abnormal, it can be considered that the message sending module is abnormal. In this embodiment, the frequency of sending messages can be monitored to determine whether the corresponding message sending module is abnormal. For different message sending modules, different frequency thresholds can be set based on their working mechanisms. In this embodiment, the message frequency statistics device can also detect whether the frequency of messages sent by each message sending module is lower than the corresponding preset frequency threshold. If it is lower, it is considered that the message sending module is abnormal. If the frequency threshold is set, it is considered that the message sending module is normal.

In practical applications, when a frequency requesting terminal has a frequency request, it sends a frequency request to the frequency statistics device, and the frequency statistics device feeds back the frequency obtained by the statistics to the frequency request terminal, so that the differences described in the prior art can be avoided. The delay of inter-process communication, thereby improving the accuracy of frequency. For example, the technical solution included at this time may specifically include the following steps:

(a) Receive the message frequency request sent by the frequency requester;

(b) sending the frequency of the message sending module to the frequency requester, and the frequency of the message sending module indicating whether the message sending module is abnormal, so that the frequency requester can detect the corresponding Whether the message sending module is abnormal, please refer to the relevant records on the side of the above-mentioned message frequency statistics device for details, which will not be repeated here.

It should be noted that the frequency of sending messages by the message sending module returned to the frequency requester is the frequency of sending messages by the latest message sending module at the current moment. That is to say, the frequency counting device has been counting the frequency of messages in real time. When receiving a message frequency request, it only obtains the frequency of the message of the message sending module corresponding to the current moment, that is, the latest frequency of the message of the message sending module. Get the historical message frequency of the message sending module.

It should be noted that, if there is only one message sending module in the process, the frequency statistics device only counts one message sending module, which can be implemented according to the above embodiment. However, if the process includes multiple message sending modules, at this time, the frequency of the message of each message sending module can be sent to the frequency requester according to the implementation manner of the above embodiment. Or if the frequency requester only wants to request the frequency of a message of a certain message sending module, the identifier of the message sending module can be carried in the message frequency request. Correspondingly, the frequency statistics device obtains the frequency of the latest message corresponding to the identifier of the message sending module, and returns it to the frequency requesting end, so that the frequency requesting end can detect the sending of the message according to the frequency of the message and the preset frequency threshold. Whether the module is abnormal. Alternatively, other service processing may also be performed according to the frequency of the message of the message sending module, which will not be repeated here.

The statistical method of the message frequency in this embodiment can be applied to the field of automatic driving, and is used to detect the message sending frequency of each module with a message transmission relationship, such as the sensor module, the obstacle identification module, the planning module, etc., and further Check whether the corresponding module is abnormal based on the frequency.

In the method for statistics of message frequencies in this embodiment, by adopting the above technical solution, the device for statistics of message frequencies in a process can perform statistics on the frequency of messages sent by each message transmission module in a plurality of message transmission modules in the same process , the problem of inaccurate frequency statistics in the prior art can be overcome, the communication delay across processes can also be avoided, and the accuracy of the frequency statistics of messages sent by the message sending module can be improved. In addition, in this embodiment, whether the message sending module is abnormal can be detected based on the frequency of statistics, whether the message sending module is abnormal can be effectively detected automatically, and the function and application of frequency statistics can also be effectively expanded.

Moreover, in this embodiment, it is also possible to return to the frequency request segment the pre-statistical frequency of sending messages by the message sending module according to the message frequency request in the frequency request segment, and it is not necessary to calculate the message sending module after receiving the message frequency request. The frequency can effectively ensure the accuracy of the returned frequency.

FIG. 3 is a structural diagram of an embodiment of an apparatus for counting message frequencies according to the present invention. As shown in FIG. 3 , the device 300 for statistics of message frequencies in this embodiment, the device for statistics of message frequencies is set in a process, and the device includes:

The recording module 301 is configured to record the multiple receiving moments of the multiple messages in the process of receiving the multiple messages sent by the pre-subscribed message sending module located in the same process as the message frequency statistics device;

The statistics module 302 is configured to count the frequency of messages sent by the message sending module according to multiple receiving moments within a preset time length.

Further optionally, as shown in FIG. 3 , the frequency statistics device 300 of this embodiment further includes: a determination module 303, configured to determine the module identifier of the message sending module according to the process identifier of the process;

The sending module 304 is configured to send a subscription request for the message sent by the message sending module to the message management module, where the subscription request includes the module identifier.

Further optionally, as shown in FIG. 3 , the frequency statistics device 300 in this embodiment further includes:

The detection module 305 is configured to detect whether the message sending module is abnormal according to the frequency of sending messages by the message sending module and a preset frequency threshold.

Further optionally, as shown in FIG. 3 , the frequency statistics device 300 in this embodiment further includes:

The receiving module 306 is used for receiving the message frequency request sent by the frequency requesting terminal;

The sending module 304 is configured to send to the frequency requester the frequency of the message sending module sending the message sending module sending the message; the frequency of sending the message by the message sending module indicates whether the message sending module is abnormal.

In the frequency statistics apparatus of this embodiment, the implementation principle and technical effect of implementing frequency statistics by using the above-mentioned modules are the same as those of the above-mentioned related method embodiments.

According to the embodiments of the present application, the present application further provides an electronic device and a readable storage medium.

As shown in FIG. 4 , it is a block diagram of an electronic device according to the frequency statistics method according to an embodiment of the present application. Electronic devices are intended to represent various forms of digital computers, such as laptops, desktops, workstations, personal digital assistants, servers, blade servers, mainframe computers, and other suitable computers. Electronic devices may also represent various forms of mobile devices, such as personal digital processors, cellular phones, smart phones, wearable devices, and other similar computing devices. The components shown herein, their connections and relationships, and their functions are by way of example only, and are not intended to limit implementations of the application described and/or claimed herein.

As shown in FIG. 4, the electronic device includes: one or more processors 401, a memory 402, and interfaces for connecting various components, including a high-speed interface and a low-speed interface. The various components are interconnected using different buses and may be mounted on a common motherboard or otherwise as desired. The processor may process instructions executed within the electronic device, including instructions stored in or on memory to display graphical information of the GUI on an external input/output device, such as a display device coupled to the interface. In other embodiments, multiple processors and/or multiple buses may be used with multiple memories and multiple memories, if desired. Likewise, multiple electronic devices may be connected, each providing some of the necessary operations (eg, as a server array, a group of blade servers, or a multiprocessor system). A processor 401 is taken as an example in FIG. 4 .

The memory 402 is the non-transitory computer-readable storage medium provided by the present application. Wherein, the memory stores instructions executable by at least one processor, so that the at least one processor executes the frequency statistics method provided by the present application. The non-transitory computer-readable storage medium of the present application stores computer instructions for causing the computer to execute the frequency statistics method provided by the present application.

As a non-transitory computer-readable storage medium, the memory 402 can be used to store non-transitory software programs, non-transitory computer-executable programs, and modules, such as program instructions/modules corresponding to the frequency statistics method in the embodiments of the present application (for example, appendix). related modules shown in Figure 3). The processor 401 executes various functional applications and data processing of the server by running the non-transitory software programs, instructions and modules stored in the memory 402, ie, implements the frequency statistics method in the above method embodiments.

The memory 402 may include a storage program area and a storage data area, wherein the storage program area may store an operating system, an application program required by at least one function; the storage data area may store data created by the use of electronic equipment according to the frequency statistics method, etc. . Additionally, memory 402 may include high-speed random access memory, and may also include non-transitory memory, such as at least one magnetic disk storage device, flash memory device, or other non-transitory solid state storage device. In some embodiments, the memory 402 may optionally include memory located remotely from the processor 401, and these remote memories may be connected to the electronic device of the frequency statistics method via a network. Examples of such networks include, but are not limited to, the Internet, an intranet, a local area network, a mobile communication network, and combinations thereof.

The electronic device for the frequency statistics method may further include: an input device 403 and an output device 404 . The processor 401 , the memory 402 , the input device 403 and the output device 404 may be connected by a bus or in other ways, and the connection by a bus is taken as an example in FIG. 4 .

The input device 403 can receive input numerical or character information, and generate key signal input related to user settings and function control of XXX's electronic equipment, such as a touch screen, a keypad, a mouse, a trackpad, a touchpad, a pointing stick, an or Multiple input devices such as mouse buttons, trackballs, joysticks, etc. Output devices 404 may include display devices, auxiliary lighting devices (eg, LEDs), haptic feedback devices (eg, vibration motors), and the like. The display device may include, but is not limited to, a liquid crystal display (LCD), a light emitting diode (LED) display, and a plasma display. In some implementations, the display device may be a touch screen.

Various implementations of the systems and techniques described herein can be implemented in digital electronic circuitry, integrated circuit systems, application specific ASICs (application specific integrated circuits), computer hardware, firmware, software, and/or combinations thereof. These various embodiments may include being implemented in one or more computer programs executable and/or interpretable on a programmable system including at least one programmable processor that The processor, which may be a special purpose or general-purpose programmable processor, may receive data and instructions from a storage system, at least one input device, and at least one output device, and transmit data and instructions to the storage system, the at least one input device, and the at least one output device an output device.

These computational programs (also referred to as programs, software, software applications, or codes) include machine instructions for programmable processors, and may be implemented using high-level procedural and/or object-oriented programming languages, and/or assembly/machine languages calculation program. As used herein, the terms "machine-readable medium" and "computer-readable medium" refer to any computer program product, apparatus, and/or apparatus for providing machine instructions and/or data to a programmable processor ( For example, magnetic disks, optical disks, memories, programmable logic devices (PLDs), including machine-readable media that receive machine instructions as machine-readable signals. The term "machine-readable signal" refers to any signal used to provide machine instructions and/or data to a programmable processor.

To provide interaction with a user, the systems and techniques described herein may be implemented on a computer having a display device (eg, a CRT (cathode ray tube) or LCD (liquid crystal display) monitor) for displaying information to the user ); and a keyboard and pointing device (eg, a mouse or trackball) through which a user can provide input to the computer. Other kinds of devices can also be used to provide interaction with the user; for example, the feedback provided to the user can be any form of sensory feedback (eg, visual feedback, auditory feedback, or tactile feedback); and can be in any form (including acoustic input, voice input, or tactile input) to receive input from the user.

The systems and techniques described herein may be implemented on a computing system that includes back-end components (eg, as a data server), or a computing system that includes middleware components (eg, an application server), or a computing system that includes front-end components (eg, a user's computer having a graphical user interface or web browser through which a user may interact with implementations of the systems and techniques described herein), or including such backend components, middleware components, Or any combination of front-end components in a computing system. The components of the system may be interconnected by any form or medium of digital data communication (eg, a communication network). Examples of communication networks include: Local Area Networks (LANs), Wide Area Networks (WANs), and the Internet.

A computer system can include clients and servers. Clients and servers are generally remote from each other and usually interact through a communication network. The relationship of client and server arises by computer programs running on the respective computers and having a client-server relationship to each other.

According to the technical solutions of the embodiments of the present application, when a pre-subscribed message sending module of the same process sends a message, the sending time of the message is recorded; To overcome the technical problem of inaccurate frequency statistics in the prior art, since the frequency statistics in the embodiments of the present application occur between the same processes, there is no inter-process communication delay, and the accuracy of the frequency statistics can be effectively improved.

According to the technical solutions of the embodiments of the present application, the frequency of each message sending module in the multiple message sending modules in the same process can also be counted, and the accuracy of the frequency statistics of each message sending module can be effectively ensured.

According to the technical solutions of the embodiments of the present application, a message time cache can also be configured for each message sending module, which is used to record the sending time of the message sent by the corresponding message sending module, so that the frequency of the message sending module can be accurately counted in the follow-up, so as to avoid Frequency statistics error occurs when multiple message sending modules are put together for statistics.

According to the technical solutions of the embodiments of the present application, it is also possible to detect whether the message sending module is abnormal based on the frequency of statistics, to automatically and effectively detect whether the message sending module is abnormal, and to effectively expand the function and application of frequency statistics.

According to the technical solutions of the embodiments of the present application, it is also possible to return to the frequency request segment the pre-statistical frequency of sending messages by the message sending module according to the message frequency request in the frequency request segment, and it is not necessary to calculate the message sending frequency after receiving the message frequency request. The frequency of sending messages by the module can effectively ensure the accuracy of the returned frequency.

It should be understood that steps may be reordered, added or deleted using the various forms of flow shown above. For example, the steps described in the present application can be performed in parallel, sequentially or in different orders, and as long as the desired results of the technical solutions disclosed in the present application can be achieved, no limitation is imposed herein.

The above-mentioned specific embodiments do not constitute a limitation on the protection scope of the present application. It should be understood by those skilled in the art that various modifications, combinations, sub-combinations and substitutions may occur depending on design requirements and other factors. Any modifications, equivalent replacements and improvements made within the spirit and principles of this application shall be included within the protection scope of this application.

Claims (10)

1. A statistical method of message frequency, characterized in that, the method is performed by a statistical device of message frequency, and the statistical device of message frequency is set in a process, and the method comprises: In the process of receiving the pre-subscribed multiple messages sent by the message sending module located in the same process as the message frequency statistics device, recording multiple reception times of the multiple messages; According to the multiple receiving moments within the preset time length, the frequency of sending messages by the message sending module is counted. 2. The method according to claim 1, wherein before receiving a plurality of messages sent by a pre-subscribed message sending module located in the same process as the device for statistics of the message frequency, the method further comprises: Determine the module identifier of the message sending module according to the process identifier of the process; A subscription request for the message sent by the message sending module is sent to the message management module, where the subscription request includes the module identifier. 3. The method according to claim 1 or 2, characterized in that, after counting the frequency of sending messages by the message sending module, the method further comprises: Whether the message sending module is abnormal is detected according to the frequency of sending messages by the message sending module and a preset frequency threshold. 4. The method according to claim 1 or 2, wherein after counting the frequencies of the multiple messages, the method further comprises: Receive the message frequency request sent by the frequency requester; The frequency of sending messages by the message sending module is sent to the frequency requesting end, and the frequency of sending messages by the message sending module indicates whether the message sending module is abnormal. 5. A device for statistics of message frequencies, characterized in that the device for statistics of message frequencies is set in a process, and the device comprises: a recording module, configured to record multiple reception times of the multiple messages in the process of receiving the multiple messages sent by the pre-subscribed message sending module located in the same process as the message frequency statistics device; A statistics module, configured to count the frequency of messages sent by the message sending module according to the multiple receiving moments within a preset time length. 6. The apparatus according to claim 5, wherein the apparatus further comprises: a determining module for determining the module identifier of the message sending module according to the process identifier of the process; A sending module, configured to send a subscription request for the message sent by the message sending module to the message management module, where the subscription request includes the module identifier. 7. The device according to claim 5 or 6, wherein the device further comprises: The detection module is configured to detect whether the message transmission module is abnormal according to the frequency of the message transmission module and the preset frequency threshold. 8. The apparatus according to claim 6, wherein the apparatus further comprises a receiving module; The receiving module is used for receiving the message frequency request sent by the frequency requesting terminal; The sending module is further configured to send, to the frequency requesting terminal, the frequency of sending messages by the message sending module; the frequency of sending messages by the message sending module indicates whether the message sending module is abnormal. 9. An electronic device, characterized in that, comprising: at least one processor; and a memory communicatively coupled to the at least one processor; wherein, The memory stores instructions executable by the at least one processor, the instructions being executed by the at least one processor to enable the at least one processor to perform the execution of any of claims 1-4 Methods. 10. A non-transitory computer-readable storage medium storing computer instructions, wherein the computer instructions are used to cause the computer to perform the method of any one of claims 1-4.

Images