[發明專利]面向復雜生產過程管理系統的消息總線實現方法

無效

• 申請號: 201210514195.2
• 申請日: 2012-12-04
• 公開（公告）號: CN103259701A
• 公開（公告）日: 2013-08-21
• 發明（設計）人: 于海斌;史海波;潘福成;胡國良;里鵬;段彬
• 申請（專利權）人: 中國科學院沈陽自動化研究所
• 主分類號: H04L12/40
• 分類號: H04L12/40;H04L29/08
• 代理公司: 沈陽科苑專利商標代理有限公司 21002
• 代理人: 周秀梅;許宗富

技術領域

本發明屬于計算機應用技術領域，特別涉及制造執行系統，是實現面向復雜生產過程管理系統中的消息總線的一種方法。

背景技術

在制造執行系統軟件中其客戶端節點數量和應用服務數量都具有顯著的動態性，對系統的伸縮性和可控性提出了新的要求。具備可擴展性、可維護性和可復用性的消息總線技術，十分適用于這類復雜軟件系統。消息總線可以降低系統中各個模塊間的耦合度，提高模塊的復用性，增強系統的靈活性，有效降低開發成本，提高開發效率，是構建制造執行系統的核心技術之一。

現有消息總線方案中，一般采用如下幾種方案：①以數據庫為中心的總線方案；②基于CORBA、EJB和DCOM組件的總線方案；③將各應用接口映射為智能體的總線方案。其中第①種方案由于各模塊直接訪問數據庫，因此降低了整個系統的安全性以及性能；第②種方案由于不同組件模型互調用存在互聯性問題，因此具有一定的局限性；第③種方案由于引入了智能體的概念，使系統的復雜度大大增加。在復雜生產過程管理系統中并發的消息種類繁多，數量巨大，上述總線方案無法適應這種大規模環境下的應用。本發明克服上述現有解決方案的不足，針對復雜生產過程管理系統中的大規模、并發消息的特點，提出了一種可群集的對等協同消息總線實現方法。

發明內容

本發明克服上述現有解決方案的不足，針對復雜生產過程管理系統中的大規模、并發消息的特點，提出了一種可群集的對等協同消息總線實現方法，即一種面向復雜生產過程管理系統的消息總線實現方法。

本發明為實現上述目的所采用的技術方案是：一種面向復雜生產過程管理系統的消息總線實現方法，消息總線基于對等網絡結構，在每個網絡節點部署消息節點，消息節點的發現與加入總線的過程是自組織的，負責消息的訂閱與發布。

所述消息節點的發現與加入總線的過程是自組織的，具體步驟如下：

新加入消息總線的消息節點廣播本節點的信息給其它正運行的消息節點；

啟動偵聽進程，用于偵聽其它節點加入消息總線的注冊消息；

接收到其它消息節點的注冊消息后，判斷該消息節點是否已經在消息節點隊列中存在，若存在則丟棄，否則將該消息節點加入隊列中；

已運行消息節點收到注冊消息后，也廣播本消息節點加入總線消息給其它消息節點；

處理完消息節點加入過程后，繼續偵聽消息節點加入總線的消息，不斷循環，直到總線停止服務為止。

所述本節點的信息包括本節點的地址、端口信息。

所述消息總線的消息類型包括一下的一種或幾種：

復雜報表請求消息：包括消息類型、消息標識、消息產生時間、消息源網絡地址、消息請求位置、報表名稱、報表模板名稱、查詢語句集；

復雜報表處理完畢消息：包括消息類型、消息標識、消息產生時間、消息源網絡地址、消息請求位置、報表網絡地址；

生產事件觸發消息：包括消息類型、消息標識、消息產生時間、消息源網絡地址、消息請求位置、事件名稱、事件觸發原因、事件觸發位置、事件觸發時間；

事件反饋消息：包括消息類型、消息標識、消息產生時間、消息源網絡地址、消息請求位置、事件處理結果；

報警消息：包括其主要包括：消息類型、消息標識、消息產生時間、消息源網絡地址、報警消息產生位置，報警原因；

自定義通知消息：包括消息類型、消息標識、消息產生時間、消息源網絡地址、消息發生地址、消息文本。

所述偵聽進程內創建二個線程，其中一個線程用于監控特定的TCP端口號，當端口有消息傳入時，其接收消息，并將消息寫入待處理消息隊列中；另一個線程用于消息的解析與處理，其監視待處理消息隊列，一旦發現有消息到達，則從待處理消息隊列中取出消息，對消息進行分析處理。

本發明具有以下優點：

1.總線消息分發處理效率高；

2．消息總線體系結構簡單；

3.具有高安全性及高可靠性。

附圖說明

圖1消息總線體系結構圖；

圖2消息節點注冊與發現流程圖。

具體實施方式

下面結合附圖及實施例對本發明做進一步的詳細說明。

本發明所述的消息總線基于對等網絡結構，每個節點都需要部署消息節點，消息節點負責消息的訂閱與發布，每個消息節點間，即可以發布消息也可以訂閱消息，消息節點是自組織的，可以自動構建成消息總線，從總線結構上保障了消息總線具有較高的可靠性。