異步分布式列對象請求代理系統應用方法
2023-04-23 00:42:46
專利名稱：異步分布式列對象請求代理系統應用方法
技術領域：
本發明涉及一種異步分布式列對象請求代理系統的應用方法，屬於分布式網絡監控系統領域。
背景技術：
隨著計算機網絡和電信網的快速發展和膨脹，人們對於網絡的安全，可靠的要求越來越高，網絡監控系統可以讓用戶有效的監控、分配有限的網絡資源。傳統的網絡監控系統採用集中運行模式，中心伺服器負責對整個網絡進行統一的監控和管理。這種模式下，大量的監控或管理信息傳輸會消耗網絡帶寬，且中心伺服器往往超負荷工作，嚴重影響監控系統的運行效率。這種系統結構較簡單，但是可擴展性差，如果中心伺服器失效，將引起整個網絡無法監控。為了克服集中式監控的缺陷，可以進行分布式層次監控，由多個監控伺服器進行監控，再將監控結果層層匯總。在這樣的體系結構中會有很多個監控伺服器存在。這種系統可以進行分布式分層次監控，可以滿足現有超大網絡的監控需求。但分布式分層次監控系統的體系結構比較複雜，系統各個伺服器間都需要互相調用，這首先需要一種能夠異步響應的，分布式的請求代理系統來滿足層次調用的要求，同時，傳統的監控數據使用對象傳遞，該方式不能有效的利用現有帶寬，因此監控數據本身的傳輸也需要一種能更高效利用現有網絡帶寬的方式。
發明內容
為了解決上述問題，本發明提供了一種異步分布式列對象請求代理系統的應用方法。具體技術方案如下
本發明實施例提供的一種異步分布式列對象請求代理系統的應用方法，包括
51、第一子系統接收到符合本命名服務命名的消息；
52、Gate把請求傳遞給軟體總線處理；
53、軟體總線讀取請求消息中請求信息，匹配在總線中註冊的樁信息尋找請求代理單元的樁，並傳遞請求消息給請求代理；
54、請求代理根據請求數據，填充代理追蹤信息入棧，若請求本系統服務，傳遞消息到本地服務單元，並直接進入S6，若請求其他系統數據，則請求代理需要按照本地緩存的命名信息尋找第二子系統的命名服務，並發送給第二子系統的fete處理該消息；
55、第二子系統的fete收到請求消息，並重複步驟中的Sl到S4；
56、服務單元收到請求消息後，令該消息進入本服務待處理隊列；
57、服務單元提醒調度器，本服務有請求需要執行，調度器調度該服務單元運行請求；
58、服務單元運行請求後得到一個響應消息，該響應消息中包含了代理追蹤棧，服務發送響應消息給請求代理，根據消息的追蹤信息，該響應消息傳遞給消息的請求單元。
作為本發明的進一步改進，所述S7步驟的響應消息是異步發送的消息，消息發送者在發送消息後不需要等待該消息的響應，該消息的請求者需要以異步的方式獲取消息的響應。作為本發明的進一步改進，若一個服務單元調用其他單元的服務，且其他單元的位置是通過本系統內的請求代理來確定的，其步驟為
S10、服務單元發送對其他單元的調用請求消息給總線；
S20、軟體總線讀取請求消息中請求信息，匹配在總線中註冊的樁信息尋找請求代理單元的樁信息，並傳遞請求消息給請求代理；
S30、請求代理根據請求數據，填充代理追蹤信息入棧，若請求本系統服務，傳遞消息到本地服務單元，並直接進入S50，若請求其他系統數據，則請求代理需要按照本地緩存的命名信息尋找第二子系統的命名服務，並發送給第二子系統的fete處理該消息； S40、第二子系統的(iate收到請求消息，並重複Sl到S4 ； S50、其他單元收到請求消息後，令該消息進入本服務待處理隊列； S60、服務單元提醒調度器，本服務有請求需要執行，調度器調度該服務單元運行請
求；
S70、服務單元運行請求後得到一個響應消息，該響應消息中包含了代理追蹤棧，服務發送響應消息給請求代理，根據消息的追蹤信息，該響應消息會最終被傳遞給消息的請求單元。作為本發明的進一步改進，所述S8和S70具體包括以下步驟 S100、服務單元把運行請求後得到的響應消息，發送給系統所在的總線； S200、總線獲取請求代理樁信息後，發送該響應消息給請求代理單元；
S300、請求代理單元按照消息中包含的代理追蹤棧信息，分情況處理，如果該響應對應的請求在本伺服器，則直接發送該響應消息給本伺服器的請求單元，到此，本次請求響應的流程結束，否則進行S400;
S400、如過該響應的請求不在本伺服器，請求代理需要按照本地緩存的命名信息尋找第一子系統的命名服務，並發送給第一子系統的fete處理該響應消息；
S500、第一子系統的fete收到響應消息後，發送給總線處理，總線獲取第一子系統上的請求代理單元處理該響應消息；
S600、第一子系統上的請求代理，按照消息中包含的代理追蹤棧信息，重複S300的處理，直到本次請求響應的流程結束。作為本發明的進一步改進，所述各單元間的交互是通過會話傳遞的，一個會話封裝了單元和單元間通信的管道，該管道的底層實現可以是tcp或Udp或ipc三種方式，在會話中單元可以進行發送一個請求，響應一個請求，主動發送一個通知的操作。 由以上技術方案可以看出，本發明的異步分布式列對象請求代理系統能適應從小網絡到大網絡到超大網絡的分布式層次監控要求，列對象數據壓縮傳輸能有效的節約網絡帶寬，達成高效監控大網絡的目的。
圖1是本發明一實施方式分布式子系統的單元圖； 圖2是本發明一實施方式分布式子系統交互的示意圖；圖3是本發明一實施方式異步分布式列對象請求代理系統的應用方法的流程圖； 圖4是本發明另一實施方式異步分布式列對象請求代理系統的應用方法的流程圖； 圖5是S8和S70的具體流程圖。
具體實施方式
為了使本發明的目的、技術方案和優點更加清楚，下面結合附圖和具體實施例對本發明進行詳細描述。對批量監控數據本身的傳輸，需要使用列對象方式。因列對象傳輸只傳遞一個列名稱和多個列數據來組成網絡監控數據，且順序、高度重複的數據可以產生更高的壓縮比， 故本發明中的列對象本身也被設計為是一個具備高壓縮比的數據集，本系統中各個服務單元的調用都是採用這個列對象來傳遞請求和響應消息。在此基礎上構建的本分布式列對象請求代理系統中的單元或系統間調用的消息定義(包括請求消息，請求響應消息，通知消息)具備了高壓縮比，可以快速傳遞的特性，能夠有效的減小對監控網絡的帶寬需求。如圖1所示，在本發明一實施方式中，異步分布式列對象請求代理系統由多個分布式子系統構成，每個分布式子系統包括
TCP/UDP/IPC (kite單元用於負責系統中各單元或系統的底層通信實現，TCP (kite為 TCP (傳輸控制協議)方式的通信實現，UDP fete為UDP (用戶數據報協議)方式的通信實現，IPC Gate (Inner Process Communication)為進程內的通信實現。命名服務單元用於負責系統間調用的命名解析，名字格式為「協議//地址[ 埠 ]/單元名」，協議可選數據為tcp/udp/ipc，分別對應組件中的三種(iate，通過一個指定的命名即可以獲得一個可供單元進行請求/響應或通知操作的會話。軟體總線用於管理一個系統內所有可以提供服務的軟體單元，每個軟體單元註冊到軟體總線後，才可以對外提供服務，同時，只有該單元註冊到軟體總線後，才可以向其他單元請求服務。總線樁每個接入到軟體總線的單元，必須存在一個總線樁，總線樁負責單元和總線的交互，從其他伺服器來得請求到達軟體總線後，總線調度總線樁發送請求給單元，在單元處理完成後，單元發送相應給總線樁，由總線樁請求總線調度返回結果給請求伺服器。調度器所有需要CPU執行的代碼都必須通過調度器調度運行。調度器以負載均衡的方式實現任務按照優先級調度，以保障伺服器穩定運行。請求代理單元請求代理管理請求可以到達的對端，該對端可以是本機也可以是不是本機，甚至可以是多個層次嵌套下的主機，因此請求代理屏蔽了具體執行任務的機器的位置，對於一個原始請求來說，其只需要按照命名向具備請求代理的軟體總線請求服務， 軟體總線向請求代理髮起請求後，請求代理按照命名情況決定轉發請求到本總線對應的單元或其他機器上的對應單元，請求代理的存在使得靈活的部署多個層次的分布式伺服器成為可能。以上單元間的交互是通過會話傳遞的，一個會話封裝了單元和單元間通信的管道，該管道的底層實現可以是tcp/udp/ipc三種方式，在會話中單元可以進行發送一個請求，響應一個請求，主動發送一個通知的操作。如圖2、圖3所示，在本發明一實施方式中，異步分布式列對象請求代理系統包括子系統A和子系統B，在分布式子系統A在fete接收到一個Client請求消息後的對這個請求消息的處理流程
51、子系統A接收到符合本命名服務命名的消息，注意如果消息指定的命名不在本系統，則該消息不會被本系統接收；
52、Gate把請求傳遞給軟體總線處理，注意，此處傳遞的具體含義為創建一個會話，在會話中傳輸消息，後面每個步驟中的傳遞均為此處的含義，後面的步驟的描述直接使用傳遞；
53、軟體總線讀取請求消息中請求信息，匹配在總線中註冊的樁信息尋找請求代理單元的樁，並傳遞請求消息給請求代理；
54、請求代理根據請求數據，填充代理追蹤信息入棧，若請求本系統服務，傳遞消息到本地服務單元，並直接進入S6，若請求其他系統數據(示意圖中為子系統B)，則請求代理需要按照本地緩存的命名信息尋找子系統B的命名服務，並發送給子系統B的fete處理該消息；
55、子系統B的fete收到請求消息，類似的，子系統B的處理需要重複步驟中的Sl到
S4；
56、服務單元收到請求消息後，令該消息進入本服務待處理隊列；
57、服務單元提醒調度器，本服務有請求需要執行。調度器會在合適的時候調度該服務單元運行請求；
58、服務單元運行請求後得到一個響應消息，該響應消息中包含了代理追蹤棧，服務發送響應消息給請求代理。根據消息的追蹤信息，該響應消息會最終被傳遞給消息的請求單兀。需要指出的是，S7的響應消息是個異步發送的消息，消息發送者在發送消息後不需要等待該消息的響應，該消息的請求者需要以異步的方式獲取消息的響應。同樣的，如圖4所示，若一個服務單元(假設其為單元S-A)如果調用其他單元的服務(假設其為單元S-B)，該單元S-B的位置是通過本系統內的請求代理來確定的，單元S-A 並不知道S-B的具體位置是否和S-A在同一系統內，其步驟為
S10、S-A發送對S-B單元的調用請求消息給總線；
S20、軟體總線讀取請求消息中請求信息，匹配在總線中註冊的樁信息尋找請求代理單元的樁信息，並傳遞請求消息給請求代理；
S30、請求代理根據請求數據，填充代理追蹤信息入棧，若請求本系統服務，傳遞消息到本地服務單元，並直接進入S50，若請求其他系統數據(本圖為子系統B)，則請求代理需要按照本地緩存的命名信息尋找子系統B的命名服務，並發送給子系統B的fete處理該消息；
S40、子系統B的(iate收到請求消息，類似的，子系統B的處理應該重複Sl到S4。S50、服務單元B收到請求消息後，令該消息進入本服務待處理隊列；
S60、服務單元提醒調度器，本服務有請求需要執行。調度器會在合適的時候調度該服務單元運行請求；
S70、服務單元運行請求後得到一個響應消息，該響應消息中包含了代理追蹤棧，服務發送響應消息給請求代理。根據消息的追蹤信息，該響應消息會最終被傳遞給消息的請求單元。進一步的，如圖5所示，S8和S70，請求代理單元都在發送響應消息給請求的單元，假設該服務單元位於子系統B，其收到一個請求，並由調度器調度運行後產生了對應的響應，詳細步驟如下
S100、服務單元把運行請求後得到的響應消息，發送給系統所在的總線； S200、總線獲取請求代理樁信息後，發送該響應消息給請求代理單元； S300、請求代理單元按照消息中包含的代理追蹤棧信息，分情況處理，如果該響應對應的請求在本伺服器，則直接發送該響應消息給本伺服器的請求單元，到此，本次請求響應的流程結束。否則進行S400;
S400、如過該響應的請求不在本伺服器(假設請求單元在子系統A)，請求代理需要按照本地緩存的命名信息尋找子系統A的命名服務，並發送給子系統A的fete處理該響應消息；
S500、子系統A的fete收到響應消息後，發送給總線處理。總線獲取子系統A上的請求代理單元處理該響應消息；
S600、子系統A上的請求代理，按照消息中包含的代理追蹤棧信息，重複S300的處理， 直到本次請求響應的流程結束。需要注意的是S300到S600的處理何時跳出，取決於系統的層次關係，分布式系統的層次如果為N層，則該循環至多循環N-I次即可結束處理。需要注意的是本異步分布式列對象請求代理系統不需要區分Client和krver， 實際上只要是採用本分布式對象請求代理體系結構的系統，即可以按照各自的命名互相訪問，互為Client,互為Server。異步分布式列對象請求代理系統的應用方法適用於如下幾種情況
第一種所有的服務單元都在本端，這種形式適用於小網絡，如校園網的監控，單伺服器模式即可以完成網絡的監控。這種部署可以很方便的修改為第二種應用方式。第二種分服務平行部署，不對伺服器分層。即部分服務單元在一臺伺服器，另外部分服務單元在另外的伺服器等，這種模式下，可以按照服務單元的多少切分為2個或更多的平行伺服器。一個同樣應用了本體系結構Client可以按照服務的命名向各平行伺服器請求服務，這種模式可以適應更大規模的網絡監控，如一些流量很大的校園網或企業網， 這種模式下可以很方便的建立平行的服務集群。第三種分層網格式應用部署
首先按照網絡規模切分為N個子監控網絡。其次，在N個子網絡上，可部署N個單機服務系統，在N個子網上可部署M個(M N) 大網系統。優選地，還可以進一步對N個單機系統進一步切分，如每個單機切分成X個平行服務，則需要部署為N*X個平行子網絡監控系統。最後，在M個大網絡系統上可部署一個或多個頂層網絡監控系統。同時，本方式的頂層系統，也可以應用為多個平行頂層系統，如監控全網絡告警的頂層系統為一個單獨的頂層監控子系統，監控性能的頂層系統為一個單獨的頂層監控子系統。為了描述的方便，描述以上裝置時以功能分為各種單元分別描述。當然，在實施本申請時可以把各單元的功能在同一個或多個軟體和/或硬體中實現。通過以上的實施方式的描述可知，本領域的技術人員可以清楚地了解到本申請可藉助軟體加必需的通用硬體平臺的方式來實現。基於這樣的理解，本申請的技術方案本質上或者說對現有技術做出貢獻的部分可以以軟體產品的形式體現出來，該計算機軟體產品可以存儲在存儲介質中，如ROM/RAM、磁碟、光碟等，包括若干指令用以使得一臺計算機設備 (可以是個人計算機，伺服器，或者網絡設備等)執行本申請各個實施方式或者實施方式的某些部分所述的方法。以上所描述的裝置實施方式僅僅是示意性的，其中所述作為分離部件說明的單元可以是或者也可以不是物理上分開的，作為單元顯示的部件可以是或者也可以不是物理單元，即可以位於一個地方，或者也可以分布到多個網絡單元上。可以根據實際的需要選擇其中的部分或者全部單元來實現本實施方式方案的目的。本領域普通技術人員在不付出創造性勞動的情況下，即可以理解並實施。本申請可用於眾多通用或專用的計算系統環境或配置中。例如個人計算機、伺服器計算機、手持設備或可攜式設備、平板型設備、多處理器系統、基於微處理器的系統、置頂盒、可編程的消費電子設備、網絡PC、小型計算機、大型計算機、包括以上任何系統或設備的分布式計算環境等等。本申請可以在由計算機執行的計算機可執行指令的一般上下文中描述，例如程序單元。一般地，程序單元包括執行特定任務或實現特定抽象數據類型的例程、程序、對象、組件、數據結構等等。也可以在分布式計算環境中實踐本申請，在這些分布式計算環境中，由通過通信網絡而被連接的遠程處理設備來執行任務。在分布式計算環境中，程序單元可以位於包括存儲設備在內的本地和遠程計算機存儲介質中。應當理解，雖然本說明書按照實施方式加以描述，但並非每個實施方式僅包含一個獨立的技術方案，說明書的這種敘述方式僅僅是為清楚起見，本領域技術人員應當將說明書作為一個整體，各實施方式中的技術方案也可以經適當組合，形成本領域技術人員可以理解的其他實施方式。上文所列出的一系列的詳細說明僅僅是針對本發明的可行性實施方式的具體說明，它們並非用以限制本發明的保護範圍，凡未脫離本發明技藝精神所作的等效實施方式或變更均應包含在本發明的保護範圍之內。
權利要求
1.一種異步分布式列對象請求代理系統的應用方法，其特徵在於，當第一子系統在 Gate接收到一個Client請求消息後，所述方法包括以下步驟51、第一子系統接收到符合本命名服務命名的消息；52、Gate把請求傳遞給軟體總線處理；53、軟體總線讀取請求消息中請求信息，匹配在總線中註冊的樁信息尋找請求代理單元的樁，並傳遞請求消息給請求代理；54、請求代理根據請求數據，填充代理追蹤信息入棧，若請求本系統服務，傳遞消息到本地服務單元，並直接進入S6，若請求其他系統數據，則請求代理需要按照本地緩存的命名信息尋找第二子系統的命名服務，並發送給第二子系統的fete處理該消息；55、第二子系統的fete收到請求消息，並重複步驟中的Sl到S4；56、服務單元收到請求消息後，令該消息進入本服務待處理隊列；57、服務單元提醒調度器，本服務有請求需要執行，調度器調度該服務單元運行請求；58、服務單元運行請求後得到一個響應消息，該響應消息中包含了代理追蹤棧，服務發送響應消息給請求代理，根據消息的追蹤信息，該響應消息傳遞給消息的請求單元。
2.如權利要求1所述的方法，其特徵在於，所述S7步驟的響應消息是異步發送的消息， 消息發送者在發送消息後不需要等待該消息的響應，該消息的請求者需要以異步的方式獲取消息的響應。
3.如權利要求1所述的方法，其特徵在於，若一個服務單元調用其他單元的服務，且其他單元的位置是通過本系統內的請求代理來確定的，其步驟為S10、服務單元發送對其他單元的調用請求消息給總線；S20、軟體總線讀取請求消息中請求信息，匹配在總線中註冊的樁信息尋找請求代理單元的樁信息，並傳遞請求消息給請求代理；S30、請求代理根據請求數據，填充代理追蹤信息入棧，若請求本系統服務，傳遞消息到本地服務單元，並直接進入S50，若請求其他系統數據，則請求代理需要按照本地緩存的命名信息尋找第二子系統的命名服務，並發送給第二子系統的fete處理該消息；S40、第二子系統的(iate收到請求消息，並重複Sl到S4 ；S50、其他單元收到請求消息後，令該消息進入本服務待處理隊列；S60、服務單元提醒調度器，本服務有請求需要執行，調度器調度該服務單元運行請求；S70、服務單元運行請求後得到一個響應消息，該響應消息中包含了代理追蹤棧，服務發送響應消息給請求代理，根據消息的追蹤信息，該響應消息會最終被傳遞給消息的請求單元。
4.如權利要求3所述的方法，其特徵在於，所述S8和S70具體包括以下步驟S100、服務單元把運行請求後得到的響應消息，發送給系統所在的總線；S200、總線獲取請求代理樁信息後，發送該響應消息給請求代理單元；S300、請求代理單元按照消息中包含的代理追蹤棧信息，分情況處理，如果該響應對應的請求在本伺服器，則直接發送該響應消息給本伺服器的請求單元，到此，本次請求響應的流程結束，否則進行S400;S400、如過該響應的請求不在本伺服器，請求代理需要按照本地緩存的命名信息尋找第一子系統的命名服務，並發送給第一子系統的fete處理該響應消息；S500、第一子系統的fete收到響應消息後，發送給總線處理，總線獲取第一子系統上的請求代理單元處理該響應消息；S600、第一子系統上的請求代理，按照消息中包含的代理追蹤棧信息，重複S300的處理，直到本次請求響應的流程結束。
5.如權利要求1至4中任意一項所述的方法，其特徵在於，所述各單元間的交互是通過會話傳遞的，一個會話封裝了單元和單元間通信的管道，該管道的底層實現可以是tcp或 Udp或ipc三種方式，在會話中單元可以進行發送一個請求，響應一個請求，主動發送一個通知的操作。
全文摘要
本發明提供了一種異步分布式列對象請求代理系統的應用方法第一子系統接收到符合本命名服務命名的消息；Gate把請求傳遞給軟體總線；軟體總線讀取請求信息，匹配在總線中註冊的樁信息，並傳遞請求消息給請求代理；請求代理根據請求數據，填充代理追蹤信息入棧，若請求本系統服務，傳遞消息到本地服務單元，若請求其他系統數據，則請求代理需要按照本地緩存的命名信息尋找第二子系統的命名服務，並發送給第二子系統的Gate處理該消息；第二子系統的Gate收到請求消息；服務單元收到請求消息後，令該消息進入本服務待處理隊列；並提醒調度器，調度器調度該服務單元運行請求；服務單元運行請求後得到一個響應消息，該響應消息中包含了代理追蹤棧，服根據消息的追蹤棧，該響應消息傳遞給消息的請求單元。
文檔編號H04L29/08GK102355505SQ20111031434
公開日2012年2月15日 申請日期2011年10月17日 優先權日2011年10月17日
發明者胡斌, 連琨 申請人:蘇州邁科網絡安全技術股份有限公司