[發明專利]一種消息持久化方法、服務器和計算機可讀存儲介質

有效

• 申請號: 201710960149.8
• 申請日: 2017-10-16
• 公開（公告）號: CN107704329B
• 公開（公告）日: 2020-07-14
• 發明（設計）人: 陳宇珽;許再越;熊璐;李正;茅廷;余波;李升先;李志斌
• 申請（專利權）人: 中匯信息技術（上海）有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;H04L29/08
• 代理公司: 北京睿派知識產權代理事務所(普通合伙) 11597
• 代理人: 劉鋒

1.一種消息持久化方法，包括：

接收需要持久化的消息后，獲取所述消息所屬的消息主題；

將所述消息存儲在所述消息主題對應的數據文件中；

定時更新消息索引文件，建立所述消息對應的消息索引記錄，所述消息索引文件包括索引頭和消息索引記錄；以及

在時間索引文件中，每隔單位時間生成一條時間索引記錄；

其中，所述消息索引文件和所述時間索引文件是在預先設定的時間點創建的；所述索引頭包括參考時間戳，所述參考時間戳對應的參考時間作為存儲消息時間點的參考；所述消息索引記錄包括對應的數據文件標識、所述消息在所述數據文件中的偏移地址和相對時間戳，所述相對時間戳是存儲消息時間點相對所述參考時間而得到的；所述時間索引記錄用于存儲在當前單位時間內存儲的第一條消息對應的消息索引記錄在所述消息索引文件中的偏移地址，其中，所述相對時間戳的時間精度大于所述單位時間。

2.根據權利要求1所述的消息持久化方法，其特征在于，所述方法還包括：

在接收到讀取指定時間段內消息的指令時根據所述時間索引文件和所述消息索引文件索引并讀取對應數據文件中對應的消息。

3.根據權利要求2所述的消息持久化方法，其特征在于，根據所述時間索引文件和所述消息索引文件索引并讀取對應數據文件中對應的消息包括：

根據所述參考時間戳獲取所述指定時間段的相對起始單位時間和相對結束單位時間；

根據所述相對起始單位時間和所述時間索引文件索引獲取第一消息索引記錄的偏移地址；

根據所述相對結束單位時間和所述時間索引文件索引獲取第二消息索引記錄的偏移地址；

在所述消息索引文件中獲取所述第一消息索引記錄的偏移地址和第二消息索引記錄的偏移地址之間的所有消息索引記錄；

根據所獲取的消息索引記錄讀取對應的數據文件獲得指定時間段的所有消息；

其中，根據所述第一消息索引記錄的偏移地址依次加上一條消息索引記錄的字節長度值直到得到所述第二消息索引記錄的偏移地址可依次獲取指定時間段內所有的消息索引記錄的偏移地址。

4.根據權利要求3所述的消息持久化方法，其特征在于，根據所述相對起始單位時間和所述時間索引文件索引獲取第一消息索引記錄的偏移地址包括：

計算第一時間索引記錄在所述時間索引文件中的偏移地址；

根據所獲得的所述第一時間索引記錄的偏移地址查詢所述第一時間索引記錄獲取所述第一消息索引記錄的偏移地址；

其中，所述第一時間索引記錄為相對起始單位時間對應的時間索引記錄；所述第一時間索引記錄的偏移地址是所述相對起始單位時間的數值乘以時間索引記錄的長度值。

5.根據權利要求3所述的消息持久化方法，其特征在于，根據所述相對結束單位時間和所述時間索引文件索引獲取第二消息索引記錄的偏移地址包括：

計算第二時間索引記錄在所述時間索引文件中的偏移地址；

根據所獲得的所述第二時間索引記錄的偏移地址查詢所述第二時間索引記錄獲取中間偏移地址；

將所述中間偏移地址減去消息索引記錄的字節長度值從而獲得所述第二消息索引記錄的偏移地址；

其中，所述第二時間索引記錄為相對結束時間的下一單位時間對應的時間索引記錄；所述第二時間索引記錄的偏移地址是所述相對結束單位時間的數值加上1后再乘以時間索引記錄的長度值。

6.根據權利要求1所述的消息持久化方法，其特征在于，每個消息主題對應一個所述時間索引文件、一個所述消息索引文件和至少一個所述數據文件。

7.根據權利要求1所述的消息持久化方法，其特征在于，所述方法還包括：

創建第一個數據文件，所述第一個數據文件在預先設定的時間點創建和/或在存儲此消息主題的第一條消息時創建；

在所述數據文件大小達到預定的閾值時，創建新的數據文件。