CN118316887B - Flow surge elimination method and device for mass-sending information - Google Patents
Flow surge elimination method and device for mass-sending information Download PDFInfo
- Publication number
- CN118316887B CN118316887B CN202410735614.8A CN202410735614A CN118316887B CN 118316887 B CN118316887 B CN 118316887B CN 202410735614 A CN202410735614 A CN 202410735614A CN 118316887 B CN118316887 B CN 118316887B
- Authority
- CN
- China
- Prior art keywords
- information
- server
- group
- detection
- virtual thread
- 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
- 238000000034 method Methods 0.000 title claims abstract description 42
- 230000008030 elimination Effects 0.000 title description 5
- 238000003379 elimination reaction Methods 0.000 title description 5
- 238000012544 monitoring process Methods 0.000 claims abstract description 21
- 238000001514 detection method Methods 0.000 claims description 80
- 238000004088 simulation Methods 0.000 claims description 37
- 238000004590 computer program Methods 0.000 claims description 16
- 230000011664 signaling Effects 0.000 claims description 16
- 239000011159 matrix material Substances 0.000 claims description 14
- 238000011217 control strategy Methods 0.000 claims description 10
- 230000005540 biological transmission Effects 0.000 claims description 6
- 230000002159 abnormal effect Effects 0.000 claims description 4
- 238000010276 construction Methods 0.000 claims description 2
- 238000004364 calculation method Methods 0.000 claims 4
- 230000000694 effects Effects 0.000 abstract description 3
- 238000005516 engineering process Methods 0.000 abstract description 2
- 238000012545 processing Methods 0.000 description 7
- 238000010586 diagram Methods 0.000 description 4
- 230000008569 process Effects 0.000 description 4
- 238000004891 communication Methods 0.000 description 3
- 230000005856 abnormality Effects 0.000 description 2
- 230000006870 function Effects 0.000 description 2
- 238000012986 modification Methods 0.000 description 2
- 230000004048 modification Effects 0.000 description 2
- 230000003287 optical effect Effects 0.000 description 2
- 230000004044 response Effects 0.000 description 2
- 206010044565 Tremor Diseases 0.000 description 1
- 230000000903 blocking effect Effects 0.000 description 1
- 238000011161 development Methods 0.000 description 1
- 230000006872 improvement Effects 0.000 description 1
- 238000010295 mobile communication Methods 0.000 description 1
- 230000001105 regulatory effect Effects 0.000 description 1
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L47/00—Traffic control in data switching networks
- H04L47/10—Flow control; Congestion control
- H04L47/30—Flow control; Congestion control in combination with information about buffer occupancy at either end or at transit nodes
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Telephonic Communication Services (AREA)
Abstract
The embodiment of the invention provides a traffic surge eliminating method and device for mass-sending information, and relates to the technical field of network management technology. The method comprises the following steps: acquiring group sending information to be processed, and storing the group sending information into a preset virtual thread; monitoring information flow of group information of the virtual thread; under the condition that the information flow of the group sending information contained in the virtual thread is determined to be larger than a preset threshold value, a second server is called to execute target operation on the group sending information in the virtual thread in cooperation with the first server; executing the target operation on the group messaging information in the virtual thread through the first server under the condition that the information flow of the group messaging information contained in the virtual thread is smaller than a preset threshold value; the invention solves the problem of service interruption caused by flow surge, thereby achieving the effect of improving service stability.
Description
Technical Field
The embodiment of the invention relates to the technical field of data monitoring and processing, in particular to a flow surge eliminating method and device for mass-sending information.
Background
With the rapid development of the mobile internet, mass-sending information has become one of the important ways for enterprises, organizations and users to communicate. Mass-messaging generally refers to sending the same information content to a large number of users through email, text messaging, instant messaging software, and the like. The information sending mode has wide application in the aspects of sales promotion, news release, service notification and the like, and particularly has important effect on commercial sales promotion.
However, in the existing group messaging system, there is a rapid increase in the demand of users for receiving information at a specific time point, such as holiday promotion, emergency notification, etc., under high concurrency, so that the server faces a huge traffic pressure, which is easy to cause service interruption or delay.
There is currently no better solution to the above problems.
Disclosure of Invention
The embodiment of the invention provides a flow surge elimination method and a flow surge elimination device for mass-sending information, which are used for at least solving the problem of service interruption caused by flow surge in the related technology.
According to one embodiment of the present invention, there is provided a traffic surge cancellation method for mass-sending information, including:
the method comprises the steps of obtaining group sending information to be processed, and storing the group sending information into a preset virtual thread, wherein the virtual thread is provided by a first server;
monitoring information flow of group information of the virtual thread;
Under the condition that the information flow of the group sending information contained in the virtual thread is larger than a preset threshold value, a second server is called to execute target operation on the group sending information in the virtual thread in cooperation with the first server, wherein the second server comprises other servers except the first server;
and under the condition that the information flow of the group sending information contained in the virtual thread is smaller than a preset threshold value, executing the target operation on the group sending information in the virtual thread through the first server.
In an exemplary embodiment, the invoking the second server to target the group signaling in the virtual thread in conjunction with the first server includes:
thread balance detection is carried out on the second server;
And sending a call instruction to the second server under the condition that the thread balance of the second server meets a preset balance condition so as to instruct the second server to perform service synchronization operation on a first service resource and the first server, wherein the second server comprises the first service resource.
In an exemplary embodiment, the monitoring the information traffic of the group signaling of the virtual thread includes:
Performing feature detection on the group messaging information, wherein the feature detection comprises at least any one of group messaging period detection, group messaging address detection and group messaging requirement detection;
And determining a safety control strategy according to the characteristic detection result, and carrying out safety control on the group information according to the safety control strategy.
In an exemplary embodiment, after the obtaining the group information to be processed, the method further comprises:
storing the group information into a first storage space;
And when the first information is acquired again, calling the mass-sending information out of the first storage space, wherein the mass-sending information comprises the first information.
In one exemplary embodiment, after said performing a target operation on said group information in said virtual thread, said method further comprises:
Generating an operation result receipt according to the target operation result and preset script logic;
Sending the operation result receipt to a simulation service, and performing simulation detection on the operation result receipt through the simulation service, wherein the simulation service comprises a client simulation service and a server simulation service, and the simulation detection is performed simultaneously on the client simulation service and the server simulation service;
And sending the operation result receipt to a target user under the condition that the simulation detection result meets the requirement.
According to another embodiment of the present invention, there is provided a traffic surge cancellation device for mass-sending information, including:
The information acquisition module is used for acquiring group sending information to be processed, and storing the group sending information into a preset virtual thread, wherein the virtual thread is provided by a first server;
The flow monitoring module is used for monitoring information flow of the group signaling information of the virtual thread;
The first execution module is used for calling a second server to execute target operation on the group messaging information in the virtual thread in cooperation with the first server under the condition that the information flow of the group messaging information contained in the virtual thread is determined to be larger than a preset threshold, wherein the second server comprises other servers except the first server;
and the second execution module is used for executing the target operation on the mass-sending information in the virtual thread through the first server under the condition that the information flow of the mass-sending information contained in the virtual thread is smaller than a preset threshold value.
In an exemplary embodiment, the invoking the second server to target the group signaling in the virtual thread in conjunction with the first server includes:
thread balance detection is carried out on the second server;
And sending a call instruction to the second server under the condition that the thread balance of the second server meets a preset balance condition so as to instruct the second server to perform service synchronization operation on a first service resource and the first server, wherein the second server comprises the first service resource.
In one exemplary embodiment, the flow monitoring module includes:
The characteristic detection unit is used for carrying out characteristic detection on the group information, wherein the characteristic detection comprises at least any one of group sending period detection, group sending address detection and group sending requirement detection;
and the safety control unit is used for determining a safety control strategy according to the characteristic detection result and carrying out safety control on the group information according to the safety control strategy.
According to a further embodiment of the invention, there is also provided a computer readable storage medium having stored therein a computer program, wherein the computer program is arranged to perform the steps of any of the method embodiments described above when run.
According to a further embodiment of the invention, there is also provided an electronic device comprising a memory having stored therein a computer program and a processor arranged to run the computer program to perform the steps of any of the method embodiments described above.
According to the invention, the virtual thread is used for temporarily storing the mass-sending information, and other servers are called to process the mass-sending information under the condition that the message flow is larger than the threshold value, so that the pressure of flow surge on the servers is reduced, and the stability of the servers is improved, therefore, the problem of service interruption caused by the flow surge can be solved, and the effect of improving the service stability of the servers is achieved.
Drawings
Fig. 1 is a hardware block diagram of a mobile terminal for a traffic surge elimination method for mass-sending information according to an embodiment of the present invention;
FIG. 2 is a flow chart of a traffic surge cancellation method for mass-transit information according to an embodiment of the invention;
fig. 3 is a block diagram of a traffic surge eliminating device for mass-sending information according to an embodiment of the present invention.
Detailed Description
Embodiments of the present invention will be described in detail below with reference to the accompanying drawings in conjunction with the embodiments.
It should be noted that the terms "first," "second," and the like in the description and the claims of the present invention and the above figures are used for distinguishing between similar objects and not necessarily for describing a particular sequential or chronological order.
The method embodiments provided in the embodiments of the present application may be performed in a mobile terminal, a computer terminal or similar computing device. Taking the mobile terminal as an example, fig. 1 is a block diagram of a hardware structure of a mobile terminal of a traffic surge eliminating method for mass-sending information according to an embodiment of the present application. As shown in fig. 1, a mobile terminal may include one or more (only one is shown in fig. 1) processors 102 (the processor 102 may include, but is not limited to, a microprocessor MCU or a processing device such as a programmable logic device FPGA) and a memory 104 for storing data, wherein the mobile terminal may also include a transmission device 106 for communication functions and an input-output device 108. It will be appreciated by those skilled in the art that the structure shown in fig. 1 is merely illustrative and not limiting of the structure of the mobile terminal described above. For example, the mobile terminal may also include more or fewer components than shown in fig. 1, or have a different configuration than shown in fig. 1.
The memory 104 may be used to store a computer program, for example, a software program of application software and a module, such as a computer program corresponding to a traffic surge eliminating method for mass-sending information in an embodiment of the present invention, and the processor 102 executes the computer program stored in the memory 104 to perform various functional applications and data processing, that is, implement the method described above. Memory 104 may include high-speed random access memory, and may also include non-volatile memory, such as one or more magnetic storage devices, flash memory, or other non-volatile solid-state memory. In some examples, the memory 104 may further include memory remotely located relative to the processor 102, which may be connected to the mobile terminal via a network. Examples of such networks include, but are not limited to, the internet, intranets, local area networks, mobile communication networks, and combinations thereof.
The transmission device 106 is used to receive or transmit data via a network. Specific examples of the network described above may include a wireless network provided by a communication provider of the mobile terminal. In one example, the transmission device 106 includes a network adapter (Network Interface Controller, simply referred to as a NIC) that can connect to other network devices through a base station to communicate with the internet. In one example, the transmission device 106 may be a Radio Frequency (RF) module, which is configured to communicate with the internet wirelessly.
In this embodiment, a method for eliminating traffic surges for group sending information is provided, and fig. 2 is a flowchart of a method for eliminating traffic surges for group sending information according to an embodiment of the present invention, as shown in fig. 2, where the flowchart includes the following steps:
Step S201, obtaining group sending information to be processed, and storing the group sending information into a preset virtual thread, wherein the virtual thread is provided by a first server;
In the embodiment, the mass-sending message is stored in the virtual thread first, so that impact of large-flow data on the server is avoided, and the stability of the server is improved; meanwhile, the method is convenient to detect the mass-sent messages before processing the mass-sent messages, and the like, so that the adaptability of the system to different requirements and environments is improved.
The mass-sending message can be short messages, mails, communication messages of instant messaging software (such as micro-message messages, tremble messages and the like) and other information needing mass-sending; the virtual thread can support high concurrent data, and the first server providing the virtual thread needs to ensure that the first server has certain system redundancy so as to accept high concurrent traffic and can support the requirement of multiple extensions, and the number of the first servers can be one or multiple, and the number of the first servers can be regulated according to actual use environments.
It should be noted that, in order to increase the response speed, the information may be sent to the virtual thread while the group sending message is received, so that the response speed may be controlled within several milliseconds, and meanwhile, information blocking caused by affecting other network interfaces is avoided.
Step S202, monitoring information flow of group information of the virtual thread;
In this embodiment, in the process of storing the group information into the virtual thread, the information traffic in the storage process is monitored, so that the relevant processing is performed in time when the traffic surge occurs or the traffic entering the thread reaches the threshold value, thereby ensuring the stability of the service.
The information flow monitoring can be realized through a preset flow monitoring program.
Step S203, when it is determined that the information flow of the group sending information included in the virtual thread is greater than a preset threshold, invoking a second server to execute a target operation on the group sending information in the virtual thread in cooperation with the first server, where the second server includes other servers except the first server;
In this embodiment, when the impending traffic surge is detected, part or all of the resources of other servers are called to process the surge data, so that the service pressure of the first server is reduced, service interruption or delay caused by the traffic surge is eliminated, and normal operation of the server service is ensured.
For example, assuming that a large amount of data is coming in a short time, a call instruction with a call identifier is sent to other servers to call the other servers to co-process the large amount of coming data in cooperation with the first server.
The second server can be one server or a server cluster formed by a plurality of servers, and can be in an idle state or a working state when being called; when the second server is called, part of the resources of the second server can be called, or all the resources of the second server can be called, and the adjustment can be specifically performed according to the actual use condition; the target operation may be to transmit the group information, that is, to the target user or the target device, or may be to perform processing such as clipping or adjusting the group information.
Step S204, executing, by the first server, the target operation on the group sending information in the virtual thread, if it is determined that the information flow of the group sending information included in the virtual thread is less than the preset threshold.
In this embodiment, the information flow is smaller than the preset value, which means that flow surge will not occur temporarily in future time, and related information is called from the virtual thread through the preset core service to perform operations such as information consumption.
In an alternative embodiment, the invoking the second server to target the group signaling in the virtual thread in conjunction with the first server includes:
step S2031, detecting a thread balance of the second server;
Step S2032, sending a call instruction to the second server to instruct the second server to perform service synchronization operation on the first service resource and the first server, where the second server includes the first service resource, if the thread balance of the second server meets a preset balance condition.
In this embodiment, the thread balance detection is performed to determine whether the second server has enough free resources to be invoked, so as to ensure that related resources can be invoked when the target operation is performed subsequently.
The thread balance detection comprises detecting the content such as the remaining thread resources, storage space, computing power and the like of the second server.
In an alternative embodiment, the monitoring the information traffic of the group signaling of the virtual thread includes:
step S2021, performing feature detection on the group signaling information, where the feature detection includes at least any one of group signaling period detection, group signaling address detection, and group signaling requirement detection;
Step S2022, determining a security management and control policy according to the feature detection result, and performing security management and control on the group signaling information according to the security management and control policy.
In this embodiment, in the flow monitoring process, besides monitoring the flow, it is necessary to detect the information content, the group sending period, the group sending address, and other contents of the group sending information, so as to determine whether the related group sending information is normal content, avoid sending wrong group sending information, and reduce resource consumption caused by network attack.
The group sending period detection comprises the step of detecting the group sending period of group sending information, wherein the group sending period of short message content is at least 1 day to several weeks in general, the group sending period of instant messaging is one week to several weeks and is different, the group sending period of mails is 1 day to several months, and the like; the group sending address detection comprises detecting the address of a target object which needs to receive information and the address of sending information, and generally, the addresses of the target objects in the same batch are not repeated, and the addresses of the sending information are generally the same; the group sending requirement detection comprises configuration conditions, sending conditions and the like of short messages needing group sending; it should be noted that, in general, the group sending period, the group sending address, the group sending requirement, and the like of the same content have correlation, for example, the group sending period of the short message is 1 day, the group sending address should be a mobile phone number, and if the group sending address has a website or other content, it is noted that the group sending address may have abnormality; therefore, in the feature detection, in order to ensure the detection accuracy, the detection results of the group sending period detection, the group sending address detection, the group sending requirement detection and the like can be constructed according to a preset matrix construction rule, the detection results are used as matrix elements to be filled into the matrix, then the correlation of the related elements in the matrix is judged, the correlation value can be calculated and judged according to the correlation coefficient, and if the correlation value does not fall into a preset threshold range, the feature of the detection result or the group sending information is abnormal.
In an alternative embodiment, after the obtaining of the group information to be processed, the method further comprises:
step S205, storing the group information into a first storage space;
step S206, when the first information is retrieved, retrieving the group sending information from the first storage space, where the group sending information includes the first information.
In this embodiment, the group information is stored in the first storage space to facilitate subsequent duplication of the group information (e.g. whether related information is abnormal, etc.), so as to provide a reference basis for subsequent adjustment of the system related policy (e.g. establishing a user whitelist, vip list, etc.).
The first storage space can be a memory, a magnetic disk, a mobile hard disk or a fixed hard disk and other storage devices; the first information is information re-received in the group sending information; for example, after receiving the group sending information including the A information, temporarily storing the group sending information into a memory; when the A information is received later, the A information in the temporary memory is called out to be directly transmitted or otherwise operated, so that the processing time is saved.
In addition, when the system does not send out the group sending information in time due to factors such as faults, the first information (for example, the A information) stored in the first storage space can be directly called to send after the faults are removed, so that information loss is avoided.
In an alternative embodiment, after said performing a target operation on said group information in said virtual thread, said method further comprises:
Step S207, generating an operation result receipt according to the target operation result and preset script logic;
Step S208, the operation result receipt is sent to a simulation service, and simulation detection is carried out on the operation result receipt through the simulation service, wherein the simulation service comprises a client simulation service and a server simulation service, and the simulation detection is carried out on the client simulation service and the server simulation service at the same time;
step S209, sending the operation result receipt to a target user under the condition that the simulation detection result meets the requirement.
In this embodiment, when sending an information receipt to a user, there is a case where the receipt cannot be normally analyzed by the user due to a failure in sending the receipt caused by a system failure or an abnormality in the user side, in order to avoid the above problem, the relevant receipt may be sent to a specific simulation area, where the sending situation (i.e., a server side simulation service) and the analyzing situation (i.e., a client side simulation service) are simulated, so as to ensure that the receipt can be correctly sent and analyzed.
The server simulation service needs to simulate according to the environment condition of the user, namely, needs to collect the environment parameters of the user and build the environment; and the receipt of the operation result is automatically generated through the preset script logic, so that the generation efficiency of the receipt can be improved, and the labor cost is greatly saved.
It should be noted that in some cases, the simulation detection may be performed sequentially on the client side and the server side, that is, the simulation service of the client side and the simulation service of the server side may not be performed simultaneously, and may be specifically adjusted according to the actual situation.
From the description of the above embodiments, it will be clear to a person skilled in the art that the method according to the above embodiments may be implemented by means of software plus the necessary general hardware platform, but of course also by means of hardware, but in many cases the former is a preferred embodiment. Based on such understanding, the technical solution of the present invention may be embodied essentially or in a part contributing to the prior art in the form of a software product stored in a storage medium (e.g. ROM/RAM, magnetic disk, optical disk) comprising instructions for causing a terminal device (which may be a mobile phone, a computer, a server, or a network device, etc.) to perform the method according to the embodiments of the present invention.
The embodiment also provides a traffic surge eliminating device for mass-sending information, which is used for realizing the above embodiment and the preferred implementation, and is not described in detail. As used below, the term "module" may be a combination of software and/or hardware that implements a predetermined function. While the means described in the following embodiments are preferably implemented in software, implementation in hardware, or a combination of software and hardware, is also possible and contemplated.
Fig. 3 is a block diagram of a traffic surge eliminating device for mass-sending information according to an embodiment of the present invention, and as shown in fig. 3, the device includes:
the information acquisition module 31 is configured to acquire group sending information to be processed, and store the group sending information into a preset virtual thread, where the virtual thread is provided by a first server;
The flow monitoring module 32 is configured to monitor information flow of the group signaling information of the virtual thread;
The first execution module 33 is configured to invoke a second server to execute a target operation on the group messaging information in the virtual thread in cooperation with the first server, where the second server includes other servers except the first server, when it is determined that the information flow of the group messaging information included in the virtual thread is greater than a preset threshold;
And a second execution module 34, configured to execute, by the first server, the target operation on the group sending information in the virtual thread, if it is determined that the information flow of the group sending information included in the virtual thread is less than a preset threshold.
In an alternative embodiment, the invoking the second server to target the group signaling in the virtual thread in conjunction with the first server includes:
thread balance detection is carried out on the second server;
And sending a call instruction to the second server under the condition that the thread balance of the second server meets a preset balance condition so as to instruct the second server to perform service synchronization operation on a first service resource and the first server, wherein the second server comprises the first service resource.
In an alternative embodiment, the flow monitoring module includes:
The characteristic detection unit is used for carrying out characteristic detection on the group information, wherein the characteristic detection comprises at least any one of group sending period detection, group sending address detection and group sending requirement detection;
and the safety control unit is used for determining a safety control strategy according to the characteristic detection result and carrying out safety control on the group information according to the safety control strategy.
It should be noted that each of the above modules may be implemented by software or hardware, and for the latter, it may be implemented by, but not limited to: the modules are all located in the same processor; or the above modules may be located in different processors in any combination.
Embodiments of the present invention also provide a computer readable storage medium having a computer program stored therein, wherein the computer program is arranged to perform the steps of any of the method embodiments described above when run.
In one exemplary embodiment, the computer readable storage medium may include, but is not limited to: a usb disk, a Read-Only Memory (ROM), a random access Memory (Random Access Memory RAM), a removable hard disk, a magnetic disk, or an optical disk, or other various media capable of storing a computer program.
An embodiment of the invention also provides an electronic device comprising a memory having stored therein a computer program and a processor arranged to run the computer program to perform the steps of any of the method embodiments described above.
In an exemplary embodiment, the electronic apparatus may further include a transmission device connected to the processor, and an input/output device connected to the processor.
Specific examples in this embodiment may refer to the examples described in the foregoing embodiments and the exemplary implementation, and this embodiment is not described herein.
It will be appreciated by those skilled in the art that the modules or steps of the invention described above may be implemented in a general purpose computing device, they may be concentrated on a single computing device, or distributed across a network of computing devices, they may be implemented in program code executable by computing devices, so that they may be stored in a storage device for execution by computing devices, and in some cases, the steps shown or described may be performed in a different order than that shown or described herein, or they may be separately fabricated into individual integrated circuit modules, or multiple modules or steps of them may be fabricated into a single integrated circuit module. Thus, the present invention is not limited to any specific combination of hardware and software.
The above description is only of the preferred embodiments of the present invention and is not intended to limit the present invention, but various modifications and variations can be made to the present invention by those skilled in the art. Any modification, equivalent replacement, improvement, etc. made within the principle of the present invention should be included in the protection scope of the present invention.
Claims (10)
1. The traffic surge eliminating method for mass information transmission is characterized by comprising the following steps:
the method comprises the steps of obtaining group sending information to be processed, and storing the group sending information into a preset virtual thread, wherein the virtual thread is provided by a first server;
Monitoring information flow of group information of the virtual thread, wherein the monitoring of the information flow of the group information of the virtual thread comprises feature detection of the group information, wherein the feature detection comprises at least any one of group sending period detection, group sending address detection and group sending requirement detection, after a feature detection result is obtained, a detection matrix is built according to a preset matrix building rule, the feature detection result is used as a matrix element to be filled into the detection matrix, element correlation calculation is performed on the detection matrix, and the feature detection result is determined to be abnormal under the condition that the correlation calculation result does not fall into a preset threshold range;
Under the condition that the information flow of the group sending information contained in the virtual thread is larger than a preset threshold value, a second server is called to execute target operation on the group sending information in the virtual thread in cooperation with the first server, wherein the second server comprises other servers except the first server;
and under the condition that the information flow of the group sending information contained in the virtual thread is smaller than a preset threshold value, executing the target operation on the group sending information in the virtual thread through the first server.
2. The method of claim 1, wherein the invoking the second server in conjunction with the first server to target group signaling in the virtual thread comprises:
thread balance detection is carried out on the second server;
And sending a call instruction to the second server under the condition that the thread balance of the second server meets a preset balance condition so as to instruct the second server to perform service synchronization operation on a first service resource and the first server, wherein the second server comprises the first service resource.
3. The method of claim 1, wherein the monitoring information traffic for group signaling of the virtual thread further comprises:
And determining a safety control strategy according to the characteristic detection result, and carrying out safety control on the group information according to the safety control strategy.
4. The method of claim 1, wherein after the obtaining of the group information to be processed, the method further comprises:
storing the group information into a first storage space;
And when the first information is acquired again, calling the mass-sending information out of the first storage space, wherein the mass-sending information comprises the first information.
5. The method of claim 4, wherein after said performing a target operation on said group information in said virtual thread, said method further comprises:
Generating an operation result receipt according to the target operation result and preset script logic;
Sending the operation result receipt to a simulation service, and performing simulation detection on the operation result receipt through the simulation service, wherein the simulation service comprises a client simulation service and a server simulation service, and the simulation detection is performed simultaneously on the client simulation service and the server simulation service;
And sending the operation result receipt to a target user under the condition that the simulation detection result meets the requirement.
6. A traffic surge cancellation device for mass-transit information, comprising:
The information acquisition module is used for acquiring group sending information to be processed, and storing the group sending information into a preset virtual thread, wherein the virtual thread is provided by a first server;
The traffic monitoring module is used for monitoring information traffic of the group-transmitted information of the virtual thread, wherein the traffic monitoring module comprises a feature detection unit, and the feature detection unit is used for carrying out feature detection on the group-transmitted information, wherein the feature detection comprises at least any one of group-transmitted period detection, group-transmitted address detection and group-transmitted demand detection; after obtaining a characteristic detection result, constructing a detection matrix according to a preset matrix construction rule, filling the characteristic detection result into the detection matrix as a matrix element, performing element correlation calculation on the detection matrix, and determining that the characteristic detection result is abnormal under the condition that the correlation calculation result does not fall into a preset threshold range;
The first execution module is used for calling a second server to execute target operation on the group messaging information in the virtual thread in cooperation with the first server under the condition that the information flow of the group messaging information contained in the virtual thread is determined to be larger than a preset threshold, wherein the second server comprises other servers except the first server;
and the second execution module is used for executing the target operation on the mass-sending information in the virtual thread through the first server under the condition that the information flow of the mass-sending information contained in the virtual thread is smaller than a preset threshold value.
7. The apparatus of claim 6, wherein the invoking the second server in conjunction with the first server to target group signaling in the virtual thread comprises:
thread balance detection is carried out on the second server;
And sending a call instruction to the second server under the condition that the thread balance of the second server meets a preset balance condition so as to instruct the second server to perform service synchronization operation on a first service resource and the first server, wherein the second server comprises the first service resource.
8. The apparatus of claim 6, wherein the flow monitoring module further comprises:
and the safety control unit is used for determining a safety control strategy according to the characteristic detection result and carrying out safety control on the group information according to the safety control strategy.
9. A computer readable storage medium, characterized in that the computer readable storage medium has stored therein a computer program, wherein the computer program is arranged to execute the method of any of the claims 1 to 5 when run.
10. An electronic device comprising a memory and a processor, characterized in that the memory has stored therein a computer program, the processor being arranged to run the computer program to perform the method of any of the claims 1 to 5.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202410735614.8A CN118316887B (en) | 2024-06-07 | 2024-06-07 | Flow surge elimination method and device for mass-sending information |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202410735614.8A CN118316887B (en) | 2024-06-07 | 2024-06-07 | Flow surge elimination method and device for mass-sending information |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN118316887A CN118316887A (en) | 2024-07-09 |
| CN118316887B true CN118316887B (en) | 2024-09-17 |
Family
ID=91731467
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202410735614.8A Active CN118316887B (en) | 2024-06-07 | 2024-06-07 | Flow surge elimination method and device for mass-sending information |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN118316887B (en) |
Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101431734A (en) * | 2008-11-07 | 2009-05-13 | 中兴通讯股份有限公司 | Method and system for group sending short messages |
| CN103428008A (en) * | 2013-08-28 | 2013-12-04 | 浙江大学 | Big data distribution strategy oriented to multiple user groups |
Family Cites Families (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| ES2784239T3 (en) * | 2007-12-06 | 2020-09-23 | Broadcast of announcements to a plurality of diverse communication devices | |
| US8706822B2 (en) * | 2010-06-23 | 2014-04-22 | Microsoft Corporation | Delivering messages from message sources to subscribing recipients |
| CN106921634B (en) * | 2015-12-28 | 2020-11-20 | 中兴通讯股份有限公司 | Multimedia stream multicast method and device |
| CN110798412B (en) * | 2019-10-18 | 2023-05-23 | 北京浪潮数据技术有限公司 | Multicast service processing method and device, cloud platform, equipment and readable storage medium |
| CN114785749B (en) * | 2022-04-14 | 2024-07-16 | 北京京东拓先科技有限公司 | Message group sending processing method and device |
| CN115269111A (en) * | 2022-06-13 | 2022-11-01 | 阿里巴巴（中国）有限公司 | Task processing method, system and device and readable medium |
| CN117692401A (en) * | 2022-09-09 | 2024-03-12 | 深圳市腾讯网络信息技术有限公司 | Message sending method, device, server and storage medium |
-
2024
- 2024-06-07 CN CN202410735614.8A patent/CN118316887B/en active Active
Patent Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101431734A (en) * | 2008-11-07 | 2009-05-13 | 中兴通讯股份有限公司 | Method and system for group sending short messages |
| CN103428008A (en) * | 2013-08-28 | 2013-12-04 | 浙江大学 | Big data distribution strategy oriented to multiple user groups |
Also Published As
| Publication number | Publication date |
|---|---|
| CN118316887A (en) | 2024-07-09 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN108256118B (en) | Data processing method, device, system, computing equipment and storage medium | |
| CN108737218B (en) | Automatic verification method and device for message push arrival rate | |
| CN109450691B (en) | Service gateway monitoring method, device and computer readable storage medium | |
| CN112559154B (en) | Optimization method, system, equipment and readable storage medium for message transmission quantity increase | |
| CN110674440A (en) | Buried point data processing method, system, computer device and readable storage medium | |
| CN114095567B (en) | Data access request processing method and device, computer equipment and medium | |
| CN111246406A (en) | Short message sending method, system, storage medium and terminal equipment | |
| CN113259428A (en) | Data access request processing method and device, computer equipment and medium | |
| CN110333916B (en) | Request message processing method, device, computer system and readable storage medium | |
| CN112367345A (en) | Data processing method, server device and computer readable storage medium | |
| CN111666145A (en) | Message processing method and system of message queue and computer equipment | |
| CN109788251B (en) | Video processing method, device and storage medium | |
| CN113055493B (en) | Data packet processing method, device, system, scheduling device and storage medium | |
| CN110209548B (en) | Service control method, system, electronic device and computer readable storage medium | |
| CN118316887B (en) | Flow surge elimination method and device for mass-sending information | |
| CN112988417B (en) | Message processing method, device, electronic equipment and computer readable medium | |
| CN113747506B (en) | Resource scheduling method, device and network system | |
| CN113965563B (en) | Service processing method and device based on model and server | |
| CN114048059A (en) | Method and device for adjusting timeout time of interface, computer equipment and storage medium | |
| CN110134547B (en) | Middleware-based repeated data deleting method and related device | |
| CN112994976A (en) | Gateway testing method and device, electronic equipment and storage medium | |
| CN110543470A (en) | Message early warning method and device, storage medium and electronic device | |
| US20140359104A1 (en) | Grouping processing method and system | |
| CN112311765A (en) | Message detection method and device | |
| CN110955579A (en) | Ambari-based large data platform monitoring method |
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 |