[發明專利]高并發業務請求處理方法

無效

• 申請號: 201110176960.X
• 申請日: 2011-06-28
• 公開（公告）號: CN102291324A
• 公開（公告）日: 2011-12-21
• 發明（設計）人: 鞠進步;高磊
• 申請（專利權）人: 北京神州泰岳軟件股份有限公司
• 主分類號: H04L12/58
• 分類號: H04L12/58;H04L29/06
• 代理公司: 北京路浩知識產權代理有限公司 11002
• 代理人: 王瑩

技術領域

本發明涉及即時通訊技術領域，特別涉及一種高并發業務請求處理方法。

背景技術

隨著IM(InstantMessaging，即時通訊)用戶規模的增多，IM業務內的業務請求數量越來越多，并且業務請求的發起頻率也不均勻。如果每來一個業務請求就進行一次網絡處理，效率比較低，并且在業務請求突增(比如早上上班時間大量用戶登錄或者服務器重啟后會有大量用戶重新連接服務器，這些都會造成請求突增)的情況下故障率也比較高。

面對這個問題，通常的解決方案是建立一個消息隊列，然后后臺一個請求一個請求的處理這些業務請求。這個解決方案，雖然將業務請求的處理轉移到了后臺，但實質上針對每一個業務請求還是需要發送一次網絡請求。因此，面對大業務量的業務請求，處理請求的效率依然很低，并且占用較多的客戶端和服務器的內存。

發明內容

(一)要解決的技術問題

本發明要解決的技術問題是：如何提供一種高并發業務請求處理方法，以提高對業務請求的處理效率，節省客戶端和服務器內存。

(二)技術方案

為解決上述技術問題，本發明提供一種高并發業務請求處理方法，其包括步驟：

A：將業務請求和目的IP壓入客戶端的分組消息隊列；

B：根據所述目的IP，將所述業務請求壓入所述分組消息隊列的數據存儲模塊的子消息隊列中；

C：將所述子消息隊列中的多個業務請求，在所述分組消息隊列的網絡處理模塊中，合并成一個網絡請求后發送給所述目的IP對應的服務器。

優選地，所述數據存儲模塊包括以散列表實現地一組分組對象。

優選地，所述分組對象包含鍵值IP和所述子消息隊列。

優選地，所述步驟B具體包括以下步驟：

B1：判斷是否存在一個分組對象的鍵值IP與所述目的IP一致，如果存在，將所述業務請求壓入所述分組對象的子消息隊列中，否則，執行步驟B2；

B2：在所述數據存儲模塊中創建一個新的分組對象，所述新的分組對象的鍵值IP同于所述目的IP；

B3：將所述業務請求壓入所述新的分組對象的子消息隊列中。

優選地，所述網絡處理模塊包含多個操作系統線程。

優選地，所述步驟C具體包括以下步驟；

C1：所述線程周期性查詢和判斷所述子消息隊列中的業務請求的數量，如果所述業務請求的數量超過第一設定值m，則將所述子消息隊列中前m個業務請求合并成一個網絡請求后發送給所述目的IP對應的服務器，否則，執行C2；

C2：所述線程判斷所述子消息隊列中第1個業務請求的等待時間是否超過第二設定值n，如果超過，則將所述子消息隊列中所有業務請求合并成一個網絡請求后發送給所述目的IP對應的服務器，否則，執行所述步驟C1。

優選地，所述第一設定值m為32。

優選地，所述第二設定值n為200毫秒。

優選地，在所述步驟C之后還包括步驟D：所述服務器接收所述網絡請求后，將所述網絡請求拆分成所述多個業務請求后分別進行響應。

(三)有益效果

本發明的高并發業務請求處理方法，通過設置分組消息隊列，首先將業務請求按照目的IP進行分組，然后將同組的業務請求合并成網絡請求后再發送給服務器。從而，減少了網絡請求次數，提高了對業務請求的處理效率，節省客戶端和服務器內存。

附圖說明

圖1是本發明實施例所述的高并發業務請求處理方法的流程圖。

具體實施方式

下面結合附圖和實施例，對本發明的具體實施方式作進一步詳細描述。以下實施例用于說明本發明，但不用來限制本發明的范圍。

圖1是本發明實施例所述的高并發業務請求處理方法的流程圖。如圖1所示，所述方法包括：

步驟A：將業務請求和目的IP壓入客戶端的分組消息隊列。

所述分組消息隊列建立在所述客戶端上，其包括數據存儲模塊和網絡處理模塊。

所述數據存儲模塊包含以散列表實現地一組分組對象。所述分組對象包括鍵值IP和子消息隊列。所述數據存儲模塊能夠以所述鍵值IP為索引查找相應的分組對象。

所述網絡處理模塊包含多個操作系統線程，所述操作系統線程的數量能夠配置調整。

步驟B：根據所述目的IP，將所述業務請求壓入所述分組消息隊列的數據存儲模塊的子消息隊列中。

所述步驟B具體包括：