[發明專利]一種消息的管理方法和系統

有效

• 申請號: 201811573289.0
• 申請日: 2018-12-21
• 公開（公告）號: CN109714409B
• 公開（公告）日: 2021-09-14
• 發明（設計）人: 劉剛;鄧偉偉;崔陽;鞏仔明;邱慧
• 申請（專利權）人: 優估（上海）信息科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/863;H04L1/18
• 代理公司: 北京華智則銘知識產權代理有限公司 11573
• 代理人: 王昌貴

1.一種消息的管理方法，其特征在于，所述方法包括：

消息管理后臺接收消息發送端發送的消息，將所述消息存儲在所述消息對應的隊列中，并在所述隊列對應的至少一個隊列服務器中確定傳遞所述消息的目標隊列服務器；

所述消息管理后臺生成預設配置文件，所述預設配置文件至少包括進程數量及回調地址；

所述每個隊列服務器部署服務注冊通知節點，以感知配置文件的變更；

所述預設配置文件由所述消息管理后臺發送至各個隊列服務器或由隊列服務器收到服務注冊通知節點的通知時去所述消息管理后臺處獲取；

所述目標隊列服務器從所述隊列中獲取所述消息，并基于所述預設配置文件，在所述目標隊列服務器的多個進程中確定傳遞所屬消息的目標進程，所述目標進程基于所述回調地址將所述消息傳遞至消息接收端，并指示所述消息管理后臺將所述消息從所述隊列中刪除；

如果所述目標隊列服務器檢測到所述消息傳遞失敗，則將所述消息進行落地存儲，并按照預設重發機制對所述消息進行重新傳遞。

2.根據權利要求1所述的方法，其特征在于，所述在所述隊列對應的至少一個隊列服務器中確定傳遞所述消息的目標隊列服務器，包括：

所述消息管理后臺計算所述隊列對應的各個隊列服務器的負載度，將所述負載度最低的隊列服務器確定為傳遞所述消息的目標隊列服務器。

3.根據權利要求1所述的方法，其特征在于，所述按照預設重發機制對所述消息進行重新傳遞，包括：

所述目標隊列服務器每隔預設周期，對所述消息進行重新傳遞；

如果所述目標隊列服務器對所述消息進行重新傳遞的次數超過預設次數，則停止對所述消息進行重新傳遞，并按照預設通信方式向管理員發送對所述消息的告警信息。

4.根據權利要求1-3任一項所述的方法，其特征在于，所述方法還包括：

如果所述消息管理后臺接收到修改命令，則將基于所述修改命令更新的預設配置文件推送至各個隊列服務器；

各個所述隊列服務器的進程管理器基于更新后的預設配置文件進行進程配置。

5.一種消息的管理系統，其特征在于，所述系統包括消息管理后臺和消息隊列集群，所述消息隊列集群包括至少一個隊列服務器，其中：

所述消息管理后臺，用于接收消息發送端發送的消息，將所述消息存儲在所述消息對應的隊列中，并在所述隊列對應的至少一個所述隊列服務器中確定傳遞所述消息的目標隊列服務器；

所述消息管理后臺生成預設配置文件，所述預設配置文件至少包括進程數量及回調地址；

所述每個隊列服務器部署服務注冊通知節點，以感知配置文件的變更；

所述預設配置文件由所述消息管理后臺發送至各個隊列服務器或由隊列服務器收到服務注冊通知節點的通知時去所述消息管理后臺處獲取；

所述目標隊列服務器，用于從所述隊列中獲取所述消息，并基于所述預設配置文件，在所述目標隊列服務器的多個進程中確定傳遞所屬消息的目標進程，所述目標進程基于所述回調地址將所述消息傳遞至消息接收端，并指示所述消息管理后臺將所述消息從所述隊列中刪除；

所述目標隊列服務器，還用于如果檢測到所述消息傳遞失敗，則將所述消息進行落地存儲，并按照預設重發機制對所述消息進行重新傳遞。

6.根據權利要求5所述的系統，其特征在于，所述消息管理后臺，還用于：

計算所述隊列對應的各個隊列服務器的負載度，將所述負載度最低的隊列服務器確定為傳遞所述消息的目標隊列服務器。

7.根據權利要求5所述的系統，其特征在于，所述目標隊列服務器，還用于：

每隔預設周期，對所述消息進行重新傳遞；

如果對所述消息進行重新傳遞的次數超過預設次數，則停止對所述消息進行重新傳遞，并按照預設通信方式向管理員發送對所述消息的告警信息。

8.根據權利要求5-7任一項所述的系統，其特征在于，所述隊列服務器還包括進程管理器；

所述消息管理后臺，還用于如果接收到修改命令，則將基于所述修改命令更新的預設配置文件推送至各個隊列服務器；

所述進程管理器，用于基于更新后的預設配置文件進行進程配置。