[發明專利]一種消息保序方法、網絡節點及存儲介質

有效

• 申請號: 201710468861.6
• 申請日: 2017-06-20
• 公開（公告）號: CN109104446B
• 公開（公告）日: 2022-04-15
• 發明（設計）人: 郭華
• 申請（專利權）人: 中興通訊股份有限公司
• 主分類號: H04L67/141
• 分類號: H04L67/141;H04L67/568;H04L67/566
• 代理公司: 深圳鼎合誠知識產權代理有限公司 44281
• 代理人: 薛祥輝

本發明公開了一種消息保序方法、網絡節點及存儲介質，屬于通訊技術領域。本發明實施例中方法包括：接收至少一個消息生產者生成的消息序列；按照預設的消息生產者、消息消費者及消息緩存分區的映射關系，將消息序列保存到對應的消息緩存分區，該映射關系中消息消費者數量小于等于消息緩存分區數量；從消息緩存分區將消息序列發送給對應的消息消費者進行消費。本發明實施例中通過消息緩存分區建立消息生產者和消息消費者之間的映射，實現消息有序、高效的處理，免了消息處理時的二次消費和競爭。

技術領域

本發明涉及通訊技術領域，尤其涉及一種消息保序方法、網絡節點及存儲介質。

背景技術

消息處理的模型是典型的生產者消費者模型，這是一個簡單的模型，但隨著消息處理規模的增加，消息處理模型演化為多消息生產者和多消息消費者，并引入了消息緩存，模型變得復雜。同時，當消息處理系統中出現對消息保序的要求(如監控系統)時，由于多消息消費者的存在，處理變得更加復雜。多消息生產者和多消息消費者場景下的消息保序，要求消息生產者A生產的消息序列abcde，按照同樣的序列被消息消費者消費，否則系統就會出錯。

解決的措施通常是在消息生產者和消息消費者之間有一個消息分發者，它負責把消息生產者生產的消息，按保序的要求分發給各消費者。還有一種做法是在多個消息消費者之間使用分布式鎖，消息消費者B和C在消費A生產的消息前，要先獲取鎖，只有獲取到的消息消費者才能夠消費。消費完之后釋放這個鎖，下一次消費前再次獲取。這就保證了消息生產者的消息在多個消息消費者之間是串行按序消費的。

無論上述哪種方式，都降低了系統中消息處理的效率。消息分發者要進行消息的二次消費，容易形成單點故障和瓶頸；分布式鎖的方式存在大量的競爭，在大型分布式系統中這些開銷都是不可忍受的。

發明內容

有鑒于此，本發明的目的在于提供一種消息保序方法、網絡節點及存儲介質，以解決目前消息處理系統中消息處理效率低、開銷大的問題。

本發明解決上述技術問題所采用的技術方案如下：

第一方面，本發明提供一種消息保序方法，該方法包括：

接收至少一個消息生產者生成的消息序列；

按照預設的消息生產者、消息消費者及消息緩存分區的映射關系，將所述消息序列保存到對應的消息緩存分區，所述映射關系中消息消費者數量小于等于消息緩存分區數量；

從所述消息緩存分區將所述消息序列發送給對應的消息消費者進行消費。

第二方面，本發明提供一種網絡節點，所述網絡節點包括處理器、存儲器及收發器，所述存儲器、所述收發器和所述處理器通過總線連接；

所述收發器用于接收至少一個消息生產者生成的消息序列；

所述處理器用于按照預設的消息生產者、消息消費者及消息緩存分區的映射關系，將所述消息序列保存到所述存儲器中對應的消息緩存分區，所述映射關系中消息消費者數量小于等于消息緩存分區數量；

所述收發器用于從所述消息緩存分區將所述消息序列發送給對應的消息消費者進行消費。

第三方面，本發明提供一種計算機可讀存儲介質，其上存儲有計算機程序，該程序被處理器執行時實現如上述第一方面中任一所述的方法。

本發明實施例中通過接收至少一個消息生產者生成的消息序列；按照預設的消息生產者、消息消費者及消息緩存分區的映射關系，將消息序列保存到對應的消息緩存分區；從消息緩存分區將消息序列發送給對應的消息消費者進行消費。本發明實施例中通過消息緩存分區建立消息生產者和消息消費者之間的映射，映射一旦建立就不需要第三方的介入，消息生產者和消息消費者借助這個映射關系可以實現消息有序、高效的處理，且由于映射關系中消息消費者數量小于等于消息緩存分區數量，保證了每個消息消費者都至少對應一個分區，避免了消息處理時的二次消費和競爭，提高了消息處理的效率。