[發(fā)明專利]信息遞送系統(tǒng)和方法

有效

• 申請?zhí)枺?/td>: 201010197976.4
• 申請日: 2010-06-03
• 公開（公告）號: CN102271147A
• 公開（公告）日: 2011-12-07
• 發(fā)明（設(shè)計）人: 陳學理;張云海;李文瑾
• 申請（專利權(quán)）人: 北京神州綠盟信息安全科技股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L1/00
• 代理公司: 中國專利代理(香港)有限公司 72001
• 代理人: 謝建云;譚祐祥

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

本發(fā)明涉及信息收集、分發(fā)和處理領(lǐng)域，尤其涉及一種分布式的、從多個計算節(jié)點收集信息并將這些信息分發(fā)到相應(yīng)處理系統(tǒng)進行處理的信息遞送系統(tǒng)和方法。

背景技術(shù)

在網(wǎng)絡(luò)中，尤其是在國際互聯(lián)網(wǎng)中，隨著網(wǎng)絡(luò)用戶的不斷增加和網(wǎng)絡(luò)服務(wù)所覆蓋的范圍越來越廣，經(jīng)常需要將大量的服務(wù)節(jié)點部署在多個不同的網(wǎng)絡(luò)位置和網(wǎng)絡(luò)服務(wù)提供者處，以便快速和方便地為遍布各地并使用不同網(wǎng)絡(luò)接入系統(tǒng)的用戶提供服務(wù)。經(jīng)常地，這些服務(wù)節(jié)點需要收集與用戶相關(guān)的信息，并且發(fā)送到中心處理節(jié)點進行統(tǒng)一處理。在這種大型的系統(tǒng)中，服務(wù)節(jié)點和中心處理節(jié)點通常都是以集群和/或分布式方式存在，因而，如何在這些節(jié)點之間遞送消息以及如何實現(xiàn)節(jié)點之間的負載均衡就成了這類系統(tǒng)設(shè)計的一個重要方面。

本發(fā)明的申請人在申請?zhí)枮?00910084545.4的專利申請中公開了一種主機探測系統(tǒng)，該主機探測系統(tǒng)基于云安全的思想，利用大量分布廣泛的探測器來收集主機信息，并且由中心部件來對從探測器收集的主機信息進行分析和處理以便獲得實時和準確的主機信息。在此系統(tǒng)中，多種類的探測器適應(yīng)于不同的網(wǎng)絡(luò)拓撲，所提供的主機信息也針對不同的拓撲結(jié)構(gòu)和主機類型進行了針對性的類型修改，因此需要一種機制將大量分散的主機信息傳遞到中心部件來分析和處理。

現(xiàn)有的用于將各個探測器的信息發(fā)送到中心部件的方法直接將主機信息發(fā)送到中心部件。這種現(xiàn)有的方法存在兩個問題，首先，由于探測器分布廣泛且數(shù)量龐大，而中心部件數(shù)量有限，當大量探測器同時發(fā)送主機信息時，很容易造成中心部件的通信鏈路被堵塞而不可用；其次，當中心部件也分布在網(wǎng)絡(luò)中的各個位置處時，即使使用了現(xiàn)有的服務(wù)器集群和負載均衡技術(shù)，也只能保證在某個集群中的中心部件的工作負荷均衡，而無法保證所有中心部件的均衡工作，而很容易造成其中有幾個中心部件節(jié)點“餓死”，而有其他幾個中心部件節(jié)點“撐死”的情況。

因此，所希望的是提供一種改進的信息遞送系統(tǒng)和方法，其能夠?qū)碜杂嬎愎?jié)點的大量消息快速地發(fā)送到中心節(jié)點進行處理，而不會導致中心節(jié)點的負載明顯失衡以及通信阻塞。

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

本發(fā)明的目的在于提供一種可以解決或者至少緩解現(xiàn)有技術(shù)中的問題的信息遞送系統(tǒng)和方法，其特別適合于具有大量計算節(jié)點向中心處理系統(tǒng)快速和可靠地遞送信息進行處理的情況，其中中心處理系統(tǒng)也具有多個分布式的中心節(jié)點，并且這些中心節(jié)點能夠以均衡方式處理從計算節(jié)點遞送過來的信息。

根據(jù)本發(fā)明的一個方面，提供了一種用于在網(wǎng)絡(luò)中遞送信息的信息遞送系統(tǒng)，包括：至少一個計算節(jié)點，用于從網(wǎng)絡(luò)中收集各種信息；至少一個信息收集分發(fā)設(shè)備，用于接收所述計算節(jié)點所收集的信息，并且存儲所述信息；以及至少一個信息分析器，用于從所述信息收集分發(fā)設(shè)備獲取信息以進行處理，其中每個計算節(jié)點保持信息收集分發(fā)設(shè)備列表，并從中選擇要向其發(fā)送信息的信息收集分發(fā)設(shè)備，每個信息收集分發(fā)設(shè)備保持活躍信息收集分發(fā)設(shè)備列表，并且和其它信息收集分發(fā)設(shè)備進行交互以更新該活躍信息收集分發(fā)設(shè)備列表，以及所述計算節(jié)點利用所述信息收集分發(fā)設(shè)備所保持的活躍信息收集分發(fā)設(shè)備列表來更新所述計算節(jié)點的信息收集分發(fā)設(shè)備列表。

根據(jù)本發(fā)明的另一個方面，提供了一種利用信息遞送系統(tǒng)在網(wǎng)絡(luò)中傳遞信息的方法，該信息遞送系統(tǒng)包括至少一個用于從網(wǎng)絡(luò)中收集各種信息的計算節(jié)點、至少一個信息收集分發(fā)設(shè)備和至少一個信息分析器，該方法包括步驟：所述計算節(jié)點確定要向其發(fā)送信息的信息收集分發(fā)設(shè)備；所確定的信息收集分發(fā)設(shè)備接收并存儲所述計算節(jié)點所收集的信息；以及所述信息分析器從所述信息收集分發(fā)設(shè)備獲取信息以進行處理，其中所述信息收集分發(fā)設(shè)備通過與其它信息收集分發(fā)設(shè)備進行交互來更新其保持的活躍信息收集分發(fā)設(shè)備列表，所述計算節(jié)點根據(jù)所述信息收集分發(fā)設(shè)備保持的活躍信息收集分發(fā)設(shè)備列表根據(jù)其保持的信息收集分發(fā)設(shè)備列表，以及所述計算節(jié)點通過從其所保持的信息收集分發(fā)設(shè)備列表中選擇信息收集分發(fā)設(shè)備之一來確定要向其發(fā)送信息的信息收集分發(fā)設(shè)備。

根據(jù)本發(fā)明的還有一個方面，提供了一種信息收集分發(fā)設(shè)備，用于接收一個或者多個計算節(jié)點收集的信息并存儲所述信息，所述信息收集分發(fā)設(shè)備包括：信息接收器，用于從所述計算節(jié)點接收信息，并緩存所接收的信息；以及信息存儲器，用于接收并存儲所述信息接收器所緩存的信息，其中所述信息收集分發(fā)設(shè)備保持活躍信息收集分發(fā)設(shè)備列表，和其它信息收集分發(fā)設(shè)備進行交互以更新該活躍信息收集分發(fā)設(shè)備列表，并且將所保持的活躍信息收集分發(fā)設(shè)備列表發(fā)送給所述計算節(jié)點以更新所述計算節(jié)點的信息收集分發(fā)設(shè)備列表。