CN118316887B - 一种用于群发信息的流量浪涌消除方法及装置 - Google Patents
一种用于群发信息的流量浪涌消除方法及装置 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
本发明实施例提供了一种用于群发信息的流量浪涌消除方法及装置，涉及网络管理技术的技术领域。其方法包括：获取待处理的群发信息，并将所述群发信息存储至预设的虚拟线程中；对所述虚拟线程的群发信息进行信息流量监控；在确定所述虚拟线程中包含的群发信息的信息流量大于预设阈值的情况下，调用第二服务器配合所述第一服务器对所述虚拟线程中的所述群发信息执行目标操作；在确定所述虚拟线程中包含的群发信息的信息流量小于预设阈值的情况下，通过所述第一服务器对所述虚拟线程中的所述群发信息执行所述目标操作；通过本发明，解决了流量浪涌导致的服务中断的问题，进而达到了提高服务稳定性的效果。
Description
技术领域
本发明实施例涉及数据监控处理技术领域，具体而言，涉及一种用于群发信息的流量浪涌消除方法及装置。
背景技术
随着移动互联网的快速发展，群发信息已成为企业、组织与用户沟通的重要方式之一。群发信息通常指的是通过电子邮件、短信、即时通讯软件等渠道，向大量用户发送相同的信息内容。这种信息发送方式在促销活动、新闻发布、服务通知等方面具有广泛的应用，特别是短信群发，对于商业促销活动有重要作用。
然而，现有的群发信息系统在高并发情况下存在着在特定的时间点，如节假日促销、突发事件通知等，用户接收信息的需求急剧增加，导致服务器面临巨大的流量压力，容易造成服务中断或延迟。
针对上述问题，当前并无较好的解决方案。
发明内容
本发明实施例提供了一种用于群发信息的流量浪涌消除方法及装置，以至少解决相关技术中流量浪涌导致的服务中断的问题。
根据本发明的一个实施例，提供了一种用于群发信息的流量浪涌消除方法，包括：
获取待处理的群发信息，并将所述群发信息存储至预设的虚拟线程中，所述虚拟线程由第一服务器提供；
对所述虚拟线程的群发信息进行信息流量监控；
在确定所述虚拟线程中包含的群发信息的信息流量大于预设阈值的情况下，调用第二服务器配合所述第一服务器对所述虚拟线程中的所述群发信息执行目标操作，其中，所述第二服务器包括除第一服务器以外的其他服务器；
在确定所述虚拟线程中包含的群发信息的信息流量小于预设阈值的情况下，通过所述第一服务器对所述虚拟线程中的所述群发信息执行所述目标操作。
在一个示例性实施例中，所述调用第二服务器配合所述第一服务器对所述虚拟线程中的群发信息进行目标操作包括：
对所述第二服务器进行线程余额检测；
在所述第二服务器的线程余额符合预设的余额条件的情况下，向所述第二服务器发送调用指令，以指示所述第二服务器将第一服务资源与所述第一服务器进行服务同步操作，其中，所述第二服务器包含所述第一服务资源。
在一个示例性实施例中，所述对所述虚拟线程的群发信息进行信息流量监控包括：
对所述群发信息进行特征检测，其中，所述特征检测包括群发周期检测、群发地址检测以及群发需求检测至少任意之一；
根据所述特征检测结果，确定安全管控策略，并根据所述安全管控策略对所述群发信息进行安全管控。
在一个示例性实施例中，在所述获取待处理的群发信息之后，所述方法还包括：
将所述群发信息存储至第一存储空间；
在重新获取到第一信息的情况，将所述群发信息从所述第一存储空间调出，所述群发信息包括所述第一信息。
在一个示例性实施例中，在所述对所述虚拟线程中的所述群发信息执行目标操作之后，所述方法还包括：
根据目标操作结果以及预设的脚本逻辑，生成操作结果回执；
将所述操作结果回执发送至模拟服务，并通过所述模拟服务对所述操作结果回执进行模拟检测，其中，所述模拟服务包括客户端模拟服务以及服务端模拟服务，所述模拟检测在所述客户端模拟服务以及所述服务端模拟服务同时进行；
在所述模拟检测结果符合要求的情况下，将所述操作结果回执发送至目标用户。
根据本发明的另一个实施例，提供了一种用于群发信息的流量浪涌消除装置，包括：
信息采集模块，用于获取待处理的群发信息，并将所述群发信息存储至预设的虚拟线程中，所述虚拟线程由第一服务器提供；
流量监控模块，用于对所述虚拟线程的群发信息进行信息流量监控；
第一执行模块，用于在确定所述虚拟线程中包含的群发信息的信息流量大于预设阈值的情况下，调用第二服务器配合所述第一服务器对所述虚拟线程中的所述群发信息执行目标操作，其中，所述第二服务器包括除第一服务器以外的其他服务器；
第二执行模块，在确定所述虚拟线程中包含的群发信息的信息流量小于预设阈值的情况下，通过所述第一服务器对所述虚拟线程中的所述群发信息执行所述目标操作。
在一个示例性实施例中，所述调用第二服务器配合所述第一服务器对所述虚拟线程中的群发信息进行目标操作包括：
对所述第二服务器进行线程余额检测；
在所述第二服务器的线程余额符合预设的余额条件的情况下，向所述第二服务器发送调用指令，以指示所述第二服务器将第一服务资源与所述第一服务器进行服务同步操作，其中，所述第二服务器包含所述第一服务资源。
在一个示例性实施例中，所述流量监控模块包括：
特征检测单元，用于对所述群发信息进行特征检测，其中，所述特征检测包括群发周期检测、群发地址检测以及群发需求检测至少任意之一；
安全管控单元，用于根据所述特征检测结果，确定安全管控策略，并根据所述安全管控策略对所述群发信息进行安全管控。
根据本发明的又一个实施例，还提供了一种计算机可读存储介质，所述计算机可读存储介质中存储有计算机程序，其中，所述计算机程序被设置为运行时执行上述任一项方法实施例中的步骤。
根据本发明的又一个实施例，还提供了一种电子装置，包括存储器和处理器，所述存储器中存储有计算机程序，所述处理器被设置为运行所述计算机程序以执行上述任一项方法实施例中的步骤。
通过本发明，由于通过虚拟线程对群发信息进行暂时性存储，并在消息流量大于阈值的情况下调用其他服务器对群发信息进行处理，从而减少流量浪涌对服务器的压力，提高服务器的稳定性，因此，可以解决流量浪涌导致的服务中断的问题，达到提高服务器服务稳定性的效果。
附图说明
图1是本发明实施例的一种用于群发信息的流量浪涌消除方法的移动终端的硬件结构框图；
图2是根据本发明实施例的一种用于群发信息的流量浪涌消除方法的流程图；
图3是根据本发明实施例的一种用于群发信息的流量浪涌消除装置的结构框图。
具体实施方式
下文中将参考附图并结合实施例来详细说明本发明的实施例。
需要说明的是，本发明的说明书和权利要求书及上述附图中的术语“第一”、“第二”等是用于区别类似的对象，而不必用于描述特定的顺序或先后次序。
本申请实施例中所提供的方法实施例可以在移动终端、计算机终端或者类似的运算装置中执行。以运行在移动终端上为例，图1是本发明实施例的一种用于群发信息的流量浪涌消除方法的移动终端的硬件结构框图。如图1所示，移动终端可以包括一个或多个（图1中仅示出一个）处理器102（处理器102可以包括但不限于微处理器MCU或可编程逻辑器件FPGA等的处理装置）和用于存储数据的存储器104，其中，上述移动终端还可以包括用于通信功能的传输设备106以及输入输出设备108。本领域普通技术人员可以理解，图1所示的结构仅为示意，其并不对上述移动终端的结构造成限定。例如，移动终端还可包括比图1中所示更多或者更少的组件，或者具有与图1所示不同的配置。
存储器104可用于存储计算机程序，例如，应用软件的软件程序以及模块，如本发明实施例中的一种用于群发信息的流量浪涌消除方法对应的计算机程序，处理器102通过运行存储在存储器104内的计算机程序，从而执行各种功能应用以及数据处理，即实现上述的方法。存储器104可包括高速随机存储器，还可包括非易失性存储器，如一个或者多个磁性存储装置、闪存、或者其他非易失性固态存储器。在一些实例中，存储器104可进一步包括相对于处理器102远程设置的存储器，这些远程存储器可以通过网络连接至移动终端。上述网络的实例包括但不限于互联网、企业内部网、局域网、移动通信网及其组合。
传输设备106用于经由一个网络接收或者发送数据。上述的网络具体实例可包括移动终端的通信供应商提供的无线网络。在一个实例中，传输设备106包括一个网络适配器（Network Interface Controller，简称为NIC），其可通过基站与其他网络设备相连从而可与互联网进行通讯。在一个实例中，传输设备106可以为射频（Radio Frequency，简称为RF）模块，其用于通过无线方式与互联网进行通讯。
在本实施例中提供了一种用于群发信息的流量浪涌消除方法，图2是根据本发明实施例的一种用于群发信息的流量浪涌消除方法的流程图，如图2所示，该流程包括如下步骤：
步骤S201，获取待处理的群发信息，并将所述群发信息存储至预设的虚拟线程中，所述虚拟线程由第一服务器提供；
在本实施例中，将群发消息先存储在虚拟线程中，以避免大流量的数据直接对服务器造成冲击，提高服务器的稳定性；同时也方便在对群发消息进行处理之前先对群发消息进行检测等处理，从而提高系统对于不同需求环境的适应性。
其中，群发消息可以是需要群发的短信、邮件、即时通讯软件的通讯消息（如微信消息、抖音消息等）等信息；虚拟线程通常可以支持高并发的数据，而提供虚拟线程的第一服务器通常需要保证其具有一定的系统冗余以便可以接受高并发的流量，且能够支持多扩展的需求，且第一服务器的数量可以是一台，也可以是多台，具体根据实际使用环境进行调整。
需要说明的是，为了提高响应速度，可以在接收到群发消息的同时即将该信息发送至虚拟线程，以使得响应速度可以控制在几毫秒之内，同时也避免影响其他网络接口而造成信息堵塞。
步骤S202，对所述虚拟线程的群发信息进行信息流量监控；
在本实施例中，在将群发信息存储至虚拟线程的过程中，对存储过程中的信息流量进行监控，以在即将出现流量浪涌或进入线程的流量达到阈值的情况下及时进行相关处理，从而保证了服务的稳定性。
其中，信息流量监控可以通过预设的流量监控程序实现。
步骤S203，在确定所述虚拟线程中包含的群发信息的信息流量大于预设阈值的情况下，调用第二服务器配合所述第一服务器对所述虚拟线程中的所述群发信息执行目标操作，其中，所述第二服务器包括除第一服务器以外的其他服务器；
在本实施例中，在监测到即将出现流量浪涌时，则调用其他服务器的部分或全部资源来对浪涌的数据进行处理，从而减少第一服务器的服务压力，从而消除流量浪涌造成的服务中断或延迟，保证服务器服务的正常运行。
例如，假设短时间内来了大量的数据，则向其他服务器发送带有调用标识的调用指令，以调用其他服务器配合第一服务器对到来的大量数据进行共同处理。
其中，第二服务器可以是一台服务器，也可以是多台服务器组成的服务器集群，且第二服务器在被调用时，可以是处于空闲状态，也可以是处于工作状态；调用第二服务器时可以调用部分第二服务器的资源，也可以是调用第二服务器的全部资源，具体可以根据实际使用情况进行调整；目标操作可以是对群发信息进行发送，即发送给目标用户或目标设备，也可以是对群发信息进行剪裁或调整等处理。
步骤S204，在确定所述虚拟线程中包含的群发信息的信息流量小于预设阈值的情况下，通过所述第一服务器对所述虚拟线程中的所述群发信息执行所述目标操作。
在本实施例中，信息流量小于预设值，说明未来时间内暂时不会出现流量浪涌，此时则通过预设的核心服务从虚拟线程中调用相关信息进行信息消费等操作。
在一个可选的实施例中，所述调用第二服务器配合所述第一服务器对所述虚拟线程中的群发信息进行目标操作包括：
步骤S2031，对所述第二服务器进行线程余额检测；
步骤S2032，在所述第二服务器的线程余额符合预设的余额条件的情况下，向所述第二服务器发送调用指令，以指示所述第二服务器将第一服务资源与所述第一服务器进行服务同步操作，其中，所述第二服务器包含所述第一服务资源。
在本实施例中，进行线程余额检测是为了判断第二服务器是否有足够的空闲资源可以被调用，以保证后续进行目标操作时可以调用相关资源。
其中，线程余额检测包括检测第二服务器的剩余的线程资源、存储空间、算力等内容。
在一个可选的实施例中，所述对所述虚拟线程的群发信息进行信息流量监控包括：
步骤S2021，对所述群发信息进行特征检测，其中，所述特征检测包括群发周期检测、群发地址检测以及群发需求检测至少任意之一；
步骤S2022，根据所述特征检测结果，确定安全管控策略，并根据所述安全管控策略对所述群发信息进行安全管控。
在本实施例中，在进行流量监控过程中，除了对流量大小进行监控之外，还需要对群发信息的信息内容、群发周期、群发地址等内容进行检测，以判断相关群发信息是否为正常内容，避免发送错误的群发信息以及减少因网络攻击造成的资源消耗。
其中，群发周期检测包括对群发信息进行群发的周期进行检测，一般情况下，短信内容的群发周期至少为1天到几周，即时通信的群发周期为一周到几周不等，邮件的群发周期为1天到几个月，以此类推；群发地址检测包括对需要接受信息的目标对象的地址以及发送信息的地址进行检测，一般情况下，同一批次的目标对象的地址不会重复，发送信息的地址通常相同；群发需求检测包括需要进行群发的短信的配置条件以及发送条件等；需要说明的是，一般情况下，相同内容的群发周、群发地址以及群发需求等具有相关性，例如短信的群发周期为1天，则其群发地址应当为手机号，如果群发地址出现网址或其他内容，则说明群发地址可能存在异常；因而在进行特征检测时，为保证检测准确性可以将群发周期检测、群发地址检测、群发需求检测等检测结果根据预设的矩阵构建规则构建检测矩阵，并将检测结果作为矩阵元素填入矩阵，随后判断矩阵中相关元素的相关性，相关性值可以根据相关性系数进行计算判断，如果相关性值未落入预设的阈值范围，则说明检测结果或群发信息的特征存在异常。
在一个可选的实施例中，在所述获取待处理的群发信息之后，所述方法还包括：
步骤S205，将所述群发信息存储至第一存储空间；
步骤S206，在重新获取到第一信息的情况，将所述群发信息从所述第一存储空间调出，所述群发信息包括所述第一信息。
在本实施例中，将群发信息存储到第一存储空间是为了方便后续对群发信息的情况进行复盘（例如相关信息是否异常等），从而为后续的系统相关策略的调整提供参考依据（例如建立用户白名单、Vip名单等）。
其中，第一存储空间可以是内存，也可以是磁盘，还可以是移动硬盘或固定硬盘等存储设备；第一信息为群发信息中重新接收到的信息；例如，在接收到包含A信息的群发信息后，将该群发信息存储值临时内存；当后续又接收到A信息时，则将临时内存中的A信息调出直接进行发送或其他操作，从而节约处理时间。
另外，当系统因为故障等因素导致群发信息未及时发出时，也可以在故障排除后直接调用第一存储空间内存储的第一信息（例如前述A信息）来进行发送，从而避免信息缺失。
在一个可选的实施例中，在所述对所述虚拟线程中的所述群发信息执行目标操作之后，所述方法还包括：
步骤S207，根据目标操作结果以及预设的脚本逻辑，生成操作结果回执；
步骤S208，将所述操作结果回执发送至模拟服务，并通过所述模拟服务对所述操作结果回执进行模拟检测，其中，所述模拟服务包括客户端模拟服务以及服务端模拟服务，所述模拟检测在所述客户端模拟服务以及所述服务端模拟服务同时进行；
步骤S209，在所述模拟检测结果符合要求的情况下，将所述操作结果回执发送至目标用户。
在本实施例中，在向用户发送信息回执时，存在着因系统故障导致的回执发送失败或用户端异常导致用户无法正常解析回执的情况，为避免上述问题，可以先将相关回执发送至特定的模拟区域，在该区域模拟发送情况（即服务端模拟服务）和解析情况（即客户端模拟服务），从而保证回执可以被正确发送和解析。
其中，服务端模拟服务需要根据用户的环境情况进行模拟，即需要收集用户的环境参数并进行环境的搭建；而通过预设的脚本逻辑自动生成操作结果回执能够提高回执的生成效率，极大的节约人工成本。
需要说明的是，在一些情况下，模拟检测可以依次在客户端和服务端进行，即模客户端模拟服务和服务端模拟服务可以不同时进行，具体可以根据实际情况进行调整。
通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到根据上述实施例的方法可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件，但很多情况下前者是更佳的实施方式。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质（如ROM/RAM、磁碟、光盘）中，包括若干指令用以使得一台终端设备（可以是手机，计算机，服务器，或者网络设备等）执行本发明各个实施例所述的方法。
在本实施例中还提供了一种用于群发信息的流量浪涌消除装置，该装置用于实现上述实施例及优选实施方式，已经进行过说明的不再赘述。如以下所使用的，术语“模块”可以实现预定功能的软件和/或硬件的组合。尽管以下实施例所描述的装置较佳地以软件来实现，但是硬件，或者软件和硬件的组合的实现也是可能并被构想的。
图3是根据本发明实施例的一种用于群发信息的流量浪涌消除装置的结构框图，如图3所示，该装置包括：
信息采集模块31，用于获取待处理的群发信息，并将所述群发信息存储至预设的虚拟线程中，所述虚拟线程由第一服务器提供；
流量监控模块32，用于对所述虚拟线程的群发信息进行信息流量监控；
第一执行模块33，用于在确定所述虚拟线程中包含的群发信息的信息流量大于预设阈值的情况下，调用第二服务器配合所述第一服务器对所述虚拟线程中的所述群发信息执行目标操作，其中，所述第二服务器包括除第一服务器以外的其他服务器；
第二执行模块34，在确定所述虚拟线程中包含的群发信息的信息流量小于预设阈值的情况下，通过所述第一服务器对所述虚拟线程中的所述群发信息执行所述目标操作。
在一个可选的实施例中，所述调用第二服务器配合所述第一服务器对所述虚拟线程中的群发信息进行目标操作包括：
对所述第二服务器进行线程余额检测；
在所述第二服务器的线程余额符合预设的余额条件的情况下，向所述第二服务器发送调用指令，以指示所述第二服务器将第一服务资源与所述第一服务器进行服务同步操作，其中，所述第二服务器包含所述第一服务资源。
在一个可选的实施例中，所述流量监控模块包括：
特征检测单元，用于对所述群发信息进行特征检测，其中，所述特征检测包括群发周期检测、群发地址检测以及群发需求检测至少任意之一；
安全管控单元，用于根据所述特征检测结果，确定安全管控策略，并根据所述安全管控策略对所述群发信息进行安全管控。
需要说明的是，上述各个模块是可以通过软件或硬件来实现的，对于后者，可以通过以下方式实现，但不限于此：上述模块均位于同一处理器中；或者，上述各个模块以任意组合的形式分别位于不同的处理器中。
本发明的实施例还提供了一种计算机可读存储介质，该计算机可读存储介质中存储有计算机程序，其中，该计算机程序被设置为运行时执行上述任一项方法实施例中的步骤。
在一个示例性实施例中，上述计算机可读存储介质可以包括但不限于：U盘、只读存储器（Read-Only Memory，简称为ROM）、随机存取存储器（Random Access Memory，简称为RAM）、移动硬盘、磁碟或者光盘等各种可以存储计算机程序的介质。
本发明的实施例还提供了一种电子装置，包括存储器和处理器，该存储器中存储有计算机程序，该处理器被设置为运行计算机程序以执行上述任一项方法实施例中的步骤。
在一个示例性实施例中，上述电子装置还可以包括传输设备以及输入输出设备，其中，该传输设备和上述处理器连接，该输入输出设备和上述处理器连接。
本实施例中的具体示例可以参考上述实施例及示例性实施方式中所描述的示例，本实施例在此不再赘述。
显然，本领域的技术人员应该明白，上述的本发明的各模块或各步骤可以用通用的计算装置来实现，它们可以集中在单个的计算装置上，或者分布在多个计算装置所组成的网络上，它们可以用计算装置可执行的程序代码来实现，从而，可以将它们存储在存储装置中由计算装置来执行，并且在某些情况下，可以以不同于此处的顺序执行所示出或描述的步骤，或者将它们分别制作成各个集成电路模块，或者将它们中的多个模块或步骤制作成单个集成电路模块来实现。这样，本发明不限制于任何特定的硬件和软件结合。
以上所述仅为本发明的优选实施例而已，并不用于限制本发明，对于本领域的技术人员来说，本发明可以有各种更改和变化。凡在本发明的原则之内，所作的任何修改、等同替换、改进等，均应包含在本发明的保护范围之内。
Claims (10)
1.一种用于群发信息的流量浪涌消除方法，其特征在于，包括：
获取待处理的群发信息，并将所述群发信息存储至预设的虚拟线程中，所述虚拟线程由第一服务器提供；
对所述虚拟线程的群发信息进行信息流量监控，其中，所述对所述虚拟线程的群发信息进行信息流量监控包括对所述群发信息进行特征检测，其中，所述特征检测包括群发周期检测、群发地址检测以及群发需求检测至少任意之一，在得到特征检测结果之后，根据预设的矩阵构建规则构建检测矩阵，并将所示特征检测结果作为矩阵元素填入所述检测矩阵，并对所述检测矩阵进行元素相关性计算，在相关性计算结果未落入预设的阈值范围的情况下，确定所述特征检测结果存在异常；
在确定所述虚拟线程中包含的群发信息的信息流量大于预设阈值的情况下，调用第二服务器配合所述第一服务器对所述虚拟线程中的所述群发信息执行目标操作，其中，所述第二服务器包括除第一服务器以外的其他服务器；
在确定所述虚拟线程中包含的群发信息的信息流量小于预设阈值的情况下，通过所述第一服务器对所述虚拟线程中的所述群发信息执行所述目标操作。
2.根据权利要求1所述的方法，其特征在于，所述调用第二服务器配合所述第一服务器对所述虚拟线程中的群发信息进行目标操作包括：
对所述第二服务器进行线程余额检测；
在所述第二服务器的线程余额符合预设的余额条件的情况下，向所述第二服务器发送调用指令，以指示所述第二服务器将第一服务资源与所述第一服务器进行服务同步操作，其中，所述第二服务器包含所述第一服务资源。
3.根据权利要求1所述的方法，其特征在于，所述对所述虚拟线程的群发信息进行信息流量监控还包括：
根据所述特征检测结果，确定安全管控策略，并根据所述安全管控策略对所述群发信息进行安全管控。
4.根据权利要求1所述的方法，其特征在于，在所述获取待处理的群发信息之后，所述方法还包括：
将所述群发信息存储至第一存储空间；
在重新获取到第一信息的情况，将所述群发信息从所述第一存储空间调出，所述群发信息包括所述第一信息。
5.根据权利要求4所述的方法，其特征在于，在所述对所述虚拟线程中的所述群发信息执行目标操作之后，所述方法还包括：
根据目标操作结果以及预设的脚本逻辑，生成操作结果回执；
将所述操作结果回执发送至模拟服务，并通过所述模拟服务对所述操作结果回执进行模拟检测，其中，所述模拟服务包括客户端模拟服务以及服务端模拟服务，所述模拟检测在所述客户端模拟服务以及所述服务端模拟服务同时进行；
在所述模拟检测结果符合要求的情况下，将所述操作结果回执发送至目标用户。
6.一种用于群发信息的流量浪涌消除装置，其特征在于，包括：
信息采集模块，用于获取待处理的群发信息，并将所述群发信息存储至预设的虚拟线程中，所述虚拟线程由第一服务器提供；
流量监控模块，用于对所述虚拟线程的群发信息进行信息流量监控，其中，所述流量监控模块包括特征检测单元，所述特征检测单元用于对所述群发信息进行特征检测，其中，所述特征检测包括群发周期检测、群发地址检测以及群发需求检测至少任意之一；在得到特征检测结果之后，根据预设的矩阵构建规则构建检测矩阵，并将所示特征检测结果作为矩阵元素填入所述检测矩阵，并对所述检测矩阵进行元素相关性计算，在相关性计算结果未落入预设的阈值范围的情况下，确定所述特征检测结果存在异常；
第一执行模块，用于在确定所述虚拟线程中包含的群发信息的信息流量大于预设阈值的情况下，调用第二服务器配合所述第一服务器对所述虚拟线程中的所述群发信息执行目标操作，其中，所述第二服务器包括除第一服务器以外的其他服务器；
第二执行模块，在确定所述虚拟线程中包含的群发信息的信息流量小于预设阈值的情况下，通过所述第一服务器对所述虚拟线程中的所述群发信息执行所述目标操作。
7.根据权利要求6所述的装置，其特征在于，所述调用第二服务器配合所述第一服务器对所述虚拟线程中的群发信息进行目标操作包括：
对所述第二服务器进行线程余额检测；
在所述第二服务器的线程余额符合预设的余额条件的情况下，向所述第二服务器发送调用指令，以指示所述第二服务器将第一服务资源与所述第一服务器进行服务同步操作，其中，所述第二服务器包含所述第一服务资源。
8.根据权利要求6所述的装置，其特征在于，所述流量监控模块还包括：
安全管控单元，用于根据所述特征检测结果，确定安全管控策略，并根据所述安全管控策略对所述群发信息进行安全管控。
9.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质中存储有计算机程序，其中，所述计算机程序被设置为运行时执行所述权利要求1至5任一项中所述的方法。
10.一种电子装置，包括存储器和处理器，其特征在于，所述存储器中存储有计算机程序，所述处理器被设置为运行所述计算机程序以执行所述权利要求1至5任一项中所述的方法。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202410735614.8A CN118316887B (zh) | 2024-06-07 | 2024-06-07 | 一种用于群发信息的流量浪涌消除方法及装置 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202410735614.8A CN118316887B (zh) | 2024-06-07 | 2024-06-07 | 一种用于群发信息的流量浪涌消除方法及装置 |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN118316887A CN118316887A (zh) | 2024-07-09 |
| CN118316887B true CN118316887B (zh) | 2024-09-17 |
Family
ID=91731467
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202410735614.8A Active CN118316887B (zh) | 2024-06-07 | 2024-06-07 | 一种用于群发信息的流量浪涌消除方法及装置 |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN118316887B (zh) |
Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101431734A (zh) * | 2008-11-07 | 2009-05-13 | 中兴通讯股份有限公司 | 一种短消息群发系统及方法 |
| CN103428008A (zh) * | 2013-08-28 | 2013-12-04 | 浙江大学 | 面向多用户群的大数据分发策略 |
Family Cites Families (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| ES2784239T3 (es) * | 2007-12-06 | 2020-09-23 | Difusión de avisos a una pluralidad de diversos dispositivos de comunicaciones | |
| US8706822B2 (en) * | 2010-06-23 | 2014-04-22 | Microsoft Corporation | Delivering messages from message sources to subscribing recipients |
| CN106921634B (zh) * | 2015-12-28 | 2020-11-20 | 中兴通讯股份有限公司 | 多媒体流组播方法和装置 |
| CN110798412B (zh) * | 2019-10-18 | 2023-05-23 | 北京浪潮数据技术有限公司 | 组播业务处理方法、装置、云平台、设备及可读存储介质 |
| CN114785749B (zh) * | 2022-04-14 | 2024-07-16 | 北京京东拓先科技有限公司 | 一种消息群发处理方法和装置 |
| CN115269111A (zh) * | 2022-06-13 | 2022-11-01 | 阿里巴巴（中国）有限公司 | 一种任务处理方法、系统、装置及可读介质 |
| CN117692401A (zh) * | 2022-09-09 | 2024-03-12 | 深圳市腾讯网络信息技术有限公司 | 消息发送方法、装置、服务器及存储介质 |
-
2024
- 2024-06-07 CN CN202410735614.8A patent/CN118316887B/zh active Active
Patent Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101431734A (zh) * | 2008-11-07 | 2009-05-13 | 中兴通讯股份有限公司 | 一种短消息群发系统及方法 |
| CN103428008A (zh) * | 2013-08-28 | 2013-12-04 | 浙江大学 | 面向多用户群的大数据分发策略 |
Also Published As
| Publication number | Publication date |
|---|---|
| CN118316887A (zh) | 2024-07-09 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN108256118B (zh) | 数据处理方法、装置、系统、计算设备以及存储介质 | |
| CN108737218B (zh) | 一种消息推送到达率的自动校验方法及装置 | |
| CN109450691B (zh) | 服务网关监控方法、设备及计算机可读存储介质 | |
| CN112559154B (zh) | 消息发送量增长的优化方法、系统、设备及可读存储介质 | |
| CN110674440A (zh) | 埋点数据处理方法、系统、计算机设备及可读存储介质 | |
| CN114095567B (zh) | 数据访问请求的处理方法、装置、计算机设备及介质 | |
| CN111246406A (zh) | 一种短信发送方法、系统、存储介质及终端设备 | |
| CN113259428A (zh) | 数据访问请求的处理方法、装置、计算机设备及介质 | |
| CN110333916B (zh) | 请求消息处理方法、装置、计算机系统及可读存储介质 | |
| CN112367345A (zh) | 数据处理方法、服务端设备及计算机可读存储介质 | |
| CN111666145A (zh) | 消息队列的消息处理方法、系统和计算机设备 | |
| CN109788251B (zh) | 视频处理方法、装置及存储介质 | |
| CN113055493B (zh) | 数据包处理方法、装置、系统、调度设备和存储介质 | |
| CN110209548B (zh) | 服务控制方法、系统、电子设备及计算机可读存储介质 | |
| CN118316887B (zh) | 一种用于群发信息的流量浪涌消除方法及装置 | |
| CN112988417B (zh) | 消息处理方法、装置、电子设备及计算机可读介质 | |
| CN113747506B (zh) | 一种资源调度方法、装置和网络系统 | |
| CN113965563B (zh) | 基于模型的业务处理方法及装置、服务器 | |
| CN114048059A (zh) | 接口的超时时间调整方法、装置、计算机设备及存储介质 | |
| CN110134547B (zh) | 一种基于中间件的重复数据删除方法和相关装置 | |
| CN112994976A (zh) | 一种网关测试方法、装置、电子设备及存储介质 | |
| CN110543470A (zh) | 消息预警的方法及装置、存储介质和电子装置 | |
| US20140359104A1 (en) | Grouping processing method and system | |
| CN112311765A (zh) | 一种报文检测方法及装置 | |
| CN110955579A (zh) | 一种基于Ambari的大数据平台的监测方法 |
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 |