[發(fā)明專利]一種降低消息中間件網(wǎng)絡(luò)負(fù)載的消息傳遞方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201010184227.8
• 申請(qǐng)日: 2010-05-24
• 公開(kāi)（公告）號(hào): CN101917332A
• 公開(kāi)（公告）日: 2010-12-15
• 發(fā)明（設(shè)計(jì)）人: 干紅華;姜建生;趙晨;俞弘;廖蘭新
• 申請(qǐng)（專利權(quán)）人: 寧波東海藍(lán)帆科技有限公司
• 主分類號(hào): H04L12/56
• 分類號(hào): H04L12/56;H04L29/08;H04L1/00
• 代理公司: 寧波奧圣專利代理事務(wù)所(普通合伙) 33226
• 代理人: 程曉明

1.一種降低消息中間件網(wǎng)絡(luò)負(fù)載的消息傳遞方法，其特征在于包括以下步驟：

①組建一個(gè)基于XML文本數(shù)據(jù)格式消息傳遞的消息中間件，該消息中間件包括至少兩個(gè)消息隊(duì)列服務(wù)器，將每個(gè)消息隊(duì)列服務(wù)器作為一個(gè)節(jié)點(diǎn)，在每個(gè)節(jié)點(diǎn)中設(shè)置具有能夠根據(jù)目標(biāo)節(jié)點(diǎn)的地址決定下一跳節(jié)點(diǎn)的地址且支持消息拆包和封包功能的應(yīng)用層路由模式；

②在每個(gè)節(jié)點(diǎn)中設(shè)置一個(gè)用于計(jì)算消息收集時(shí)間的第一計(jì)時(shí)模塊和一個(gè)用于計(jì)算消息等待時(shí)間的第二計(jì)時(shí)模塊，在第一計(jì)時(shí)模塊中設(shè)置一個(gè)最長(zhǎng)原始消息收集時(shí)間，在第二計(jì)時(shí)模塊中設(shè)置一個(gè)最長(zhǎng)原始消息等待時(shí)間，每個(gè)節(jié)點(diǎn)接收消息生產(chǎn)者或者上一個(gè)節(jié)點(diǎn)發(fā)出的多條原始消息，當(dāng)消息收集時(shí)間大于最長(zhǎng)原始消息收集時(shí)間時(shí)，認(rèn)為原始消息已經(jīng)被收集了足夠長(zhǎng)的時(shí)間，節(jié)點(diǎn)完成一次消息收集，或當(dāng)消息等待時(shí)間大于最長(zhǎng)原始消息等待時(shí)間時(shí)，認(rèn)為原始消息等待超時(shí)，節(jié)點(diǎn)完成一次消息收集；在此，假設(shè)消息生產(chǎn)者具有一個(gè)或多個(gè)功能，消息生產(chǎn)者的每個(gè)功能具有一個(gè)消息模板，對(duì)于消息生產(chǎn)者的同一個(gè)功能發(fā)出的多條原始消息結(jié)構(gòu)基本相同；

③定義當(dāng)前完成一次消息收集的節(jié)點(diǎn)為當(dāng)前節(jié)點(diǎn)；

④計(jì)算當(dāng)前節(jié)點(diǎn)中所有原始消息的結(jié)構(gòu)相似度，并根據(jù)結(jié)構(gòu)相似度對(duì)所有原始消息進(jìn)行一次分類，得到多個(gè)同類原始消息集；

⑤當(dāng)前節(jié)點(diǎn)根據(jù)每個(gè)同類原始消息集中各個(gè)原始消息的下一跳節(jié)點(diǎn)的地址，對(duì)每個(gè)同類原始消息集中的所有原始消息進(jìn)行二次分類，得到多個(gè)同類原始消息子集，每個(gè)同類原始消息子集中的各條原始消息具有共同的下一跳節(jié)點(diǎn)的地址；

⑥定義當(dāng)前正在處理的同類原始消息子集為當(dāng)前同類原始消息子集，提取當(dāng)前同類原始消息子集中所有原始消息的相同部分內(nèi)容，并在所有原始消息的相異部分內(nèi)容中標(biāo)上各個(gè)原始消息各自的目標(biāo)節(jié)點(diǎn)的地址，將當(dāng)前同類原始消息子集中的所有原始消息的相同部分內(nèi)容與相異部分內(nèi)容進(jìn)行差分編碼，并封包成一條已編碼消息，然后當(dāng)前節(jié)點(diǎn)根據(jù)共同的下一跳節(jié)點(diǎn)的地址，將已編碼消息發(fā)送給對(duì)應(yīng)的下一跳節(jié)點(diǎn)；

⑦將下一個(gè)待處理的同類原始消息子集作為當(dāng)前同類原始消息子集，重復(fù)執(zhí)行步驟⑥的過(guò)程，直至所有同類原始消息子集處理完畢；

⑧下一跳節(jié)點(diǎn)接收已編碼消息，將該下一跳節(jié)點(diǎn)作為當(dāng)前節(jié)點(diǎn)，該當(dāng)前節(jié)點(diǎn)對(duì)已編碼消息進(jìn)行拆包解析，得到多條原始消息；

⑨定義解析出的多條原始消息中當(dāng)前正在處理的原始消息為當(dāng)前原始消息，判斷當(dāng)前原始消息的目標(biāo)節(jié)點(diǎn)的地址是否為當(dāng)前節(jié)點(diǎn)，如果是，則當(dāng)前節(jié)點(diǎn)將當(dāng)前原始消息發(fā)送給當(dāng)前節(jié)點(diǎn)對(duì)應(yīng)的消息消費(fèi)者，并繼續(xù)執(zhí)行，否則，對(duì)當(dāng)前原始消息不進(jìn)行處理；

⑩將解析出的多條原始消息中下一條待處理的原始消息作為當(dāng)前原始消息，并返回執(zhí)行步驟⑨，直至解析出的多條原始消息全部處理完畢；

對(duì)于當(dāng)前節(jié)點(diǎn)解析出的多條原始消息中未處理的所有原始消息，重復(fù)執(zhí)行步驟④至⑩，以完成消息生產(chǎn)者發(fā)出的所有原始消息到達(dá)消息消費(fèi)者。

2.根據(jù)權(quán)利要求1所述的一種降低消息中間件網(wǎng)絡(luò)負(fù)載的消息傳遞方法，其特征在于所述的步驟②中消息收集時(shí)間為：第一計(jì)時(shí)模塊從節(jié)點(diǎn)完成一次消息收集以后開(kāi)始計(jì)時(shí)，節(jié)點(diǎn)完成下一次消息收集后第一計(jì)時(shí)模塊重新開(kāi)始計(jì)時(shí)，該過(guò)程中第一計(jì)時(shí)模塊所計(jì)的時(shí)間為消息收集時(shí)間；消息等待時(shí)間為：第二計(jì)時(shí)模塊從上一條原始消息到達(dá)節(jié)點(diǎn)后開(kāi)始計(jì)時(shí)，在下一條原始消息到達(dá)節(jié)點(diǎn)后第二計(jì)時(shí)模塊重新開(kāi)始計(jì)時(shí)，該過(guò)程中第二計(jì)時(shí)模塊所計(jì)的時(shí)間為消息等待時(shí)間。