[發(fā)明專利]一種消息請(qǐng)求的傳輸方法和裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 201711460169.5
• 申請(qǐng)日: 2017-12-28
• 公開(kāi)（公告）號(hào): CN109976919A
• 公開(kāi)（公告）日: 2019-07-05
• 發(fā)明（設(shè)計(jì)）人: 羅寅卓
• 申請(qǐng)（專利權(quán)）人: 北京京東尚科信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54
• 代理公司: 中原信達(dá)知識(shí)產(chǎn)權(quán)代理有限責(zé)任公司 11219
• 代理人: 張一軍;楊曉偉

本發(fā)明公開(kāi)了一種消息請(qǐng)求的傳輸方法和裝置，涉及計(jì)算機(jī)技術(shù)領(lǐng)域。該方法的一個(gè)具體實(shí)施方式包括：接收消息請(qǐng)求；根據(jù)預(yù)先配置的消息模板，將所述消息請(qǐng)求適配為符合目標(biāo)消息隊(duì)列的請(qǐng)求；將適配后的請(qǐng)求發(fā)送至目標(biāo)消息隊(duì)列。該實(shí)施方式克服了每個(gè)應(yīng)用就不同的消息隊(duì)列需要維護(hù)多個(gè)版本代碼的技術(shù)問(wèn)題，進(jìn)而降低了研發(fā)和維護(hù)的成本。

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

本發(fā)明涉及計(jì)算機(jī)技術(shù)領(lǐng)域，尤其涉及一種消息請(qǐng)求的傳輸方法和裝置。

背景技術(shù)

消息隊(duì)列MQ(Message Queue)是一種應(yīng)用程序?qū)?yīng)用程序的通信方法，應(yīng)用程序通過(guò)寫和檢索出入列隊(duì)的針對(duì)應(yīng)用程序的數(shù)據(jù)即消息來(lái)通信。目前各個(gè)消息隊(duì)列都提供了各自特有的應(yīng)用程序編程接口API(Application Programming Interface)，來(lái)實(shí)現(xiàn)各發(fā)送消息、接收消息等功能。

在實(shí)現(xiàn)本發(fā)明過(guò)程中，發(fā)明人發(fā)現(xiàn)現(xiàn)有技術(shù)中至少存在如下問(wèn)題：

在將一個(gè)應(yīng)用程序從消息隊(duì)列A上移植到消息隊(duì)列B上時(shí)，需要對(duì)程序代碼進(jìn)行修改，以滿足消息隊(duì)列B的規(guī)定；由此，每個(gè)應(yīng)用程序就需要基于不同的消息隊(duì)列維護(hù)多個(gè)版本的代碼，從而增加了開(kāi)發(fā)和維護(hù)的成本。

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

有鑒于此，本發(fā)明實(shí)施例提供了一種消息請(qǐng)求的傳輸方法和裝置，能夠根據(jù)預(yù)先配置的消息模板，將所述消息請(qǐng)求適配為符合目標(biāo)消息隊(duì)列的消息結(jié)構(gòu)的請(qǐng)求，再將適配后的請(qǐng)求發(fā)送至目標(biāo)消息隊(duì)列，克服了每個(gè)應(yīng)用程序就不同的消息隊(duì)列需要維護(hù)多個(gè)版本代碼的技術(shù)問(wèn)題，進(jìn)而降低了研發(fā)和維護(hù)的成本。

為實(shí)現(xiàn)上述目的，根據(jù)本發(fā)明實(shí)施例的一個(gè)方面，提供了一種消息請(qǐng)求的傳輸方法，包括：接收消息請(qǐng)求；根據(jù)預(yù)先配置的消息模板，將所述消息請(qǐng)求適配為符合目標(biāo)消息隊(duì)列的請(qǐng)求；將適配后的請(qǐng)求發(fā)送至目標(biāo)消息隊(duì)列。

可選地，所述消息模板包括以下各項(xiàng)中的至少一項(xiàng)：消費(fèi)方式、消費(fèi)超時(shí)、消費(fèi)重試；其中，消費(fèi)方式是指消息請(qǐng)求的被處理方式；消費(fèi)超時(shí)是指處理一個(gè)消息請(qǐng)求需用的最長(zhǎng)時(shí)間；消費(fèi)重試是指當(dāng)一個(gè)消息請(qǐng)求沒(méi)有在消費(fèi)超時(shí)時(shí)間內(nèi)被處理，會(huì)重新發(fā)送該消息請(qǐng)求。

可選地，所述消費(fèi)方式包括以下各項(xiàng)中的至少一項(xiàng)：主題訂閱、指定應(yīng)用；所述消息請(qǐng)求中包括主題信息，所述主題訂閱指消息請(qǐng)求被訂閱該主題信息的應(yīng)用程序消費(fèi)；所述指定應(yīng)用是指消息請(qǐng)求只能被指定的應(yīng)用程序處理。

可選地，所述將適配后的請(qǐng)求發(fā)送至目標(biāo)消息隊(duì)列，包括：獲取傳輸通道；通過(guò)所述傳輸通道將適配后的請(qǐng)求發(fā)送至目標(biāo)消息隊(duì)列。

可選地，所述接收消息請(qǐng)求，包括：獲取端口信息；根據(jù)所述端口信息，偵聽(tīng)端口，直至接收到消息請(qǐng)求。

可選地，所述接收消息請(qǐng)求之后，包括：獲取目標(biāo)消息隊(duì)列的參數(shù)；判斷目標(biāo)消息隊(duì)列的參數(shù)是否在設(shè)定閾值范圍內(nèi)，若目標(biāo)消息隊(duì)列的參數(shù)不在設(shè)定閾值范圍內(nèi)，即目標(biāo)消息隊(duì)列異常，則啟動(dòng)預(yù)警或?qū)溆孟㈥?duì)列作為新的目標(biāo)消息隊(duì)列。

為實(shí)現(xiàn)上述目的，根據(jù)本發(fā)明實(shí)施例的另一方面，提供了一種消息請(qǐng)求的傳輸裝置，包括：通信模塊、適配模塊、傳輸模塊；所述通信模塊，用于：接收消息請(qǐng)求；所述適配模塊，用于：根據(jù)預(yù)先配置的消息模板，將所述消息請(qǐng)求適配為符合目標(biāo)消息隊(duì)列的消息結(jié)構(gòu)的請(qǐng)求；所述傳輸模塊，用于：將適配后的請(qǐng)求發(fā)送至目標(biāo)消息隊(duì)列。

可選地，所述適配模塊，用于：獲取消息模板；所述消息模板包括以下各項(xiàng)中的至少一項(xiàng)：消費(fèi)方式、消費(fèi)超時(shí)、消費(fèi)重試；其中，消費(fèi)方式是指消息請(qǐng)求的被處理方式；消費(fèi)超時(shí)是指處理一個(gè)消息請(qǐng)求需用的最長(zhǎng)時(shí)間；消費(fèi)重試是指當(dāng)一個(gè)消息請(qǐng)求沒(méi)有在消費(fèi)超時(shí)時(shí)間內(nèi)被處理，會(huì)重新發(fā)送該消息請(qǐng)求。

可選地，所述消費(fèi)方式包括以下各項(xiàng)中的至少一項(xiàng)：主題訂閱、指定應(yīng)用；所述消息請(qǐng)求中包括主題信息，所述主題訂閱指消息請(qǐng)求被訂閱該主題信息的應(yīng)用程序消費(fèi)；所述指定應(yīng)用是指消息請(qǐng)求只能被指定的應(yīng)用程序處理。