[發(fā)明專(zhuān)利]一種業(yè)務(wù)消息的發(fā)送方法及裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 202010054248.1
• 申請(qǐng)日: 2020-01-17
• 公開(kāi)（公告）號(hào): CN111314189B
• 公開(kāi)（公告）日: 2022-02-25
• 發(fā)明（設(shè)計(jì)）人: 趙振林
• 申請(qǐng)（專(zhuān)利權(quán)）人: 螞蟻財(cái)富（上海）金融信息服務(wù)有限公司
• 主分類(lèi)號(hào): H04L12/40
• 分類(lèi)號(hào): H04L12/40;H04L67/1097
• 代理公司: 北京博思佳知識(shí)產(chǎn)權(quán)代理有限公司 11415
• 代理人: 周嗣勇

1.一種業(yè)務(wù)消息的發(fā)送方法，應(yīng)用于業(yè)務(wù)計(jì)算系統(tǒng)中的總線控制設(shè)備，所述業(yè)務(wù)計(jì)算系統(tǒng)還包括消息總線、多個(gè)消息接收設(shè)備以及至少一個(gè)消息發(fā)送設(shè)備；

基于每個(gè)消息接收設(shè)備的設(shè)備標(biāo)識(shí)哈希值，構(gòu)建一致性哈希環(huán)，所述方法包括：

通過(guò)所述消息總線，接收任一消息發(fā)送設(shè)備發(fā)送的業(yè)務(wù)消息；

根據(jù)所述業(yè)務(wù)消息，獲取所述業(yè)務(wù)消息關(guān)聯(lián)的業(yè)務(wù)對(duì)象的對(duì)象標(biāo)識(shí)；

基于所述一致性哈希環(huán)，對(duì)所述業(yè)務(wù)對(duì)象的對(duì)象標(biāo)識(shí)哈希值進(jìn)行映射，并根據(jù)映射結(jié)果，確定所述業(yè)務(wù)對(duì)象對(duì)應(yīng)的消息接收設(shè)備；

通過(guò)所述消息總線，將所述業(yè)務(wù)消息發(fā)送給所述業(yè)務(wù)對(duì)象對(duì)應(yīng)的消息接收設(shè)備，以便該消息接收設(shè)備將所述業(yè)務(wù)消息存儲(chǔ)于本地，并根據(jù)所述業(yè)務(wù)消息執(zhí)行計(jì)算。

2.如權(quán)利要求1所述的方法，根據(jù)所述業(yè)務(wù)消息，獲取所述業(yè)務(wù)消息關(guān)聯(lián)的業(yè)務(wù)對(duì)象的對(duì)象標(biāo)識(shí)，具體包括：

從所述業(yè)務(wù)消息中提取關(guān)聯(lián)于所述業(yè)務(wù)消息的業(yè)務(wù)對(duì)象的對(duì)象標(biāo)識(shí)。

3.如權(quán)利要求1所述的方法，在將所述業(yè)務(wù)消息發(fā)送給所述業(yè)務(wù)對(duì)象對(duì)應(yīng)的消息接收設(shè)備之前，所述方法還包括：

所述業(yè)務(wù)對(duì)象對(duì)應(yīng)的消息接收設(shè)備的設(shè)備標(biāo)識(shí)作為所述業(yè)務(wù)消息的標(biāo)簽；

通過(guò)所述消息總線，將所述業(yè)務(wù)消息發(fā)送給所述業(yè)務(wù)對(duì)象對(duì)應(yīng)的消息接收設(shè)備，具體包括：

將所述業(yè)務(wù)消息發(fā)送至所述消息總線對(duì)應(yīng)的消息隊(duì)列中，以便通過(guò)所述消息隊(duì)列，將所述業(yè)務(wù)消息投遞至所述業(yè)務(wù)消息的標(biāo)簽指定的消息接收設(shè)備。

4.一種業(yè)務(wù)消息的發(fā)送方法，應(yīng)用于業(yè)務(wù)計(jì)算系統(tǒng)中的總線控制設(shè)備，所述業(yè)務(wù)計(jì)算系統(tǒng)還包括消息總線、多個(gè)消息接收設(shè)備以及至少一個(gè)消息發(fā)送設(shè)備；

將業(yè)務(wù)計(jì)算系統(tǒng)中的多個(gè)消息接收設(shè)備劃分為至少兩個(gè)設(shè)備組，各設(shè)備組分別對(duì)應(yīng)不同的計(jì)算任務(wù)，并且，針對(duì)每個(gè)設(shè)備組，基于該設(shè)備組中每個(gè)消息接收設(shè)備的設(shè)備標(biāo)識(shí)哈希值，構(gòu)建該設(shè)備組對(duì)應(yīng)的一致性哈希環(huán)，所述方法包括：

通過(guò)所述消息總線，接收任一消息發(fā)送設(shè)備發(fā)送的業(yè)務(wù)消息；

根據(jù)所述業(yè)務(wù)消息，確定待計(jì)算所述業(yè)務(wù)消息的設(shè)備組，并獲取所述業(yè)務(wù)消息關(guān)聯(lián)的業(yè)務(wù)對(duì)象的對(duì)象標(biāo)識(shí)；

針對(duì)確定的每個(gè)設(shè)備組，基于該設(shè)備組對(duì)應(yīng)的一致性哈希環(huán)，對(duì)所述業(yè)務(wù)對(duì)象的對(duì)象標(biāo)識(shí)哈希值進(jìn)行映射，并根據(jù)映射結(jié)果，確定該設(shè)備組中對(duì)應(yīng)于所述業(yè)務(wù)對(duì)象的消息接收設(shè)備；

通過(guò)所述消息總線，將所述業(yè)務(wù)消息發(fā)送給該設(shè)備組中對(duì)應(yīng)于所述業(yè)務(wù)對(duì)象的消息接收設(shè)備，以便該消息接收設(shè)備將所述業(yè)務(wù)消息存儲(chǔ)于本地，并根據(jù)所述業(yè)務(wù)消息執(zhí)行該設(shè)備組對(duì)應(yīng)的計(jì)算任務(wù)。

5.如權(quán)利要求4所述的方法，所述方法還包括：

預(yù)先針對(duì)每個(gè)消息接收設(shè)備，獲取該消息接收設(shè)備指定的匹配條件；其中，同一設(shè)備組中的消息接收設(shè)備指定的匹配條件相同；

根據(jù)所述業(yè)務(wù)消息，確定待計(jì)算所述業(yè)務(wù)消息的設(shè)備組，具體包括：

針對(duì)每個(gè)設(shè)備組，判斷所述業(yè)務(wù)消息是否滿(mǎn)足該設(shè)備組中的消息接收設(shè)備指定的匹配條件；

若是，則確定該設(shè)備組待計(jì)算所述業(yè)務(wù)消息；

若否，則確定該設(shè)備組不計(jì)算所述業(yè)務(wù)消息。

6.一種業(yè)務(wù)消息的發(fā)送裝置，具體為業(yè)務(wù)計(jì)算系統(tǒng)中的總線控制設(shè)備，所述業(yè)務(wù)計(jì)算系統(tǒng)還包括消息總線、多個(gè)消息接收設(shè)備以及至少一個(gè)消息發(fā)送設(shè)備；

基于每個(gè)消息接收設(shè)備的設(shè)備標(biāo)識(shí)哈希值，構(gòu)建一致性哈希環(huán)，所述裝置包括：

消息獲取單元，用于通過(guò)所述消息總線，接收任一消息發(fā)送設(shè)備發(fā)送的業(yè)務(wù)消息；

對(duì)象標(biāo)識(shí)獲取單元，用于根據(jù)所述業(yè)務(wù)消息，獲取所述業(yè)務(wù)消息關(guān)聯(lián)的業(yè)務(wù)對(duì)象的對(duì)象標(biāo)識(shí)；

消息映射單元，基于所述一致性哈希環(huán)，用于對(duì)所述業(yè)務(wù)對(duì)象的對(duì)象標(biāo)識(shí)哈希值進(jìn)行映射，并根據(jù)映射結(jié)果，確定所述業(yè)務(wù)對(duì)象對(duì)應(yīng)的消息接收設(shè)備；

消息發(fā)送單元，用于通過(guò)所述消息總線，將所述業(yè)務(wù)消息發(fā)送給所述業(yè)務(wù)對(duì)象對(duì)應(yīng)的消息接收設(shè)備，以便該消息接收設(shè)備將所述業(yè)務(wù)消息存儲(chǔ)于本地，并根據(jù)所述業(yè)務(wù)消息執(zhí)行計(jì)算。

7.如權(quán)利要求6所述的裝置，所述對(duì)象標(biāo)識(shí)獲取單元，具體用于：

從所述業(yè)務(wù)消息中提取關(guān)聯(lián)于所述業(yè)務(wù)消息的業(yè)務(wù)對(duì)象的對(duì)象標(biāo)識(shí)。