[發明專利]一種用于高可靠雙機熱備的消息同步系統及方法

有效

• 申請號: 201810076665.9
• 申請日: 2018-01-26
• 公開（公告）號: CN108390919B
• 公開（公告）日: 2021-06-25
• 發明（設計）人: 曾學;崔鴻剛;謝軍華;張煒;張培
• 申請（專利權）人: 昆明昆船邏根機場物流系統有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/24
• 代理公司: 昆明正原專利商標代理有限公司 53100
• 代理人: 徐玲菊;羅繼元

本發明公開了一種用于高可靠雙機熱備的消息同步系統及方法，旨在提供一種可靠性高的用于高可靠雙機熱備的消息同步系統及方法。它包含兩臺服務器，其中一臺作為主服務器，另一臺作為備服務器；其特征在于：兩臺所述服務器均布署了消息總線Message Queues、雙機熱備管理服務APSB、數據訪問層服務DataAdapter、數據庫DB和同步隊列Replication Queues。本發明適用于各類企業使用。

技術領域

本發明涉及軟件工程領域，尤其是涉及一種用于高可靠雙機熱備的消息同步系統及方法。

背景技術

在軟件工程領域，計算機系統的意外停機將給企業帶來名譽和經濟的損失，為了避免系統停機帶來的風險，企業會采用雙機熱備的方式來保證業務連續和數據的完整。

傳統的計算機系統構架包含了一套雙機熱備的消息總線系統和一套應用服務器。雙機熱備的消息總線系統采用廠家提供的集群管理軟件，將兩個物理的消息總線服務器虛擬成一個服務器，虛擬服務器可能是兩個物理服務器中的任意一個。應用服務器生成的消息發布至虛擬服務器，由虛擬服務器完成消息的接收、分發、持久化和同步管理。

在消息總線系統出現故障時，集群管理軟件將在兩個物理服務器間進行主備切換。主備切換期間，應用服務器所生成的業務數據會部分丟失，以致業務出現中斷，給企業的生產營運帶來安全隱患。

發明內容

本發明的目的旨在克服現有技術存在的不足，提供了一種數據傳輸穩定的用于高可靠雙機熱備的消息同步系統及方法。

為了解決上述技術問題，本發明是通過以下技術方案實現的：

一種用于高可靠雙機熱備的消息同步系統，包含兩臺服務器，其中一臺作為主服務器，另一臺作為備服務器；兩臺所述服務器均布署了消息總線Message Queues、自主研發的雙機熱備管理服務APSB、自主研發的數據訪問層服務DataAdapter、數據庫DB和同步隊列Replication Queues；所述消息總線Message Queues用于接收生產者發布的消息，并將消息分發給訂閱了該消息的各個消費者；所述APSB服務用于訂閱本機消息總線上與業務相關的消息，作為業務消息的消費者；所述APSB服務同時負責監和并接收另外一個服務器上的同步隊列Replication Queues，并將接收的消息發布至本機消息總線上與接收消息對應的隊列中，同時作為業務消息的生產者；所述數據訪問層服務DataAdapter用于訂閱本機消息總線上需要持久化的消息，作為持久化的消息的消費者；所述數據訪問層服務DataAdapter負責監聽和接收消息總線上需要持久化數據的消息，接收消息后將其解析、存入數據庫DB中；所述數據庫DB用于消息持久化、存放業務數據；所述同步隊列Replication Queues負責接收需同步至另外一個服務器的消息且將這些消息分發至另外一個服務器的雙機熱備管理服務APSB。

優選的是，所述同步隊列Replication Queues為同一服務器上消息總線的一個或多個隊列，或者是獨立于消息總線的實現隊列型數據結構的應用或服務。

優選的是，所述消息總線Message Queues包括但不限于Apach ActiveMQ、IBMWebSphere MQ、BEA Weblogic JMS Server、Oracle AQ、Tibco、Swift MQ。

優選的是，所述數據庫DB包括但不限于SQL Server、Oracle、DB2、PostgreSQL、Access、My SQL。

一種實現如上所述高可靠雙機熱備的消息同步系統的消息同步方法，其特征在于：消息在從源服務器傳輸至目的服務器的過程中，源服務器雙機熱備管理服務在消息上增加了同步標志，以防止消息回傳至源服務器；具體步驟如下：

a）業務模塊發布業務消息至源服務器的消息總線，源服務器的雙機熱備管理服務和數據訪問層服務均訂閱并接收到業務消息；源服務器的數據訪問層服務將業務消息解析后存入數據庫；