消息中间件系统及消息处理方法
    1.
    发明公开

    公开(公告)号:CN118885310A

    公开(公告)日:2024-11-01

    申请号:CN202411050059.1

    申请日:2024-07-31

    Inventor: 林鑫 陈宇涛

    Abstract: 本说明书一个或多个实施例提供一种消息中间件系统及消息处理方法。所述消息中间件系统中部署有计算模块,所述计算模块用于在接收消息流中消息的过程中按照预设大小对消息流进行消息段的划分,所述计算模块用于判断接收到的目标消息和所述目标消息所属的目标消息流的当前消息段的总大小是否超过所述预设大小;在所述总大小超过所述预设大小的情况下,开始新消息段的划分,并确定所述目标消息归属于新消息段,以及确定所述新消息段对应的存储设备,并将所述目标消息发送至确定的存储设备进行存储;在所述总大小未超过所述预设大小的情况下,确定所述目标消息归属于所述当前消息段,并将所述目标消息发送至所述当前消息段对应的存储设备进行存储。

Patent Agency Ranking