[發明專利]將消息存儲至分布式文件系統的方法和裝置

在審

• 申請號: 201611249847.9
• 申請日: 2016-12-29
• 公開（公告）號: CN108255875A
• 公開（公告）日: 2018-07-06
• 發明（設計）人: 高志明
• 申請（專利權）人: 北京奇虎科技有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 北京市隆安律師事務所 11323
• 代理人: 權鮮枝;何立春

1.一種將消息存儲至分布式文件系統的方法，其中，所述消息為分布式消息系統中的消息，該方法包括：

在所述分布式文件系統的集群中部署消息存儲長時服務；

由所述消息存儲長時服務持續從所述分布式消息系統獲取待存儲的消息，以及根據所述待存儲消息的消息內容，確定所述待存儲消息在所述分布式文件系統中對應的存儲文件，在滿足消息存儲條件時，將所述存儲文件存儲至所述分布式文件系統的集群中。

2.如權利要求1所述的方法，其中，所述在所述分布式文件系統的集群中部署消息存儲長時服務還包括：

為所述消息存儲長時服務申請所述分布式文件系統的集群中的資源；所述資源包括：存儲資源；

所述將所述存儲文件存儲至所述分布式文件系統的集群中包括：將所述存儲文件存儲至申請到的存儲資源中。

3.如權利要求2所述的方法，其中，所述在所述分布式文件系統的集群中部署消息存儲長時服務包括：在所述分布式文件系統的資源調度器中部署消息存儲長時服務；

所述為所述消息存儲長時服務申請所述分布式文件系統的集群中的資源包括：為所述消息存儲長時服務向所述資源調度器申請所述分布式文件系統的集群中的資源。

4.如權利要求2所述的方法，其中，申請到的資源為一個或多個container；

該方法還包括：當所述消息存儲長時服務對任一container的使用觸發資源更換條件時，關閉所述container，為所述消息存儲長時服務申請替代該container的其他container。

5.如權利要求4所述的方法，其中，所述資源更換條件為如下中的任一種：

對當前container的利用時間達到預設的周期時間點；

在當前container中已寫入的消息達到預設條數。

6.一種將消息存儲至分布式文件系統的裝置，其中，所述消息為分布式消息系統中的消息，該裝置包括：

服務部署單元，適于在所述分布式文件系統的集群中部署消息存儲長時服務單元；

消息存儲長時服務單元，適于持續從所述分布式消息系統獲取待存儲的消息，以及根據所述待存儲消息的消息內容，確定所述待存儲消息在所述分布式文件系統中對應的存儲文件，在滿足消息存儲條件時，將所述存儲文件存儲至所述分布式文件系統的集群中。

7.如權利要求6所述的裝置，其中，

所述服務部署單元，還適于為所述消息存儲長時服務申請所述分布式文件系統的集群中的資源；所述資源包括：存儲資源；

所述消息存儲長時服務單元，適于將所述存儲文件存儲至申請到的存儲資源中。

8.如權利要求7所述的裝置，其中，

所述服務部署單元，適于在所述分布式文件系統的資源調度器中部署消息存儲長時服務；為所述消息存儲長時服務向所述資源調度器申請所述分布式文件系統的集群中的資源。

9.如權利要求7所述的裝置，其中，申請到的資源為一個或多個container；

所述服務部署單元，還適于在所述消息存儲長時服務對任一container的使用觸發資源更換條件時，關閉所述container，為所述消息存儲長時服務申請替代該container的其他container。

10.如權利要求9所述的裝置，其中，所述資源更換條件為如下中的任一種：

對當前container的利用時間達到預設的周期時間點；

在當前container中已寫入的消息達到預設條數。