[發明專利]一種消息處理的方法、裝置、電子設備及存儲介質

有效

• 申請號: 202110059422.6
• 申請日: 2021-01-18
• 公開（公告）號: CN112380040B
• 公開（公告）日: 2021-05-07
• 發明（設計）人: 李磊
• 申請（專利權）人: 北京美攝網絡科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/50
• 代理公司: 北京潤澤恒知識產權代理有限公司 11319
• 代理人: 莎日娜

1.一種消息處理的方法，其特征在于，應用于視頻云編輯軟件中的服務器端架構，所述方法包括：

基于go語言，分別編譯接口Dockers的接口和功能Dockers的接口；

所述接口Dockers通過所述接口Dockers的接口，接收多個待處理的消息；其中，每個所述待處理的消息攜帶標簽；

所述接口Dockers將多個所述消息分配至多個不同的接口服務器；

每個所述接口服務器將所述消息轉換成kafka消息；

每個所述接口服務器根據所述消息的標簽，將所述kafka消息發送至與所述標簽對應的所述功能Dockers；

所述功能Dockers的接口接收所述多個不同的接口服務器各自發送的所述kafka消息，并根據所述kafka消息執行相應的操作；

其中，當所述功能Dockers為任務Dockers時，所述任務Dockers中設有多個任務服務器，并且每個任務服務器設有kafka，所述任務Dockers包括任務隊列，所述任務隊列用于存儲未處理的kafka消息；所述功能Dockers的接口接收所述多個不同的接口服務器各自發送的所述kafka消息，并根據所述kafka消息執行相應的操作，包括：

所述任務Dockers的接口，接收所述多個不同的接口服務器各自發送的所述kafka消息；

檢測任務Dockers中是否有空閑的任務服務器；

若有空閑的任務服務器，則任務Dockers將接收的多個所述kafka消息發送至空閑的任務服務器；

若無空閑的任務服務器，則任務Dockers將接收的多個所述kafka消息發送至任務隊列中；

每個所述任務服務器根據各自接收的kafka消息，執行與所述kafka消息對應的任務工程。

2.根據權利要求1所述的方法，其特征在于，在所述接收多個待處理的消息之前，所述方法還包括：

服務器端接收客戶端發送的登錄請求；

根據所述登錄請求，所述服務器端基于JWT生成特定的token，并將所述token返回給所述客戶端。

3.根據權利要求2所述的方法，其特征在于，所述待處理的消息包括消息請求頭，所述消息請求頭攜帶token；

所述接口Dockers通過所述接口Dockers的接收接口，接收待處理的消息，包括：

所述客戶端將接收的所述token添加至待處理的消息的請求頭中，并將攜帶有所述token的待處理的消息發送給所述接口Dockers；

所述接口Dockers根據所述token，驗證所述客戶端是否為發送登錄請求的客戶端；

若是，所述接口Dockers通過所述接口Dockers的接收接口，接收所述待處理的消息。

4.根據權利要求1所述的方法，其特征在于，所述接口Dockers包括多個接口服務器，并且每個接口服務器設有kafka，所述接口Dockers將多個所述消息分配至多個不同的接口服務器，包括：

基于k8s，所述接口Dockers根據每個所述待處理的消息攜帶的標簽，將多個所述消息發送至與所述標簽對應的接口服務器的kafka中。

5.根據權利要求1所述的方法，其特征在于，所述任務Dockers包括任務隊列，所述任務隊列用于存儲未處理的kafka消息，在每個所述任務服務器根據各自接收的kafka消息，執行與所述kafka消息對應的任務工程之后，所述方法還包括：

執行任務工程的任務服務器向所述任務Dockers發送消息處理結束信息；

所述任務Dockers接收到所述消息處理結束信息后，查詢所述任務隊列中是否存儲有未處理的kafka消息；

若有未處理的kafka消息，則所述任務Dockers將所述未處理的kafka消息，分配至所述執行任務工程的任務服務器；

所述執行任務工程的任務服務器執行與所述未處理的kafka消息對應的任務工程。