[發明專利]一種消息處理方法、裝置及設備

在審

• 申請號: 201811452054.6
• 申請日: 2018-11-30
• 公開（公告）號: CN109688200A
• 公開（公告）日: 2019-04-26
• 發明（設計）人: 馮浩;虞開元
• 申請（專利權）人: 北京奇藝世紀科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京柏杉松知識產權代理事務所(普通合伙) 11413
• 代理人: 丁蕓;項京

1.一種消息處理方法，其特征在于，包括：

確定關于消息生產階段的生產信息，確定關于所述消息存儲階段的存儲信息，以及確定關于所述消息消費階段的消費信息；其中，所述生產信息、所述存儲信息以及所述消費信息包括所述消息的消息標識；

將所述生產信息、所述存儲信息和所述消費信息，存儲至指定的消息通道；其中，所述指定的消息通道與所述消息標識對應；所述消息通道是消息系統中用于存儲消息的物理存儲。

2.根據權利要求1所述的方法，其特征在于，所述確定關于消息生產階段的生產信息，包括：

接收消息生產端發送的消息請求；所述消息請求包括消息生產端信息、發送所述消息的發送時間；

根據所述消息請求，確定所述生產信息；

所述確定關于所述消息存儲階段的存儲信息，包括：

保存所述消息請求，并確定所述存儲信息；所述存儲信息包括所述消息標識和保存所述消息的存儲時間；

所述確定關于所述消息消費階段的消費信息，包括：

接收消息消費端發送的關于所述消息消費情況的消費情況信息；所述消費情況信息包括所述消息的消費狀態和所述消息消費的耗時；

根據所述消費情況信息，確定所述消費信息。

3.根據權利要求1所述的方法，其特征在于，所述生產信息、所述存儲信息和所述消費信息均包括所述消息的消息標識；

在所述將所述生產信息、所述存儲信息和所述消費信息，存儲至指定的消息通道之后，所述方法還包括：

從所述指定的消息通道中，獲取所述生產信息、所述存儲信息以及所述消費信息；

根據所述消息的消息標識，關聯所述生產信息、所述存儲信息和所述消費信息；

展示關聯后的所述生產信息、所述存儲信息和所述消費信息。

4.根據權利要求2所述的方法，其特征在于，所述接收消息生產端發送的消息請求，包括：

通過預先封裝的軟件開發工具包SDK，接收所述消息請求；

所述接收消息消費端發送的關于所述消息消費情況的消費情況信息，包括：

通過預先封裝的軟件開發工具包SDK，接收所述消費情況信息。

5.根據權利要求1至4任一項所述的方法，其特征在于，所述消息系統包括開源系統RocektMQ，所述消息通道包括Commit Log。

6.一種消息處理裝置，其特征在于，包括：

確定模塊，用于確定關于消息生產階段的生產信息，確定關于所述消息存儲階段的存儲信息，以及確定關于所述消息消費階段的消費信息；其中，所述生產信息、所述存儲信息以及所述消費信息包括所述消息的消息標識；

存儲模塊，用于將所述生產信息、所述存儲信息和所述消費信息，存儲至指定的消息通道；其中，所述指定的消息通道與所述消息標識對應；所述消息通道是消息系統中用于存儲消息的物理存儲。

7.根據權利要求6所述的裝置，其特征在于，所述確定模塊，包括：

第一接收子模塊，用于接收消息生產端發送的消息請求；所述消息請求包括消息生產端信息、發送所述消息的發送時間；

第一確定子模塊，用于根據所述消息請求，確定所述生產信息；

保存子模塊，用于保存所述消息請求；

第二確定子模塊，用于確定所述存儲信息；所述存儲信息包括所述消息標識和保存所述消息的存儲時間；

第二接收子模塊，用于接收消息消費端發送的關于所述消息消費情況的消費情況信息；所述消費情況信息包括所述消息的消費狀態和所述消息消費的耗時；

第三確定子模塊，用于根據所述消費情況信息，確定所述消費信息。