[發(fā)明專利]消息處理方法及設(shè)備

在審

• 申請(qǐng)?zhí)枺?/td>: 201611225524.6
• 申請(qǐng)日: 2016-12-27
• 公開（公告）號(hào): CN106776075A
• 公開（公告）日: 2017-05-31
• 發(fā)明（設(shè)計(jì)）人: 顧鑫;劉忠旭;秦君曉
• 申請(qǐng)（專利權(quán)）人: 北京五八信息技術(shù)有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54
• 代理公司: 北京同立鈞成知識(shí)產(chǎn)權(quán)代理有限公司11205
• 代理人: 楊文娟,劉芳

1.一種消息處理方法，其特征在于，應(yīng)用于應(yīng)用服務(wù)器，所述方法包括：

獲取在預(yù)設(shè)時(shí)段內(nèi)對(duì)線程池中的依賴消息處理請(qǐng)求進(jìn)行處理的成功率，所述依賴消息處理請(qǐng)求為所述應(yīng)用服務(wù)器依賴第三方服務(wù)器處理的請(qǐng)求；

若所述成功率大于預(yù)設(shè)成功率，則同時(shí)對(duì)所述線程池中所有的依賴消息處理請(qǐng)求進(jìn)行處理；

若所述成功率小于預(yù)設(shè)成功率，則同時(shí)對(duì)所述線程池中、預(yù)設(shè)個(gè)數(shù)的依賴消息處理請(qǐng)求進(jìn)行處理，所述預(yù)設(shè)個(gè)數(shù)小于所述線程池最多可容納的依賴消息處理請(qǐng)求的個(gè)數(shù)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，獲取在預(yù)設(shè)時(shí)段內(nèi)對(duì)線程池中的依賴消息處理請(qǐng)求進(jìn)行處理的成功率，包括：

獲取在所述預(yù)設(shè)時(shí)段內(nèi)、根據(jù)所述線程池中的依賴消息處理請(qǐng)求向所述第三方服務(wù)器發(fā)送的請(qǐng)求消息的第一個(gè)數(shù)；

獲取在所述預(yù)設(shè)時(shí)段內(nèi)接收到所述第三服務(wù)器發(fā)送的、與所述請(qǐng)求消息對(duì)應(yīng)的成功響應(yīng)消息的第二個(gè)數(shù)；

根據(jù)所述第一個(gè)數(shù)和所述第二個(gè)數(shù)，確定所述成功率。

3.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，同時(shí)對(duì)所述線程池中、預(yù)設(shè)個(gè)數(shù)的依賴消息處理請(qǐng)求進(jìn)行處理，包括：

按照所述線程池中各依賴消息處理請(qǐng)求的接收時(shí)間，確定所述預(yù)設(shè)個(gè)數(shù)個(gè)依賴消息處理請(qǐng)求；

同時(shí)對(duì)所述預(yù)設(shè)個(gè)數(shù)個(gè)依賴消息處理請(qǐng)求進(jìn)行處理。

4.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，所述方法還包括：

接收終端設(shè)備發(fā)送的第一依賴消息處理請(qǐng)求；

判斷所述線程池中的請(qǐng)求個(gè)數(shù)是否小于預(yù)設(shè)閾值；

若是，則將所述第一依賴消息處理請(qǐng)求存放到所述線程池；

若否，則將所述第一依賴消息處理請(qǐng)求暫存在待處理請(qǐng)求隊(duì)列，并獲取所述線程池中包括的請(qǐng)求的個(gè)數(shù)及所述依賴消息處理請(qǐng)求在所述待處理請(qǐng)求隊(duì)列中的位置，直至所述線程池中的請(qǐng)求的個(gè)數(shù)小于預(yù)設(shè)閾值、且所述依賴消息處理請(qǐng)求位于所述待處理請(qǐng)求隊(duì)列的隊(duì)首時(shí)，將所述第一依賴消息處理請(qǐng)求存儲(chǔ)到所述線程池。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，所述方法還包括：

在所述線程池中確定處理完成的依賴消息處理請(qǐng)求；

將所述處理完成的依賴消息處理請(qǐng)求移出所述線程池；

若所述待處理請(qǐng)求隊(duì)列中存在依賴消息處理請(qǐng)求，則將位于待處理請(qǐng)求隊(duì)列隊(duì)首的依賴消息處理請(qǐng)求存儲(chǔ)到所述線程池。

6.一種應(yīng)用服務(wù)器，其特征在于，應(yīng)用于應(yīng)用服務(wù)器包括獲取模塊和處理模塊，其中，

所述獲取模塊用于，獲取在預(yù)設(shè)時(shí)段內(nèi)對(duì)線程池中的依賴消息處理請(qǐng)求進(jìn)行處理的成功率，所述依賴消息處理請(qǐng)求為所述應(yīng)用服務(wù)器依賴第三方服務(wù)器處理的請(qǐng)求；

所述處理模塊用于，在所述成功率大于預(yù)設(shè)成功率時(shí)，同時(shí)對(duì)所述線程池中所有的依賴消息處理請(qǐng)求進(jìn)行處理；

所述處理模塊還用于，在所述成功率小于預(yù)設(shè)成功率時(shí)，同時(shí)對(duì)所述線程池中、預(yù)設(shè)個(gè)數(shù)的依賴消息處理請(qǐng)求進(jìn)行處理，所述預(yù)設(shè)個(gè)數(shù)小于所述線程池最多可容納的依賴消息處理請(qǐng)求的個(gè)數(shù)。

7.根據(jù)權(quán)利要求6所述的應(yīng)用服務(wù)器，其特征在于，所述獲取模塊具體用于：

獲取在所述預(yù)設(shè)時(shí)段內(nèi)、根據(jù)所述線程池中的依賴消息處理請(qǐng)求向所述第三方服務(wù)器發(fā)送的請(qǐng)求消息的第一個(gè)數(shù)；

獲取在所述預(yù)設(shè)時(shí)段內(nèi)接收到所述第三服務(wù)器發(fā)送的、與所述請(qǐng)求消息對(duì)應(yīng)的成功響應(yīng)消息的第二個(gè)數(shù)；

根據(jù)所述第一個(gè)數(shù)和所述第二個(gè)數(shù)，確定所述成功率。

8.根據(jù)權(quán)利要求6或7所述的應(yīng)用服務(wù)器，其特征在于，所述處理模塊具體用于：

按照所述線程池中各依賴消息處理請(qǐng)求的接收時(shí)間，確定所述預(yù)設(shè)個(gè)數(shù)個(gè)依賴消息處理請(qǐng)求；

同時(shí)對(duì)所述預(yù)設(shè)個(gè)數(shù)個(gè)依賴消息處理請(qǐng)求進(jìn)行處理。