[發明專利]處理電信網管系統拓撲界面大量上報消息的系統和方法

有效

• 申請號: 200710188082.7
• 申請日: 2007-11-22
• 公開（公告）號: CN101170448A
• 公開（公告）日: 2008-04-30
• 發明（設計）人: 王彬
• 申請（專利權）人: 中興通訊股份有限公司
• 主分類號: H04L12/24
• 分類號: H04L12/24;H04Q7/34;H04M3/42
• 代理公司: 北京安信方達知識產權代理有限公司
• 代理人: 龍洪;霍育棟

技術領域

本發明涉及通信領域，尤其涉及一種處理電信網管系統拓撲界面大量上報消息的系統和方法。

背景技術

在電信網管系統中，隨著需管理的網元越來越集中、數目越來越多，對界面處理的性能就有了更高的要求。對于一個網管系統，體現網絡拓撲結構以及告警的大數據量處理都是很占用資源的。對于拓撲圖來說，在一個圖中顯示上萬個網元是可能的，在這種情況，如果上報消息來得非常頻繁，界面的呈現或者處理性能將受到極大的影響。

對于這種上報消息的處理，一般有兩種方式：一種是在接收到上報消息后，在前臺部署一同步的消息線程管理器進行管理，將上報消息放到線程中進行處理。執行消息隊列時，申請寫鎖；界面操作時，需要申請讀鎖。但采用這種方式存在的問題是上報消息處理涉及到界面的處理，在以后涉及到界面處理的線程中都需要添加同步，否則界面會出現異常，而且對于系統觸發的用戶界面線程，例如刷新，則無法添加同步標識，界面容易出錯；另外一種方式就是將收到的上報消息都放到用戶界面線程中進行處理，這樣的處理方式可以避免界面出現異常，但帶來的后果是如果用戶界面線程占用時間過長，界面會出現長時間灰屏現象。這兩個方法還有一個缺點就是在前臺界面退出時，有可能還有消息上報需要處理，這時不好控制處理邏輯，有可能前臺已經退出，可線程還在運行。

發明內容

本發明要解決的技術問題是提供一種處理電信網管系統拓撲界面大量上報消息的系統和方法，以避免現有技術中繁瑣的線程鎖機制問題。

本發明采用的技術方案是：

本發明提供了一種處理電信網管拓撲界面大量上報消息的系統，包括：消息源模塊、消息隊列模塊、消息處理線程模塊和消息處理模塊；

所述消息源模塊用于產生上報消息后將其封裝成帶有級別標識的消息執行單元，并將所述消息執行單元發送給所述消息隊列模塊；

所述消息隊列模塊用于根據所述消息執行單元的級別標識，將所述消息執行單元放到對應的隊列中或將其丟棄；

消息處理線程模塊用于創建并啟動消息處理線程；

消息處理模塊用于在接收到所述消息執行單元時，將其放入用戶界面線程中進行相應的處理。

進一步地，所述消息處理線程用于在接收到所述消息處理模塊向其發送的處理完成通知消息或到了監聽周期時，開始監聽所述消息隊列模塊中是否有隊列需要處理，如有，則對其進行處理。

進一步地，所述級別標識包括前臺標識、后臺數據標識、最高級別刷新標識或自動刷新標識。

進一步地，所述消息執行單元是被封裝的消息上報單元，在前臺退出時，辨別自己是否應該繼續運行或者被調度或者結束命周期。

本發明還提供了一種使用權利要求1所述系統處理電信網管拓撲界面大量上報消息的方法，包括以下步驟：

a、消息源模塊產生上報消息，并將所述上報消息封裝成帶有級別標識的消息執行單元后發送給消息隊列模塊；

b、所述消息隊列模塊根據所述消息執行單元的級別標識將其放入對應的隊列中或將其丟棄；

c、消息處理線程接收到所述消息處理模塊向其發送的處理完成通知消息或到了監聽周期時，其開始監聽所述消息隊列模塊中是否有隊列需要處理，如有，則對其進行處理；

d、如果所述消息處理模塊接收到所述消息執行單元，則將其放入用戶界面線程中進行相應的處理。

進一步地，所述消息處理線程由消息處理線程模塊創建并啟動，所述消息處理線程根據所述監聽周期對所述消息隊列模塊進行監聽。

進一步地，步驟a中，所述級別標識包括前臺標識、后臺數據標識、最高級別刷新標識或自動刷新標識。

進一步地，步驟b具體為：所述消息隊列模塊判斷與所述消息執行單元的級別標識對應的隊列中是否已包含一刷新標識的消息執行單元或者該隊列中的消息執行單元數是否等于預先設定的閥值，如果是，則將所述消息執行單元丟棄，且將等于所述閥值的隊列中的所有消息執行單元的級別標識均置為自動刷新標識；否則，將所述消息執行單元放到所述對應的隊列中

進一步地，步驟c中，所述消息處理線程對所述隊列中的消息執行單元的處理，具體包括以下步驟：所述消息處理線程如判斷所述隊列中的消息執行單元中有所述最高級別刷新標識，則將所述消息執行單元發送給所述消息處理模塊；如果有所述自動刷新標識，則所述消息處理線程休眠一預設時間后判斷休眠的總時間是否超過了預設的等待閥值，如果是，將所述消息執行單元發送給所述消息處理模塊；如果有所述前臺標識或者后臺數據標識，則所述消息處理線程從消息隊列中取出所述消息執行單元并發送給所述消息處理模塊。