[發明專利]一種云平臺消息傳輸的管理系統及方法

在審

• 申請號: 201710096149.8
• 申請日: 2017-02-22
• 公開（公告）號: CN106878197A
• 公開（公告）日: 2017-06-20
• 發明（設計）人: 許陸丹;郭鋒
• 申請（專利權）人: 鄭州云海信息技術有限公司
• 主分類號: H04L12/863
• 分類號: H04L12/863;H04L12/803;H04L29/08
• 代理公司: 北京集佳知識產權代理有限公司11227
• 代理人: 羅滿

技術領域

本發明涉及通信管理領域，特別是涉及一種云平臺消息傳輸的管理系統及方法。

背景技術

隨著云技術的發展進步，云平臺也應運而生。而隨著應用的普及和業務量的大規模增長，對云平臺的消息管理提出了新的挑戰。

云平臺下的云消息一般可以由消息發送方即消息生產端生成，并將該消息發送至消息中間件；消息中間件繼而將該消息發送至指定的消息接收模塊即消息消費端；消息消費端可以對所接收到的消息進行相應處理。

但是，現有技術中的云平臺下的消息傳輸的可靠性較低，即消息在傳輸過程中，由于網絡故障以及其它原因，進而導致消息丟失。進一步地，云平臺下的消息傳輸的性能較低，即消息從消息生產端傳輸至消息消費端的用時較長，進而導致消息通信的性能較低。如何提高云平臺下消息通信的可靠性以及高效性是本領域亟待解決的問題。

發明內容

本發明的目的是提供一種云平臺消息傳輸的管理系統及方法，目的在于解決現有技術中云平臺下消息通信的可靠性以及高效性較低的問題。

為解決上述技術問題，本發明提供一種云平臺消息傳輸的管理系統，該系統包括：

消息發起模塊，用于生成消息并發送所述消息；

消息隊列管理模塊，用于接收所述消息發起模塊發送的所述消息，根據消息隊列內等待發送的消息數量，相應增減所述消息隊列，并將所述消息均衡分配存儲至預設消息隊列，發送所述消息；

消息接收模塊，用于接收所述消息隊列處理模塊發送的所述消息。

可選地，所述消息接收模塊還包括：

成功反饋單元，用于當消息處理成功時，向所述消息隊列管理模塊反饋成功指令，以使所述消息隊列管理模塊從所述消息隊列中刪除所述消息。

可選地，所述消息隊列管理模塊包括：

消息分發單元，用于根據各個相同類別的所述消息隊列內等待發送的消息數量，將所述消息發送至對應的所述消息接收模塊；

其中，所述消息對應多個所述消息接收模塊。

可選地，所述消息接收模塊還包括：

異常反饋單元，用于當消息處理異常時，向所述消息隊列管理模塊反饋異常指令。

可選地，所述消息隊列管理模塊還包括：

異常分發單元，用于當接收到所述消息接收模塊發送的所述異常指令時，將所述消息重新發送至不同所述消息接收模塊的另一消息接收模塊。

可選地，所述消息發起模塊還包括：

消息聲明單元，用于設定所述消息的接收者，并將所述消息進行持久化預設置。

可選地，所述管理系統基于高級消息隊列協議。

此外，本發明還提供了一種云平臺消息傳輸的管理方法，該方法包括：

消息發起模塊生成消息并發送所述消息；

消息隊列管理模塊接收所述消息發起模塊發送的所述消息，根據消息隊列內等待發送的消息數量，相應增減所述消息隊列，并將所述消息均衡分配存儲至預設消息隊列，發送所述消息；

消息接收模塊接收所述消息隊列處理模塊發送的所述消息。

可選地，還包括：

當消息處理成功時，所述消息接收模塊向所述消息隊列管理模塊反饋成功指令；

所述消息隊列管理模塊根據所述成功指令，從所述消息隊列中刪除所述消息。

可選地，還包括：

所述消息發送模塊設定所述消息的接收者，并將所述消息進行持久化預設置。

本發明所提供的一種云平臺消息傳輸的管理系統及方法，通過消息發起模塊生成消息并發送上述消息；消息隊列管理模塊接收上述消息發起模塊發送的上述消息，根據消息隊列內等待發送的消息數量，相應增減上述消息隊列，并將上述消息均衡分配存儲至預設消息隊列，發送上述消息；消息接收模塊接收上述消息隊列處理模塊發送的上述消息。消息隊列管理模塊根據各個消息隊列的負荷的高低，可以動態地增加或者是減少相應的消息隊列，以及將當前消息均衡分配存儲至到消息隊列中，保證消息及時地被傳輸至消息消費端。而將消息存儲至相應地消息隊列，保證消息在傳輸過程中不會丟失。可見，本申請有利于提高云平臺下消息傳輸的可靠性以及高效性。

附圖說明

為了更清楚的說明本發明實施例或現有技術的技術方案，下面將對實施例或現有技術描述中所需要使用的附圖作簡單的介紹，顯而易見地，下面描述中的附圖僅僅是本發明的一些實施例，對于本領域普通技術人員來講，在不付出創造性勞動的前提下，還可以根據這些附圖獲得其他的附圖。

圖1為本發明實施例所提供的云平臺消息傳輸管理系統的結構示意框圖；