[發(fā)明專利]消息傳輸方法、裝置、電子設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202111065884.5
• 申請(qǐng)日: 2021-09-10
• 公開(kāi)（公告）號(hào): CN113742110A
• 公開(kāi)（公告）日: 2021-12-03
• 發(fā)明（設(shè)計(jì)）人: 郝旭
• 申請(qǐng)（專利權(quán)）人: 北京沃東天駿信息技術(shù)有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54
• 代理公司: 中科專利商標(biāo)代理有限責(zé)任公司 11021
• 代理人: 王文思

本公開(kāi)提供了一種消息傳輸方法、裝置、電子設(shè)備及存儲(chǔ)介質(zhì)，該方法包括：響應(yīng)于接收到預(yù)定主題下的當(dāng)前消息，確定發(fā)送當(dāng)前消息的當(dāng)前生產(chǎn)者；確定訂閱預(yù)定主題的至少一個(gè)訂戶，得到訂戶集合；取針對(duì)預(yù)定主題配置的消息傳輸通道；根據(jù)消息傳輸通道，確定目標(biāo)生產(chǎn)者和目標(biāo)訂戶；以及在確定當(dāng)前生產(chǎn)者與目標(biāo)生產(chǎn)者相同，且訂戶集合中包括目標(biāo)訂戶的情況下，將當(dāng)前消息發(fā)送至目標(biāo)訂戶。

技術(shù)領(lǐng)域

本公開(kāi)涉及計(jì)算機(jī)技術(shù)領(lǐng)域，更具體地，涉及一種消息傳輸方法、消息傳輸裝置、電子設(shè)備、計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)以及計(jì)算機(jī)程序產(chǎn)品。

背景技術(shù)

MQ(Message Queue，消息隊(duì)列)是一種消息傳輸系統(tǒng)。根據(jù)消息傳遞方式的不同，MQ分為不同模式。一種為生產(chǎn)者/訂戶模式，生產(chǎn)者(消息的發(fā)送者)發(fā)送的消息會(huì)進(jìn)入到隊(duì)列，多個(gè)訂戶(消息的接收者)同時(shí)監(jiān)聽(tīng)隊(duì)列，并且隊(duì)列中的每一條消息僅被一個(gè)訂戶獲取，實(shí)現(xiàn)消息的點(diǎn)對(duì)點(diǎn)傳輸。另一種為發(fā)布/訂閱模式，生產(chǎn)者將消息發(fā)布到預(yù)定主題下，多個(gè)訂戶(消息的接收者)共同訂閱預(yù)定主題，并從預(yù)定主題下共同取得消息。

發(fā)明內(nèi)容

本公開(kāi)提供了一種消息傳輸方法、消息傳輸裝置、電子設(shè)備、計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)以及計(jì)算機(jī)程序產(chǎn)品，緩解發(fā)布/訂閱模式下當(dāng)前消息被全部訂戶共同使用的問(wèn)題，實(shí)現(xiàn)當(dāng)前消息的點(diǎn)對(duì)點(diǎn)傳輸。

本公開(kāi)的一個(gè)方面提供了一種消息傳輸方法，包括：響應(yīng)于接收到預(yù)定主題下的當(dāng)前消息，確定發(fā)送所述當(dāng)前消息的當(dāng)前生產(chǎn)者；確定訂閱所述預(yù)定主題的至少一個(gè)訂戶，得到訂戶集合；獲取針對(duì)所述預(yù)定主題配置的消息傳輸通道；根據(jù)所述消息傳輸通道，確定目標(biāo)生產(chǎn)者和目標(biāo)訂戶；以及在確定所述當(dāng)前生產(chǎn)者與所述目標(biāo)生產(chǎn)者相同，且所述訂戶集合中包括所述目標(biāo)訂戶的情況下，將所述當(dāng)前消息發(fā)送至所述目標(biāo)訂戶。

根據(jù)本公開(kāi)的實(shí)施例，消息傳輸方法還包括：確定所述消息傳輸通道是否已配置；在確定所述消息傳輸通道尚未配置的情況下，將所述當(dāng)前消息發(fā)送至所述訂戶集合中的每一個(gè)訂戶。

根據(jù)本公開(kāi)的實(shí)施例，所述在確定所述當(dāng)前生產(chǎn)者與所述目標(biāo)生產(chǎn)者相同，且所述訂戶集合中包括所述目標(biāo)訂戶的情況下，將所述當(dāng)前消息發(fā)送至所述目標(biāo)訂戶包括：在確定所述當(dāng)前生產(chǎn)者的標(biāo)識(shí)信息與所述目標(biāo)生產(chǎn)者的標(biāo)識(shí)信息相同，且所述訂戶集合對(duì)應(yīng)的標(biāo)識(shí)信息集合中包括所述目標(biāo)訂戶的標(biāo)識(shí)信息的情況下，將所述當(dāng)前消息發(fā)送至所述目標(biāo)訂戶。

根據(jù)本公開(kāi)的實(shí)施例，消息傳輸方法還包括：在滿足預(yù)設(shè)條件的情況下，將所述當(dāng)前消息發(fā)送至所述訂戶集合中的每一個(gè)訂戶；其中，所述預(yù)設(shè)條件包括以下中的至少一個(gè)：所述當(dāng)前生產(chǎn)者與所述目標(biāo)生產(chǎn)者不同；所述訂戶集合中不包括所述目標(biāo)訂戶。

根據(jù)本公開(kāi)的實(shí)施例，消息傳輸方法還包括：展示所述當(dāng)前生產(chǎn)者的標(biāo)識(shí)信息和接收到所述當(dāng)前消息的訂戶的標(biāo)識(shí)信息。

本公開(kāi)的另一個(gè)方面提供了一種消息傳輸裝置，包括：當(dāng)前生產(chǎn)者確定模塊、訂戶集合確定模塊、消息傳輸通道獲取模塊、對(duì)象確定模塊以及第一發(fā)送模塊；當(dāng)前生產(chǎn)者確定模塊用于響應(yīng)于接收到預(yù)定主題下的當(dāng)前消息，確定發(fā)送所述當(dāng)前消息的當(dāng)前生產(chǎn)者；訂戶集合確定模塊用于確定訂閱所述預(yù)定主題的至少一個(gè)訂戶，得到訂戶集合；消息傳輸通道獲取模塊用于獲取針對(duì)所述預(yù)定主題配置的消息傳輸通道；對(duì)象確定模塊用于根據(jù)所述消息傳輸通道，確定目標(biāo)生產(chǎn)者和目標(biāo)訂戶；第一發(fā)送模塊用于在確定所述當(dāng)前生產(chǎn)者與所述目標(biāo)生產(chǎn)者相同，且所述訂戶集合中包括所述目標(biāo)訂戶的情況下，將所述當(dāng)前消息發(fā)送至所述目標(biāo)訂戶。

根據(jù)本公開(kāi)的實(shí)施例，消息傳輸裝置還包括：判斷模塊和第二發(fā)送模塊；判斷模塊用于確定所述消息傳輸通道是否已配置；第二發(fā)送模塊用于在確定所述消息傳輸通道尚未配置的情況下，將所述當(dāng)前消息發(fā)送至所述訂戶集合中的每一個(gè)訂戶。

本公開(kāi)的另一方面提供了一種電子設(shè)備，包括一個(gè)或多個(gè)處理器，還包括用于存儲(chǔ)一個(gè)或多個(gè)程序的存儲(chǔ)器；其中，當(dāng)所述一個(gè)或多個(gè)程序被所述一個(gè)或多個(gè)處理器執(zhí)行時(shí)，使得所述一個(gè)或多個(gè)處理器實(shí)現(xiàn)實(shí)現(xiàn)本公開(kāi)實(shí)施例所述的方法。