[發(fā)明專(zhuān)利]一種控制消息發(fā)送速度的方法、存儲(chǔ)介質(zhì)及設(shè)備

在審

• 申請(qǐng)?zhí)枺?/td>: 202310587945.7
• 申請(qǐng)日: 2023-05-24
• 公開(kāi)（公告）號(hào): CN116527772A
• 公開(kāi)（公告）日: 2023-08-01
• 發(fā)明（設(shè)計(jì)）人: 于樹(shù)鋒;張大志;梁賢暉;李鵬飛
• 申請(qǐng)（專(zhuān)利權(quán)）人: 北京易聯(lián)達(dá)商務(wù)服務(wù)有限公司
• 主分類(lèi)號(hào): H04L67/61
• 分類(lèi)號(hào): H04L67/61
• 代理公司: 北京智行陽(yáng)光知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11738
• 代理人: 黃錦陽(yáng)

本發(fā)明公開(kāi)了一種控制消息發(fā)送速度的方法、存儲(chǔ)介質(zhì)及設(shè)備，消息發(fā)送方在接收到待發(fā)送的消息后，先根據(jù)消息的時(shí)效性及業(yè)務(wù)屬性，按預(yù)設(shè)的劃分標(biāo)準(zhǔn)，將消息劃分優(yōu)先級(jí)，并放入所屬優(yōu)先級(jí)對(duì)應(yīng)的消息隊(duì)列；對(duì)各個(gè)優(yōu)先級(jí)的消息隊(duì)列進(jìn)行發(fā)送處理：對(duì)各個(gè)優(yōu)先級(jí)的消息隊(duì)列進(jìn)行發(fā)送處理，其中，對(duì)于高優(yōu)先級(jí)的消息，在不高于預(yù)設(shè)的最大發(fā)送速率的情況下優(yōu)先發(fā)送，低優(yōu)先級(jí)的消息為高優(yōu)先級(jí)的消息讓路。本發(fā)明對(duì)消息實(shí)行分級(jí)處理策略，消息優(yōu)先級(jí)越高的消息將優(yōu)先發(fā)送，在不影響整體發(fā)送速度的同時(shí)保證了消息的時(shí)效性。本發(fā)明中，消息發(fā)送方在分布式環(huán)境下采用了統(tǒng)一的消息發(fā)送控制機(jī)制，可以保證系統(tǒng)整體發(fā)送能力被最大可能的利用起來(lái)。

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

本發(fā)明涉及網(wǎng)絡(luò)消息傳輸技術(shù)領(lǐng)域，具體涉及一種控制消息發(fā)送速度的方法、存儲(chǔ)介質(zhì)及設(shè)備。

背景技術(shù)

平臺(tái)之間發(fā)送消息時(shí)，按照消息發(fā)送的方向，可分為消息接收方和消息發(fā)送方。由于消息接收方接收并處理消息的能力是一定的，當(dāng)消息發(fā)送方發(fā)送消息的速度超過(guò)消息接收方處理消息的速度時(shí)，就會(huì)造成發(fā)送方發(fā)送的部分消息在接收方堆積并產(chǎn)生超時(shí)的異常情況。所以，消息的發(fā)送方應(yīng)該根據(jù)消息接收方的處理能力來(lái)控制己方的消息發(fā)送速度。

當(dāng)前的處理方式是，消息發(fā)送方根據(jù)消息接收方的處理能力預(yù)設(shè)一個(gè)最大發(fā)送速度，對(duì)單位時(shí)間內(nèi)的消息發(fā)送數(shù)量進(jìn)行累加，當(dāng)累計(jì)數(shù)量達(dá)到預(yù)設(shè)的最大值時(shí)，將暫停發(fā)送消息，直到下一個(gè)單位時(shí)間開(kāi)始重新累加計(jì)算發(fā)送速度。當(dāng)消息發(fā)送方的應(yīng)用服務(wù)是分布式部署，即存在多個(gè)節(jié)點(diǎn)同時(shí)向消息接收方發(fā)送消息時(shí)，為保證消息的總發(fā)送速度不超過(guò)預(yù)設(shè)最大值，則每個(gè)節(jié)點(diǎn)的最大發(fā)送速度均分總發(fā)送速度，即總發(fā)送速度M，節(jié)點(diǎn)數(shù)N，每個(gè)節(jié)點(diǎn)發(fā)送速度應(yīng)不大于M/N。

然而實(shí)際上每個(gè)節(jié)點(diǎn)的處理消息的能力是不同的，會(huì)造成有些節(jié)點(diǎn)消息出現(xiàn)擁堵而有些節(jié)點(diǎn)長(zhǎng)時(shí)間空閑的情況，這樣消息發(fā)送方整體的消息發(fā)送速度會(huì)低于接收方的最大消息處理能力，出現(xiàn)資源的浪費(fèi)。

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

針對(duì)現(xiàn)有技術(shù)的不足，本發(fā)明旨在提供一種控制消息發(fā)送速度的方法、存儲(chǔ)介質(zhì)及設(shè)備。

為了實(shí)現(xiàn)上述目的，本發(fā)明采用如下技術(shù)方案：

一種控制消息發(fā)送速度的方法，包括以下步驟：

S1、消息發(fā)送方在接收到待發(fā)送的消息后，先根據(jù)消息的時(shí)效性及業(yè)務(wù)屬性，按預(yù)設(shè)的劃分標(biāo)準(zhǔn)，將消息劃分優(yōu)先級(jí)，并放入所屬優(yōu)先級(jí)對(duì)應(yīng)的消息隊(duì)列；

S2、對(duì)各個(gè)優(yōu)先級(jí)的消息隊(duì)列進(jìn)行發(fā)送處理：

高優(yōu)先級(jí)的消息在發(fā)送前，先檢查當(dāng)前發(fā)送周期已發(fā)送的消息數(shù)量是否已達(dá)到最大發(fā)送數(shù)量；如果還沒(méi)有達(dá)到，將直接發(fā)送，并設(shè)置所屬優(yōu)先級(jí)的消息標(biāo)識(shí)，表示當(dāng)前發(fā)送周期有高優(yōu)先級(jí)消息需要發(fā)送；在發(fā)送完成后累計(jì)至當(dāng)前發(fā)送周期的已發(fā)送消息數(shù)量；

低優(yōu)先級(jí)的消息在發(fā)送前，先檢查當(dāng)前發(fā)送周期已發(fā)送的消息數(shù)量是否已達(dá)到最大發(fā)送數(shù)量；如果還沒(méi)有達(dá)到，再檢查當(dāng)前發(fā)送周期是否存在更高優(yōu)先級(jí)的消息標(biāo)識(shí)，如果沒(méi)有則直接發(fā)送；如果有，則檢查當(dāng)前發(fā)送周期已發(fā)送的消息數(shù)量是否已達(dá)到最大發(fā)送數(shù)量的預(yù)設(shè)百分比，如果沒(méi)有則直接發(fā)送，否則將等待至下一個(gè)發(fā)送周期再進(jìn)行發(fā)送處理；消息發(fā)送完成后，累計(jì)至當(dāng)前發(fā)送周期的已發(fā)送消息數(shù)量；如果當(dāng)前優(yōu)先級(jí)并非是最低優(yōu)先級(jí)，設(shè)置所屬優(yōu)先級(jí)的消息標(biāo)識(shí)，否則不設(shè)置消息標(biāo)識(shí)；

S3、在下一個(gè)發(fā)送周期開(kāi)始時(shí)，將已發(fā)送消息數(shù)量重置為0，并清空各優(yōu)先級(jí)的消息標(biāo)識(shí)。

進(jìn)一步地，當(dāng)消息發(fā)送方的應(yīng)用服務(wù)是分布式部署時(shí)，當(dāng)前發(fā)送周期的已發(fā)送消息數(shù)量和優(yōu)先級(jí)消息標(biāo)識(shí)存放在第三方緩存數(shù)據(jù)庫(kù)中；各個(gè)節(jié)點(diǎn)對(duì)本地各個(gè)優(yōu)先級(jí)的消息隊(duì)列進(jìn)行發(fā)送處理時(shí)，從第三方緩存數(shù)據(jù)庫(kù)獲取當(dāng)前發(fā)送周期的已發(fā)送消息數(shù)量和優(yōu)先級(jí)消息標(biāo)識(shí)，據(jù)此執(zhí)行步驟S2的發(fā)送處理過(guò)程。

本發(fā)明還提供一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，所述計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)內(nèi)存儲(chǔ)有計(jì)算機(jī)程序，所述計(jì)算機(jī)程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)上述方法。