CN119493673A 消息堆积量统计方法、装置、设备及存储介质 （杭州阿里云飞天信息技术有限公司）

质本申请提出一种消息堆积量统计方法、装间窗口中确定出需重新统计消息堆积量的第一前次统计时刻统计的各第二时间窗口的历史消2获取消息队列的当前消费位点，以及分别获取各时间窗口对对应的过期时间为所述消息队列中时间戳位于该时间窗口内的所有消基于当前统计时刻、所述当前消费位点以及各时间窗口的所述过基于前次统计时刻统计的各所述第二时间窗口的历史消息堆积量确定所述当前统计时刻与所述前次统计时刻之间的时间间隔将所述过期时间的最小值小于或等于所述时间间隔的时间窗口，所述将各时间窗口中除所述第一时间窗口外的时间窗口确定为所根据各所述第一时间窗口的起始时刻和结束时刻，确定时间戳基于各所述第一时间窗口内的消息的消息标识，重新统计各对各所述第二时间窗口的历史消息堆积量，以及重新统计的各所述第基于各所述第一时间窗口内的消息的消息标识，确定各所述第根据消息标识的生成规则和各所述第一时间窗口内的消息的确定所述新消息的时间戳是否达到当前时间窗口若是，则统计当前时间窗口的消息堆积量，存储统计的所在出现重新统计消息堆积量的第一时间窗口的情况下，将3在当前统计时刻用户重置消费位点的情况下，将重置的消费位点确定为当前消费位在当前统计时刻用户未重置消费位点的情况下，将未被消费的消息信息获取模块，用于获取消息队列的当时间窗口确定模块，用于基于当前统计时刻、所述当堆积量计算模块，用于基于前次统计时刻统计的各所述第二4称MQ)是指在两台计算机之间传输消息过程中保存消息的容器，在互联网技术存储方面得各时间窗口中确定出需重新统计消息堆积量的第一时间窗口及无需重新统计的第二时间各所述第一时间窗口对应的消息堆积量，计算当前统计时刻所述消息队列中的消息堆积56的过期时间、当前统计时刻及当前消费位点确定需要重新统计消息堆积量的第一时间窗7定格式进行编码。队列(Queue)是一种先进先出(FIFO)的数据结构。消息队列也(Message列支持消息过期特性的情况下，消息堆积量不仅与消息的生成数量和消息的消费数量有8定当前统计时刻消息队列中的消息堆积量，从而实现了一种低成本的消息堆积量统计方次统计消息队列整体堆积量的时间，各当前统计时刻与其前次统计时刻的时间差可以相9息进行管理。以执行主体为云平台为例，该消息堆积量统计方法可应用于如图3所示的场未被消费的消息中时间戳最早的消息对应的时刻确定窗口中确定出需重新统计消息堆积量的第一时间窗口及无刻所在的时间窗口也为第一时间窗口。本实施例还考虑到消息队列可能支持消息过期特定当前统计时刻与前次统计时刻之间的时间间隔，以及当前消费位点所在的目标时间窗中的消息是否有过期消息，将该时间间隔内具有过期消息的时间窗口确定为第一时间窗和第二时间窗口对应的消息堆积量，且第一时间窗口对应的消息堆积量需要重新进行统骤S32，基于各第一时间窗口内的消息的消息标识，重新统计各第一时间窗口的消息堆积时间戳，即记录格林威治时间1970年01月01日00时00分00秒(北京时间1970年01月01日08[0083]在实际应用中，生产者生成的各条消息均可具有一个唯一标识，即消息ID[0084]假设时间段为2022_10_0100:00:00～2022_10_0100:01:00，对应时间戳为了一条消息，则时间戳为1664553630000，假设机器ID为5，序列号为10，则消息ID=标时间窗口结束时刻对应的时间戳，即确定消费位点对应时间戳之后最近的一个结束时[0091]如上，确定了消费位点对应的时间戳和目标时间窗口结束时刻对应的时间戳之后确定当前的时间是否达到当前时间窗口的结束时刻，若达到当前时间窗口的结束时刻，定新消息的时间戳是否达到当前时间窗口的结束一实施例提供的消息堆积量统计方法，图11示出了该消息堆积量统计装置的一种示意图，堆积量统计方法出于相同的发明构思，至少能够实现消息堆积量统计方法相同的有益效机程序，所述处理器400运行所述计算机程序时执行本申请前述任一实施方式所提供的消少一个通信接口403(可以是有线或者无线)实现该装置网元与至少一个其他网元之间的通方法的各步骤可以通过处理器400中的硬件的集成逻辑电路或者软件形式的指令完成。上[0108]本申请实施例提供的电子设备与本申请实施例提供的消息堆积量统计方法出于[0109]本申请实施方式还提供一种与前述实施方式所提供的消息堆积量统计方法对应理器执行以实现权上述任一实施例所述的消息堆积量施例提供的消息堆积量统计方法出于相同的发明构思，具有与其存储的应用程序所采用、上面对本申请的示例性实施例的描述中，本申请的各个特征有时被一起分组到单个实施任何熟悉本技术领域的技术人员在本申请揭露的技