[發(fā)明專(zhuān)利]一種網(wǎng)上發(fā)布信息系統(tǒng)及方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201710094319.9
• 申請(qǐng)日: 2017-02-22
• 公開(kāi)（公告）號(hào): CN106933989B
• 公開(kāi)（公告）日: 2021-01-05
• 發(fā)明（設(shè)計(jì)）人: 黎逵
• 申請(qǐng)（專(zhuān)利權(quán)）人: 深圳云視融通科技有限公司
• 主分類(lèi)號(hào): G06F16/9535
• 分類(lèi)號(hào): G06F16/9535;H04L29/08
• 代理公司: 暫無(wú)信息
• 代理人: 暫無(wú)信息

本發(fā)明涉及一種網(wǎng)上發(fā)布信息系統(tǒng)的方法，網(wǎng)上發(fā)布信息系統(tǒng)包含多個(gè)發(fā)布客戶(hù)、代理網(wǎng)絡(luò)、發(fā)布/訂閱模塊、多個(gè)訂閱客戶(hù)以及管理集群；發(fā)布/訂閱模塊包含消息存儲(chǔ)器、消息分段器、用戶(hù)訂閱管理器、消息分發(fā)器；所述方法包含系統(tǒng)相關(guān)的關(guān)鍵過(guò)程；本發(fā)明為了解決計(jì)算機(jī)理解信息資源的問(wèn)題,將語(yǔ)義技術(shù)與發(fā)布訂閱系統(tǒng)有機(jī)地結(jié)合,在語(yǔ)義層的角度上來(lái)理解發(fā)布客戶(hù)與訂閱客戶(hù)的本意,使發(fā)布的事件能更準(zhǔn)確地匹配訂閱者的要求,從而提高訂閱與發(fā)布匹配的質(zhì)量,提高整個(gè)系統(tǒng)的性能。

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

本發(fā)明涉及計(jì)算機(jī)網(wǎng)絡(luò)領(lǐng)域，涉及一種網(wǎng)上發(fā)布信息系統(tǒng)及方法。

背景技術(shù)

隨著互聯(lián)網(wǎng)成為無(wú)處不在的計(jì)算和存儲(chǔ)服務(wù)平臺(tái)，如何把數(shù)據(jù)源產(chǎn)生的數(shù)據(jù)快速地、準(zhǔn)確地分發(fā)至具有不同興趣的大規(guī)模用戶(hù)群體是當(dāng)前亟需解決的關(guān)鍵技術(shù)問(wèn)題。基于內(nèi)容的發(fā)布/訂閱因其松耦合的通訊模式適用于大規(guī)模分布式系統(tǒng)且為用戶(hù)提供了強(qiáng)大的語(yǔ)義表達(dá)能力，正成為實(shí)現(xiàn)數(shù)據(jù)分發(fā)的主要模式。

為了實(shí)現(xiàn)基于內(nèi)容的彈性可擴(kuò)展發(fā)布/訂閱服務(wù)，當(dāng)前面臨的技術(shù)挑戰(zhàn)主要包括以下兩個(gè)方面：用事件來(lái)表示發(fā)布消息以及訂閱消息，事件匹配技術(shù)能夠有效地過(guò)濾出對(duì)事件不感興趣的訂閱者，從而降低數(shù)據(jù)分發(fā)延遲；高效的事件路由技術(shù)是保證數(shù)據(jù)分發(fā)實(shí)時(shí)性的重要因素，然而，大數(shù)據(jù)塊分發(fā)中上傳帶寬存在著性能瓶頸。

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

有鑒于此，本發(fā)明提供一種解決或部分解決上述問(wèn)題的一種網(wǎng)上發(fā)布信息系統(tǒng)及方法。

為達(dá)到上述技術(shù)方案的效果，本發(fā)明的技術(shù)方案為：一種網(wǎng)上發(fā)布信息系統(tǒng)及方法，包含以下步驟：

網(wǎng)上發(fā)布信息系統(tǒng)包含多個(gè)發(fā)布客戶(hù)、代理網(wǎng)絡(luò)、發(fā)布/訂閱模塊、多個(gè)訂閱客戶(hù)以及管理集群；發(fā)布/訂閱模塊包含消息存儲(chǔ)器、消息分段器、用戶(hù)訂閱管理器、消息分發(fā)器；方法包含系統(tǒng)相關(guān)的關(guān)鍵過(guò)程；

代理網(wǎng)絡(luò)由多個(gè)子網(wǎng)絡(luò)組成，子網(wǎng)絡(luò)是一個(gè)主節(jié)點(diǎn)與節(jié)點(diǎn)構(gòu)成的網(wǎng)絡(luò)，每個(gè)節(jié)點(diǎn)被分為二層，第一層存儲(chǔ)節(jié)點(diǎn)的優(yōu)先級(jí)，第二層為臨時(shí)存儲(chǔ)區(qū)，在臨時(shí)存儲(chǔ)區(qū)中存儲(chǔ)訂閱的分類(lèi)關(guān)鍵詞、子分類(lèi)號(hào)以及一個(gè)計(jì)數(shù)器，按節(jié)點(diǎn)的優(yōu)先級(jí)的先后將節(jié)點(diǎn)進(jìn)行連接，優(yōu)先級(jí)高的節(jié)點(diǎn)先連接，使用虛擬鏈路進(jìn)行連接，虛擬鏈路能夠隨時(shí)斷開(kāi)并且隨時(shí)在節(jié)點(diǎn)之間建立連接關(guān)系；每個(gè)子網(wǎng)絡(luò)為表示的是訂閱的一個(gè)類(lèi)別，在主節(jié)點(diǎn)中存儲(chǔ)訂閱的一個(gè)類(lèi)別的關(guān)鍵詞以及分類(lèi)號(hào)，而把每一個(gè)類(lèi)別的訂閱的關(guān)鍵詞分配到每個(gè)節(jié)點(diǎn)中，節(jié)點(diǎn)的優(yōu)先級(jí)為分配訂閱的關(guān)鍵詞時(shí)分配的順序的依據(jù)；

關(guān)鍵過(guò)程包含發(fā)布客戶(hù)發(fā)送發(fā)布消息給發(fā)布/訂閱模塊的過(guò)程，具體如下：

在多個(gè)發(fā)布客戶(hù)將發(fā)布消息傳輸給發(fā)布/訂閱模塊之前，對(duì)發(fā)布消息進(jìn)行二次搜索，一次搜索為搜索發(fā)布消息中是否存在某一類(lèi)訂閱的關(guān)鍵詞，在搜索的過(guò)程中對(duì)主節(jié)點(diǎn)進(jìn)行調(diào)用，當(dāng)發(fā)現(xiàn)多個(gè)關(guān)鍵詞符合的主節(jié)點(diǎn)，關(guān)鍵詞符合越多的主節(jié)點(diǎn)作為滿(mǎn)足條件的主節(jié)點(diǎn)，并將分類(lèi)號(hào)分配給發(fā)布消息，滿(mǎn)足條件的主節(jié)點(diǎn)所在的子網(wǎng)絡(luò)勝出，將發(fā)布消息廣播給其下的所有節(jié)點(diǎn)，所有節(jié)點(diǎn)按優(yōu)先級(jí)進(jìn)行匹配，與訂閱的分類(lèi)關(guān)鍵詞進(jìn)行匹配，匹配上的節(jié)點(diǎn)中存儲(chǔ)的計(jì)數(shù)器加一，并在分類(lèi)號(hào)的基礎(chǔ)上再分配子分類(lèi)號(hào)，計(jì)數(shù)器用于記錄節(jié)點(diǎn)被匹配的次數(shù)，將發(fā)布消息連同分類(lèi)號(hào)以及子分類(lèi)號(hào)傳送給發(fā)布/訂閱模塊；對(duì)滿(mǎn)足條件的主節(jié)點(diǎn)所在的子網(wǎng)絡(luò)中的節(jié)點(diǎn)進(jìn)行實(shí)時(shí)地調(diào)整優(yōu)先級(jí)，調(diào)整的依據(jù)為計(jì)數(shù)器中的數(shù)字大小，數(shù)字越大，節(jié)點(diǎn)的優(yōu)先級(jí)越高，將匹配上的節(jié)點(diǎn)的優(yōu)先級(jí)進(jìn)行調(diào)整，如果為第一次調(diào)整，直接插入到滿(mǎn)足條件的主節(jié)點(diǎn)所在的子網(wǎng)絡(luò)的第一個(gè)節(jié)點(diǎn)之前，其余情況下，與前后相鄰的節(jié)點(diǎn)的計(jì)數(shù)器的數(shù)字進(jìn)行比較，采取二分法逐漸縮小插入位置的范圍，將匹配上的節(jié)點(diǎn)插入，使計(jì)數(shù)器中數(shù)字大的節(jié)點(diǎn)排列在子網(wǎng)絡(luò)中前面的位置；

關(guān)鍵過(guò)程還包含如何建立系統(tǒng)的數(shù)據(jù)模型；

系統(tǒng)的數(shù)據(jù)模型包含消息的表示邏輯與存儲(chǔ)格式，首先，將消息的類(lèi)型分為發(fā)布消息與訂閱消息兩種，發(fā)布消息包含需要發(fā)布的標(biāo)題以及發(fā)布的內(nèi)容，訂閱消息包含訂閱客戶(hù)需要訂閱的內(nèi)容；