[發(fā)明專利]一種消息的處理方法、裝置及計(jì)算機(jī)系統(tǒng)

在審

• 申請(qǐng)?zhí)枺?/td>: 202011147223.2
• 申請(qǐng)日: 2020-10-23
• 公開（公告）號(hào): CN112291325A
• 公開（公告）日: 2021-01-29
• 發(fā)明（設(shè)計(jì)）人: 劉煒強(qiáng);喻陽(yáng);李新豪
• 申請(qǐng)（專利權(quán)）人: 上海豹云網(wǎng)絡(luò)信息服務(wù)有限公司
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08
• 代理公司: 北京市萬(wàn)慧達(dá)律師事務(wù)所 11111
• 代理人: 段曉玲

本申請(qǐng)公開了一種消息的處理方法、裝置及計(jì)算機(jī)系統(tǒng)，所述方法包括接收消息發(fā)送方發(fā)出的消息發(fā)送請(qǐng)求，所述消息發(fā)送請(qǐng)求包括待發(fā)送消息及所述待發(fā)送消息的目標(biāo)消息類型；根據(jù)預(yù)設(shè)注冊(cè)記錄，確定所述目標(biāo)消息類型對(duì)應(yīng)的目標(biāo)接收方，所述預(yù)設(shè)注冊(cè)記錄用于存儲(chǔ)每一接收方預(yù)先注冊(cè)的待接收的消息類型；根據(jù)所述目標(biāo)消息類型對(duì)應(yīng)的發(fā)送規(guī)則，將所述待發(fā)送消息發(fā)送至所述目標(biāo)接收方，通過將每一消息類型對(duì)應(yīng)的發(fā)送規(guī)則進(jìn)行預(yù)先封裝，消息的發(fā)送方和接收方只需要選擇合適的消息類型，當(dāng)消息的接收方需要接收其他類型的消息時(shí)，不需要對(duì)消息的接收方式進(jìn)行重新部署，節(jié)省了消息接收方改變想接收的消息類型所需的時(shí)間及人力成本。

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

本發(fā)明涉及數(shù)據(jù)推送領(lǐng)域，尤其涉及一種消息的處理方法、裝置及計(jì)算機(jī)系統(tǒng)。

背景技術(shù)

消息隊(duì)列已經(jīng)逐漸成為企業(yè)IT系統(tǒng)內(nèi)部通信的核心手段。它具有低耦合、可靠投遞、廣播、流量控制、最終一致性等一系列功能，成為異步RPC的主要手段之一。

消息隊(duì)列通常的組成部分有消息生產(chǎn)者、消息中間件和消息消費(fèi)者，消息生產(chǎn)者實(shí)時(shí)地順序地將消息推送到消息通道，消息消費(fèi)者依據(jù)自己的需求接入網(wǎng)絡(luò)，并可以從消息通道中消費(fèi)不同類型的全量消息。然而，消息消費(fèi)者需要提前訂閱想要獲取的topic，以便消息中間件將該topic的消息發(fā)送至消息消費(fèi)者。這種訂閱關(guān)系一旦建立，如果需要修改就需要對(duì)項(xiàng)目進(jìn)行重新部署，耗費(fèi)大量時(shí)間成本。

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

為了解決現(xiàn)有技術(shù)的不足，本發(fā)明的主要目的在于提供一種消息的處理方法、裝置及計(jì)算機(jī)系統(tǒng)，以解決現(xiàn)有技術(shù)的上述問題。

為了達(dá)到上述目的，第一方面本發(fā)明提供了一種消息的處理方法，所述方法包括：

接收消息發(fā)送方發(fā)出的消息發(fā)送請(qǐng)求，所述消息發(fā)送請(qǐng)求包括待發(fā)送消息及所述待發(fā)送消息的目標(biāo)消息類型；

根據(jù)預(yù)設(shè)注冊(cè)記錄，確定所述目標(biāo)消息類型對(duì)應(yīng)的目標(biāo)接收方，所述預(yù)設(shè)注冊(cè)記錄用于存儲(chǔ)每一接收方預(yù)先注冊(cè)的待接收的消息類型；

根據(jù)所述目標(biāo)消息類型對(duì)應(yīng)的發(fā)送規(guī)則，將所述待發(fā)送消息發(fā)送至所述目標(biāo)接收方。

在一些實(shí)施例中，所述發(fā)送規(guī)則包括對(duì)應(yīng)的預(yù)設(shè)數(shù)據(jù)結(jié)構(gòu)及路由規(guī)則，所述根據(jù)所述目標(biāo)消息類型對(duì)應(yīng)的發(fā)送規(guī)則，將所述待發(fā)送消息發(fā)送至所述目標(biāo)接收方包括：

根據(jù)所述目標(biāo)消息類型對(duì)應(yīng)的預(yù)設(shè)數(shù)據(jù)結(jié)構(gòu)及所述待發(fā)送消息，生成待轉(zhuǎn)發(fā)消息；

根據(jù)所述目標(biāo)消息類型對(duì)應(yīng)的路由規(guī)則，將所述待轉(zhuǎn)發(fā)消息發(fā)送至所述目標(biāo)接收方。

在一些實(shí)施例中，所述根據(jù)所述目標(biāo)消息類型對(duì)應(yīng)的發(fā)送規(guī)則，將所述待發(fā)送消息發(fā)送至所述目標(biāo)接收方包括：

將所述待發(fā)送消息存儲(chǔ)至所述目標(biāo)消息類型對(duì)應(yīng)的預(yù)設(shè)隊(duì)列，以便根據(jù)對(duì)應(yīng)的發(fā)送規(guī)則將所述待發(fā)送消息發(fā)送至所述目標(biāo)接收方。

在一些實(shí)施例中，所述方法包括：

根據(jù)預(yù)設(shè)接收方發(fā)送的消息接收請(qǐng)求更新所述預(yù)設(shè)注冊(cè)記錄，所述消息接收請(qǐng)求包括所述預(yù)設(shè)接收方的待注冊(cè)消息類型。

在一些實(shí)施例中，所述目標(biāo)消息類型包括定時(shí)消息，所述定時(shí)消息對(duì)應(yīng)的路由規(guī)則包括消息的等待時(shí)長(zhǎng)，所述根據(jù)所述目標(biāo)消息類型對(duì)應(yīng)的發(fā)送規(guī)則，將所述待發(fā)送消息發(fā)送至所述目標(biāo)接收方包括：

當(dāng)所述待發(fā)送消息存儲(chǔ)至所述目標(biāo)消息類型對(duì)應(yīng)的預(yù)設(shè)隊(duì)列不小于所述等待時(shí)長(zhǎng)時(shí)，將所述待發(fā)送消息發(fā)送至所述目標(biāo)接收方。

在一些實(shí)施例中，所述目標(biāo)消息類型包括順序消息，所述消息發(fā)送請(qǐng)求包括所述待發(fā)送消息對(duì)應(yīng)的前序消息，所述根據(jù)所述目標(biāo)消息類型對(duì)應(yīng)的發(fā)送規(guī)則，將所述待發(fā)送消息發(fā)送至所述目標(biāo)接收方包括：

當(dāng)所述前序消息發(fā)送至對(duì)應(yīng)的接收方時(shí)，將所述待發(fā)送消息發(fā)送至所述目標(biāo)接收方。