[發(fā)明專利]消息的傳輸方法和裝置

有效

• 申請?zhí)枺?/td>: 201710030733.3
• 申請日: 2017-01-16
• 公開（公告）號: CN106850402B
• 公開（公告）日: 2020-11-03
• 發(fā)明（設(shè)計）人: 鐘林穎
• 申請（專利權(quán)）人: 騰訊科技（深圳）有限公司
• 主分類號: H04L12/58
• 分類號: H04L12/58;G06F9/54
• 代理公司: 北京康信知識產(chǎn)權(quán)代理有限責任公司 11240
• 代理人: 董文倩;褚敏

1.一種消息的傳輸方法，其特征在于，包括：

創(chuàng)建用于處理消息發(fā)送請求的第一進程，其中，所述消息發(fā)送請求用于請求發(fā)送消息至第一對象；

在接收到第二對象發(fā)送的所述消息發(fā)送請求時，獲取所述發(fā)送請求所請求發(fā)送的目標消息的消息類型，其中，所述消息類型包括單個消息類型和批量消息類型，所述單個消息類型為單個的消息，所述批量消息類型為連續(xù)的多個消息；

通過所述第一進程響應所述消息發(fā)送請求，將所述目標消息存儲至多個消息隊列中的目標消息隊列，其中，所述目標消息隊列用于存儲與所述目標消息的消息類型相同的消息；

通過用于發(fā)送與所述目標消息的消息類型相同的消息的第二進程，將從所述目標消息隊列中讀取的所述目標消息發(fā)送至所述第一對象，其中，所述第二進程為用于執(zhí)行消息發(fā)送任務(wù)的進程。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，通過用于發(fā)送與所述目標消息的消息類型相同的消息的進程，將從所述目標消息隊列中讀取的所述目標消息發(fā)送至所述第一對象包括：

確定多個進程中用于發(fā)送與所述目標消息的消息類型相同的消息的第二進程；

通過所述第二進程將從所述目標消息隊列中讀取的所述目標消息發(fā)送至所述第一對象。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，在通過所述第二進程將從所述目標消息隊列中讀取的所述目標消息發(fā)送至所述第一對象之前，所述方法還包括：

將存入所述消息隊列的所述目標消息的消息狀態(tài)設(shè)置為待發(fā)送狀態(tài)。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，通過所述第二進程將從所述目標消息隊列中讀取的所述目標消息發(fā)送至所述第一對象包括：

通過所述第二進程從所述消息隊列中按照預設(shè)順序讀取為待發(fā)送狀態(tài)的消息，并將讀取的消息的消息狀態(tài)設(shè)置為發(fā)送中，其中，所述讀取的消息包括所述目標消息；

通過所述第二進程將所述讀取的消息發(fā)送至所述第一對象，并在所述讀取的消息發(fā)送完成之后，將所述讀取的消息從所述消息隊列中刪除。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，通過所述第一進程響應所述消息發(fā)送請求，將所述目標消息存儲至多個消息隊列中的目標消息隊列包括：

在所述目標消息的消息類型為單個消息類型的情況下，通過所述第一進程將所述目標消息存儲至多個所述消息隊列中的第一消息隊列，其中，所述目標消息隊列包括所述第一消息隊列，所述第一消息隊列用于存儲為所述單個消息類型的消息；

在所述目標消息的消息類型為批量消息類型的情況下，通過所述第一進程將所述目標消息存儲至多個所述消息隊列中的第二消息隊列，其中，所述目標消息隊列包括所述第二消息隊列，所述第二消息隊列用于存儲為所述批量消息類型的消息，多個被設(shè)置為所述批量消息類型的消息需要連續(xù)發(fā)送。

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

在通過所述第一進程將所述目標消息存儲至多個所述消息隊列中的第二消息隊列之前，所述方法包括：判斷為所述批量消息類型的所述目標消息的消息數(shù)量是否在預設(shè)范圍內(nèi)；

將所述目標消息存儲至用于存儲為所述批量消息類型的消息的第二消息隊列包括：在判斷出為所述批量消息類型的所述目標消息的消息數(shù)量在所述預設(shè)范圍內(nèi)的情況下，將所述目標消息存儲至所述第二消息隊列。

7.根據(jù)權(quán)利要求1至6中任意一項所述的方法，其特征在于，創(chuàng)建用于處理消息發(fā)送請求的第一進程包括：

在多臺設(shè)備上創(chuàng)建允許同時運行的所述第一進程，其中，所述多臺設(shè)備為分布式部署的設(shè)備，每臺設(shè)備用于處理一種業(yè)務(wù)類型的所述目標消息。