Message processing method and apparatus in distributed system

    公开(公告)号:US11886225B2

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

    申请号:US17568828

    申请日:2022-01-05

    Inventor: Xiaoqin Xie Kun Li

    CPC classification number: G06F9/546 G06F11/3476

    Abstract: In a message processing method, a message stream platform receives a plurality of log messages from a production platform, and the plurality of log messages are used to record information about a first service executed by the production platform. The message stream platform stores the plurality of log messages in a log file based on time segments. Then, the message stream platform may send messages in a same time segment in the plurality of log files to a consumption platform based on the time segment mark. According to the message processing method, the messages in the same time segment in the plurality of log files may be sent to the consumption platform to ensure that the consumption platform obtains the log messages generated in the same time segment.

Patent Agency Ranking