[發明專利]一種基于消息隊列順序回復的實現方法和裝置

有效

• 申請號: 201711046688.7
• 申請日: 2017-10-31
• 公開（公告）號: CN107613025B
• 公開（公告）日: 2021-01-08
• 發明（設計）人: 夏淵;陳志;余春平;卜勤練
• 申請（專利權）人: 武漢光迅科技股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;G06F9/54
• 代理公司: 深圳市愛迪森知識產權代理事務所(普通合伙) 44341
• 代理人: 何婷

本發明涉及順序消息隊列收發技術領域，提供了一種基于消息隊列順序回復的實現方法和裝置。其中方法包括分發服務器在接收到客戶端的請求消息后，將請求消息拆分出一組順序排列的指令隊列；根據維護的子服務器列表，按照各子服務器所完成指令隊列中各條指令的歷史時間長度，分配指令隊列中的各指令，使得各條指令被各子服務器所執行完成的總時長最短；分發服務器在接收到各子服務器的處理結果后，按照對應指令順序組合處理結果得到響應消息。本發明提供了分配任務機制，使得請求消息可以被拆分成多條指令，并且根據歷史訓練得到的各子服務器處理對應指令的時間，計算出完成當前請求消息的最優指令分配方式，從而提高了現有系統中請求消息處理效率。

【技術領域】

本發明涉及順序消息隊列收發技術領域，特別是涉及一種基于消息隊列順序回復的實現方法和裝置。

【背景技術】

在網絡通信中，比較常見的一種方式就是客戶端(Client)/服務器(Server)通信方式(通常簡稱C/S模式，區別于瀏覽器B/S模式),服務器端提供各種各樣的服務(比如數據庫查詢，FTP文件下載等服務)，客戶端向服務器請求需要的服務。這種方式的特點是，客戶端向服務器發出請求，并等待服務器應答。在實際應用中，存在這樣一種場景，客戶端向我們的服務器請求服務，而我們的服務器需要向其他分布式服務器查詢數據，網絡模型如圖1所示。

圖1中，我們將和客戶端直接交互的服務器稱為分發器(Distributor),簡稱dist,因為它的作用就是轉發指令給后臺的服務器，并把后臺服務器的應答返回給客戶，后臺的服務器Server1,Server2,…ServerN則是提供具體的服務。

在這種場景中，分布式服務器對不同指令的響應時間都不一樣，有的指令處理邏輯復雜比較耗時，有的指令則是簡單的查詢比較快速，這樣就會出現指令應答的順序和發送的順序不一致。比如客戶端順序發送了3條指令A，B，C給服務器dist,dist再將依次將指令A,B,C分發給后臺的服務器，由于A指令比較耗時，B指令比較快速，則會出現dist收到了B，A，C指令的應答，然后回復給了客戶端,客戶收到了B,A,C應答。發明人發現，順序建立指令的應答，并反饋通過與請求消息中的請求內容順序相對應的響應內容，所構建的響應消息是保證操作人員能夠有效識別響應消息的必要條件。這樣一來便涉及響應消息的有序組合，那么現有技術中僅參考子服務器是否處于空閑，來進行指令的分發，有可能造成整個請求消息所對應的響應消息反饋的延時。

【發明內容】

本發明要解決的技術問題是現有技術中為了實現響應消息的準確可讀性，便會涉及響應消息的有序組合，那么現有技術中僅參考子服務器是否處于空閑，來進行指令的分發，有可能造成整個請求消息所對應的響應消息反饋的延時。

本發明采用如下技術方案：

第一方面，本發明提供了一種基于消息隊列順序回復的實現方法，分發服務器回復給客戶端的響應內容，按照分發服務器所接收到的指令隊列順序排列，實現方法包括：

分發服務器在接收到客戶端的請求消息后，將所述請求消息拆分出一組順序排列的指令隊列；

根據維護的子服務器列表，按照各子服務器所完成指令隊列中各條指令的歷史時間長度，分配所述指令隊列中的各指令，使得各條指令被各子服務器所執行完成的總時長最短；

分發服務器在接收到各子服務器的處理結果后，按照對應指令順序組合處理結果得到響應消息，并發送給客戶端。

優選的，所述實現方法還包括：

確認分發服務器所能接收到的各種請求消息；并確定所述各種請求消息所能拆分出的指令隊列，其中，指令隊列中每一隊列成員的指令在經過子服務器處理后，反饋處理結果給分發服務器；

將各子服務器完成各指令隊列中相應隊列成員所各自使用時間進行登記，從而使得分發服務器對應于每一條指令，在其管理的各子服務器中所需的處理時間建立統一的維護。