[發(fā)明專利]一種消息處理方法、裝置及設(shè)備

在審

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

本發(fā)明實施例提供了一種消息處理方法、裝置及設(shè)備，其中，該方法包括確定關(guān)于消息生產(chǎn)階段的生產(chǎn)信息，確定關(guān)于消息存儲階段的存儲信息，以及確定關(guān)于消息消費階段的消費信息；其中，生產(chǎn)信息、存儲信息以及消費信息包括消息的消息標識；將生產(chǎn)信息、存儲信息和消費信息，存儲至指定的消息通道；其中，指定的消息通道與消息標識對應(yīng)；消息通道是消息系統(tǒng)中用于存儲消息的物理存儲。通過本發(fā)明實施例提供的消息處理方法、裝置及設(shè)備，能夠記錄消息生命周期中的信息，使得能夠根據(jù)記錄的這些信息，更加方便地在排障過程中進行排障，簡化排障過程。

技術(shù)領(lǐng)域

本發(fā)明涉及互聯(lián)網(wǎng)技術(shù)領(lǐng)域，特別是涉及一種消息處理方法、裝置及設(shè)備。

背景技術(shù)

消息系統(tǒng)因其傳統(tǒng)的功能特點：系統(tǒng)間調(diào)用的異步解耦、減低系統(tǒng)的復(fù)雜度、流量的削峰填谷，便于業(yè)務(wù)彈性伸縮、易于實現(xiàn)最終一致性系統(tǒng)，避免分布式事務(wù)對性能的影響、支持P2P(點對點的調(diào)用)和pub/sub(發(fā)布/訂閱)模式、減少RPC(Remote ProcedureCall Protocol，遠程過程調(diào)用協(xié)議)的多次調(diào)用)等。目前已經(jīng)廣泛使用于互聯(lián)網(wǎng)企業(yè)，各類業(yè)務(wù)系統(tǒng)都有它的身影。另外隨著業(yè)務(wù)的快速增長，企業(yè)內(nèi)部需要大量數(shù)據(jù)的同步傳輸，流式計算等應(yīng)用都需要非常穩(wěn)定高效的傳輸通道給予支持，消息系統(tǒng)在其中充當了重要的角色。

消息系統(tǒng)中對消息的處理過程，一般會涉及多個處理階段，如消息生產(chǎn)階段、消息消費階段；對應(yīng)地就會涉及多個處理方，如消息生產(chǎn)階段中的生產(chǎn)方，消息消費階段中的消費方，以及消息系統(tǒng)的服務(wù)端等等。如此，會使得消息處理過程出現(xiàn)故障時的排障過程比較復(fù)雜。

發(fā)明內(nèi)容

本發(fā)明實施例的目的在于提供一種消息處理方法、裝置及設(shè)備，以實現(xiàn)更加方便地在排障過程中進行排障，簡化排障過程。具體技術(shù)方案如下：

第一方面，本發(fā)明實施例提供了一種消息處理方法，包括：

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

將所述生產(chǎn)信息、所述存儲信息和所述消費信息，存儲至指定的消息通道；其中，所述指定的消息通道與所述消息標識對應(yīng)；所述消息通道是消息系統(tǒng)中用于存儲消息的物理存儲。

可選的，所述確定關(guān)于消息生產(chǎn)階段的生產(chǎn)信息，包括：

接收消息生產(chǎn)端發(fā)送的消息請求；所述消息請求包括消息生產(chǎn)端信息、發(fā)送所述消息的發(fā)送時間；

根據(jù)所述消息請求，確定所述生產(chǎn)信息；

所述確定關(guān)于所述消息存儲階段的存儲信息，包括：

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

所述確定關(guān)于所述消息消費階段的消費信息，包括：

接收消息消費端發(fā)送的關(guān)于所述消息消費情況的消費情況信息；所述消費情況信息包括所述消息的消費狀態(tài)和所述消息消費的耗時；

根據(jù)所述消費情況信息，確定所述消費信息。

可選的，所述生產(chǎn)信息、所述存儲信息和所述消費信息均包括所述消息的消息標識；

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

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

根據(jù)所述消息的消息標識，關(guān)聯(lián)所述生產(chǎn)信息、所述存儲信息和所述消費信息；

展示關(guān)聯(lián)后的所述生產(chǎn)信息、所述存儲信息和所述消費信息。