消息处理方法及设备

摘要

本发明提供一种消息处理方法和设备。其中消息处理方法，包括：预先建立N个用于存储消息的文件，并设置时间长度为T的时间片，其中，N为大于1的整数，T为大于0的任意时间长度；在下发消息的过程中，如果需要对消息进行存储，则将下发时间属于同一时间片的消息存储到同一文件中；当需要进行消息回读时，按照文件的读取顺序对文件中存储的消息进行批量回读；处理回读的消息。通过采用本实施例的技术方案，在存储的过程中不用创建索引，在回读的过程中也不用针对每条消息进行查询，实现了对消息的连续读和连续写，有效地提高了消息写操作和读操作的性能。能够同时有效地提高消息的写操作和读操作的性能。

主权项

1.一种消息处理方法，其特征在于，包括：预先建立N个用于存储消息的文件，并设置时间长度为T的时间片，其中，N为大于1的整数，T为大于0的任意时间长度；在下发消息的过程中，如果需要对消息进行存储，则将下发时间属于同一时间片的消息存储到同一文件中；当需要进行消息回读时，按照文件的读取顺序对文件中存储的消息进行批量回读；处理回读的消息；所述将下发时间属于同一时间片的消息存储到同一文件中包括：确定所述消息的下发时间与当前时刻的时间差t；根据所述时间差t、时间片长度T以及当前正在回读的文件位置确定存放所述消息的文件的位置；将所述消息存储至所述位置对应的文件中；其中，所述根据所述时间差t、时间片长度T以及当前正在回读的文件位置确定存放所述消息的文件的位置，具体包括：确定存放所述消息的文件的位置为当前正在回读的文件后的第j个文件，所述j通过公式计算得到；其中，K为对(t-2T)/(N×T)向下取整的整数，表示对t/T向下取整。