本發明公開了一種消息監聽方法、裝置、設備及存儲介質。其中，方法包括：通知接收端從中間件中獲取協調系統zookeeper目錄；通知接收端根據協調系統zookeeper目錄，訂閱與通知接收端匹配的目標通知發送端的消息監聽服務，并從中間件中獲取預設的監聽公共組件、以及目標通知發送端的文件發布服務列表；通知接收端根據監聽公共組件和文件發布服務列表進行系統配置，通過監聽公共組件監聽協調系統zookeeper目錄中與目標通知發送端對應的文件更新消息。本發明實施例可以讓通知接收端根據業務需求訂閱消息監聽服務，通過監聽公共組件持續監聽協調系統zookeeper目錄中與目標通知發送端對應的文件更新消息。

技術領域

本發明實施例涉及計算機技術領域，尤其涉及一種消息監聽方法、裝置、設備及存儲介質。

背景技術

分布式系統的可靠協調系統zookeeper是一個分布式的，開放源碼的分布式應用程序協調服務，是一個為分布式應用提供一致性服務的軟件。zookeeper主要是為了統一分布式系統中各個節點的工作狀態，在資源沖突的情況下協調提供節點資源搶占，提供給每個節點了解整個集群所處狀態的途徑。這一切的實現都依賴于zookeeper中的事件監聽機制。

現有技術中，zookeeper中的事件監聽機制只是一種簡單的單向監聽，且有監聽真空期。如圖1a所示，通知接收端向zookeeper服務端注冊一個監視事件watcher，用于監測通知發送端是否有文件發生變化。當通知發送端有文件發生變化時，zookeeper服務端會向通知接收端進行單向通知：通知發送端有文件發生變化，以使通知接收端可以進行相應的文件更新。

zookeeper中的事件監聽機制存在以下的缺陷：每一次監聽都需要通知接收端向zookeeper服務端注冊watcher，無法做到一次注冊，多次監聽；對于zookeeper服務端上的監視事件watcher沒有進行封裝，導致每增加一個監視事件watcher，就會重寫一遍監聽代碼，造成資源浪費。

發明內容

本發明提供一種消息監聽方法、裝置、設備及存儲介質，以實現對zookeeper中的事件監聽機制進行優化，讓通知接收端根據業務需求持續監聽協調系統zookeeper目錄中與目標通知發送端對應的文件更新消息。

第一方面，本發明實施例提供了一種消息監聽方法，包括：

通知接收端從中間件中獲取協調系統zookeeper目錄；

通知接收端根據協調系統zookeeper目錄，訂閱與通知接收端匹配的目標通知發送端的消息監聽服務，并從中間件中獲取預設的監聽公共組件、以及目標通知發送端的文件發布服務列表；

通知接收端根據監聽公共組件和文件發布服務列表進行系統配置，通過監聽公共組件監聽協調系統zookeeper目錄中與目標通知發送端對應的文件更新消息。

第二方面，本發明實施例還提供了一種消息監聽裝置，包括：

列表獲取模塊，用于從中間件中獲取協調系統zookeeper目錄；

服務訂閱模塊，用于根據協調系統zookeeper目錄，訂閱與通知接收端匹配的目標通知發送端的消息監聽服務，并從中間件中獲取預設的監聽公共組件、以及目標通知發送端的文件發布服務列表；

消息監聽模塊，用于根據監聽公共組件和文件發布服務列表進行系統配置，通過監聽公共組件監聽協調系統zookeeper目錄中與目標通知發送端對應的文件更新消息。

第三方面，本發明實施例還提供了一種計算機設備，所述計算機設備包括：

一個或多個處理器；

存儲裝置，用于存儲一個或多個程序；

當所述一個或多個程序被所述一個或多個處理器執行，使得所述一個或多個處理器實現本發明任意實施例所提供的消息監聽方法。