[發明專利]分布式消息系統

有效

• 申請號: 201810014768.2
• 申請日: 2018-01-08
• 公開（公告）號: CN110022257B
• 公開（公告）日: 2023-04-07
• 發明（設計）人: 卞詠梅
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: H04L51/00
• 分類號: H04L51/00;H04L67/1097;H04L67/568;H04L43/08;H04L41/0663;G06F3/06
• 代理公司: 北京律智知識產權代理有限公司 11438
• 代理人: 邢雪紅;王衛忠

本公開涉及分布式數據技術領域，提供一種分布式消息系統，包括：數據庫，用于存儲消息的配置參數；多個消息應用服務器，用于根據請求方的消息請求和配置參數產生消息并發送給請求方；配置服務端，用于當數據庫更新時，向所有消息應用服務器下發數據庫更新通知，以使消息應用服務器從數據庫讀取更新的配置參數并寫入消息應用服務器本地緩存中；其中消息應用服務器產生消息時從本地緩存中讀取相應的配置參數。本公開設計了一套支持高并發的高可用緩存系統，通過配置服務端動態下發數據庫更新通知給所有消息應用服務器并觸發服務器自動重新加載數據庫配置到本地緩存，避免了應用重啟帶來的諸多問題，提高系統可用性。

技術領域

本公開涉及分布式數據技術領域，具體涉及一種分布式消息系統。

背景技術

在消息推送技術問世之前，消息服務器給用戶推送的消息只能等待用戶主動拉取才能看到，為了提高用戶活躍度、用戶粘性及用戶留存率，消息服務端尤其是移動設備的消息服務端需要獲取消息展示的主動權，而不是被動地等待用戶拉取消息。消息推送機制應運而生。運營人員通過自己的產品或第三方工具對用戶移動設備主動推送消息，用戶可以在移動設備屏幕鎖定狀態和通知欄看到消息服務器推送的消息通知，用戶點擊通知欄消息可喚起APP并跳轉到相應的頁面。平時在鎖屏時看到的微信消息QQ消息等均屬于移動端消息推送行列。

消息中心目前接入的消息多達一百多種。而之前消息中心系統架構并沒有將每種消息對應的必需參數配置在配置文件或數據庫中而是耦合在代碼中。這導致每接入一種新消息不僅服務端要添加與新消息相關的參數校驗，客戶端也要根據服務端返回的消息的類型來區分消息，校驗必需參數，添加相應的業務邏輯。所以每次接入新消息不僅服務端要修改代碼，還必須和客戶端發版周期一致。

為了解決這個問題，現有技術中的實現方案大部分是直接將配置參數配置在數據庫中，但是每次讀取數據庫都涉及網絡IO和磁盤IO，在高并發時對系統性能影響較大。尤其在修改數據庫配置后，如果通過手動重啟應用服務器以讓應用服務器讀取更新后的數據庫配置，因重啟時服務器相當于處于短暫的宕機狀態，故嚴重影響系統可用性。

因此，需要一種支持高并發且高可用的分布式消息系統。

在所述背景技術部分公開的上述信息僅用于加強對本公開的背景的理解，因此它可以包括不構成對本領域普通技術人員已知的現有技術的信息。

發明內容

本公開的目的在于提供一種分布式消息系統，進而至少在一定程度上克服由于相關技術的限制和缺陷而導致的一個或者多個問題。

本公開的其他特性和優點將通過下面的詳細描述變得顯然，或部分地通過本公開的實踐而習得。

根據本公開的一實施方式，公開一種分布式消息系統，包括：

數據庫，用于存儲消息的配置參數；

多個消息應用服務器，用于根據請求方的消息請求和配置參數產生消息并發送給請求方；

配置服務端，用于當數據庫更新時，向所有消息應用服務器下發數據庫更新通知，以使消息應用服務器從數據庫讀取更新的配置參數并寫入消息應用服務器本地緩存中；

其中消息應用服務器產生消息時從本地緩存中讀取相應的配置參數。

根據本公開的一示例實施方式，當消息應用服務器的消息應用程序啟動時，消息應用服務器從數據庫讀取配置參數并寫入消息應用服務器本地緩存中。

根據本公開的一示例實施方式，將消息劃分為不同的消息類別，相同類別的消息采用相同的配置參數。

根據本公開的一示例實施方式，建立與消息類別對應的消息模板，消息應用服務器采用與消息請求所屬的消息類別對應的消息模板產生消息。