一種進行多節點事務處理的集群系統及請求消息分發方法

2023-10-08 13:49:49

專利名稱：一種進行多節點事務處理的集群系統及請求消息分發方法
技術領域：
本發明涉及無線通信領域，尤其涉及一種進行多節點事務處理的集群系 統及請求消息分發方法。
背景技術：
在應用系統領域為了解決系統的性能問題，在單套設備性能優化到極限 時，如果還無法滿足性能要求則多採用集群系統的方法來擴展系統的整體性 能。在集群系統中，包括負責集群分發的事務分發伺服器和負責處理業務邏 輯的事務處理伺服器。事務分發伺服器主要負責接收外部系統消息並按照一 定的規則分發到事務處理伺服器，還負責接收事務處理伺服器的響應消息並 組裝成應答消息返回給外部系統。事務處理伺服器負責接收事務分發伺服器 發來的消息，進行業務邏輯處理並將處理結果返回給事務分發伺服器。
在一些應用系統中，消息的處理具有關聯性。 一個完整的流程包含一次 或多次關聯消息的處理。關聯消息的關聯標識符可以由外部系統產生並傳遞 給應用系統，也可以由應用系統自身產生。關聯標識符產生後，在後續的關 聯流程中進行傳遞。這些關聯的流程在事務處理伺服器的內存中保留相關數 據，供後續流程獲取使用，這些關聯的消息需要在同一個事務處理伺服器上 進行處理，因此需要解決集群系統中多個關聯消息的事務性問題。只有解決 關聯消息的事務性問題，事務性應用系統才能實現多節點集群，才能有效地 擴展應用系統的處理能力。
在一般的應用系統中為了保證安全性，基本上都採用雙機模式。雙機模 式最大的缺點是浪費了資源，其中的一臺設備一直處於閒置狀態，另外一臺 設備一直長時間處於非工作狀態，當異常情況發生需要切換到備機時很可能 無法正常切換而影響系統的運行。

發明內容
本發明要解決的技術問題是提供一種進行多節點事務處理的集群系統 及請求消息分發方法，保證系統處理多節點事務的安全可靠性。
為了解決上述問題，本發明提供了 一種進行多節點事務處理的集群系 統，包括一事務分發伺服器以及與所述分發伺服器相連的多個事務處理服務
器；所述事務分發伺服器，用於從外部系統接收到請求消息後，對所述請 求消息進行判斷，所述請求消息是初始請求消息時，解析出所述初始請求消 息中攜帶的關聯碼，根據所述關聯碼選擇一事務處理伺服器並將所述初始請 求消息發送至選擇出的此事務處理伺服器；所述事務處理伺服器，用於對從 所述事務分發伺服器接收到的所述請求消息進行處理。
進一步地，上述集群系統還具有以下特點
所述事務分發伺服器，還用於接收到所述請求消息後，對所述請求消息 進行判斷，所述請求消息是非初始請求消息時，將所述非初始請求消息發送 至處理與所述非初始請求消息相關聯的初始請求消息的事務處理伺服器上。
進一步地，上述集群系統還具有以下特點
所述事務分發伺服器，還用於判斷接收到所述請求消息是非初始請求消 息後，解析出所述非初始請求消息中攜帶的關聯碼，並判斷所述非初始請求 消息的關聯碼由外部系統產生時，根據所述關聯碼確定一事務處理伺服器並 將所述非初始請求消息發送至選"f奪出的此事務處理伺服器。
進一步地，上述集群系統還具有以下特點
所述事務處理伺服器，還用於在處理初始請求消息時，根據此事務處理 伺服器的編號生成關聯碼用於標識後續的非初始請求消息；所述事務分發服 務器，還用於判斷接收到所述請求消息是非初始請求消息後，解析出所述非 初始請求消息中攜帶的關聯碼，並判斷所述非初始請求消息的關聯碼由事務 處理伺服器產生時，根據所述關聯碼確定一事務處理伺服器並將所述非初始 請求消息發送至選擇出的此事務處理伺服器。
進一步地，上述集群系統還具有以下特點
所述事務處理伺服器，還用於在所述集群系統是電信增值業務集群系統播類業務消息時，生成事務關if關標識作為
關聯碼；對接收到的初始請求消息為定購類業務消息時，生成二次確i人4矣入 碼作為關聯碼；對接收到的初始請求消息為組合類業務消息時，生成組合業 務流水號作為關聯碼。
進一步地，上述集群系統還具有以下特點
關聯碼與事務處理伺服器的映射關係具體是所述關聯碼的比特位中的 一位或多位與事務處理伺服器編號相對應。
進一步地，上述集群系統還具有以下特點
所述事務分發伺服器採用雙機模塊，所述事務處理伺服器採用單機模 式，所述事務處理伺服器互為備份。
為了解決上述技術問題，本發明還提供了上述集群系統中進行請求消 息分發的方法，包括事務分發伺服器將從外部系統接收的請求消息發送 至選擇出的事務處理伺服器；所述事務處理伺服器接收到所述請求消息後， 對所述請求消息進行判斷，所述請求消息是初始請求消息時，解析出所述初 始請求消息中攜帶的關聯碼，根據所述關聯碼選^^一事務處理伺服器並將所 述初始請求消息發送至選擇出的此事務處理伺服器；所述事務處理月l務器對 從所述事務分發伺服器接收到的所述請求消息進行處理。
進一步地，上述方法還具有以下特點
所述事務分發伺服器接收到所述請求消息後，對所述請求消息進行判 斷，所述請求消息是非初始請求消息時，將所述非初始請求消息發送至處理 與所述非初始請求消息相關聯的初始請求消息的事務處理伺服器上；具體包 括判斷接收到所述請求消息是非初始請求消息後，解析出所述非初始請求 消息中攜帶的關聯碼，並判斷所述非初始請求消息的關聯碼由外部系統產生 時，根據所述關聯碼確定一事務處理伺服器並將所述非初始請求消息發送至 選擇出的此事務處理伺服器。
進一步地，上述方法還具有以下特點
所述事務處理伺服器在處理初始請求消息時，根據此事務處理伺服器的編號生成關聯碼用於標識後續的非初始請求消息；所述事務分發伺服器判斷
接收到所述請求消息是非初始請求消息後，解析出所述非初始請求消息中攜 帶的關聯碼，並判斷所述非初始請求消息的關聯碼由事務處理伺服器產生 時，根據所述關聯碼確定一事務處理伺服器並將所述非初始請求消息發送至 選擇出的此事務處理伺服器。
本發明可擴展應用系統的處理能力，降低系統的建設成本，保證系統的 安全可靠性，同時解決事務性集群系統的關聯性消息分發問題，保證多節點 事務性集群系統的正常運行及可靠性。


圖1是本實施例中多節點事務處理的集群系統的組成結構示意圖2是本實施例中集群系統分發請求消息的方法流程圖3是具體實施例中電信增值業務集群系統分發請求消息的方法流程圖。
具體實施例方式
如圖1所示，進行多節點事務處理的集群系統包括一個面向外部系統的 事務分發伺服器以及與此事務分發伺服器相連的多個負責邏輯處理的事務 處理伺服器；以及與事務處理伺服器相連的資料庫；
事務分發伺服器採用雙機模式保證事務分發伺服器的安全性；事務處理 伺服器互為備份，每個事務處理器的功能相同，並且均採用單機模式以便節 省成本。
所述事務分發伺服器，用於將從外部系統接收的請求消息發送至選擇出 的事務處理伺服器，還用於在檢測到一事務處理伺服器出現運行異常時，將 需要發送至此事務處理伺服器的消息分發到其它任一事務處理伺服器上。
所述事務分發伺服器，處理從外部系統接收的請求消息時，根據請求消 息的不同類型進行不同的處理方式，包括一 、請求消息是初始^青求消息。
請求消息是初始請求消息時，關聯碼由外部系統產生，由於每臺事務處 理伺服器的處理能力相同，每一臺事務處理伺服器均可以正常處理，並在事 務處理伺服器上建立緩存以便後續消息處理時獲取相關數據。為便於後續非
初始請求消息分發到同一個事務處理伺服器上，需要採用固定的分發規則
根據初始請求消息的關聯碼建立分發的映射規則，將關聯碼的比特位中的一 位或多位與事務處理伺服器的編號建立映射關係。事務分發伺服器通過解析 關聯碼，根據關聯碼與事務處理伺服器的映射關係獲取事務處理伺服器編 號，從而將此初始請求消息分發到對應的事務處理伺服器上。
二、請求消息是非初始請求消息。
請求消息是非初始請求消息時，由於與初始請求消息具有關聯性(通過 關聯碼關聯)，需要事務分發伺服器將非初始請求消息分發到初始請求消息 所在的事務處理伺服器上進行處理，並獲取上一個請求消息保存的內存數
據。此第二種類型還有分為以下兩種情形
1、 非初始請求消息的關聯碼由外部系統產生時，為了解決初始請求消 息和非初始請求消息的關聯性，對此類非初始請求消息採用與初始請求消息 相同的分發規則事務分發伺服器根據非初始請求消息關聯碼的比特位中一 位或多位與事務處理伺服器的映射關係獲取事務處理伺服器編號，從而分發 到對應的事務處理伺服器上。
2、 非初始請求消息的關聯碼由事務處理伺服器產生時，由於關聯碼由 集群系統自身產生，可以通過對關聯碼進行編碼約定的方式實現分發。事務 處理伺服器針對非初始請求消息的關聯碼的比特位中 一位或多位與事務處 理伺服器的映射關係，事務分發伺服器根據此映射關係確定一事務處理服務 器並將此非初始請求消息發送至選擇出的此事務處理伺服器。
實現上述方案，本發明中採用的關聯碼的比特位中的一位或多位與事務 處理伺服器編號相對應映射方式，簡單易行。例如，可以將關聯碼的比特位 中的末一位或末幾位與事務處理伺服器編號對應；或者，將關聯碼的比特位 中的第一位或前幾位與事務處理伺服器編號對應，等等。所述事務分發伺服器，在收到的請求消息中攜帶多個關聯碼時，先確定 關聯碼的優先級或系統設定的分發規則進行一定次序的下發。
所述事務處理伺服器，用於從所述事務分發^^務器接收請求消息並進4亍 處理；還用於在處理初始請求消息時，根據此事務處理伺服器的編號生成關 聯碼用於標識後續的非初始請求消息。
所述資料庫，採用雙機模式以保證安全性，用於對數據進行統一存儲和管理。
對應於圖l所述系統，本集群系統中對事務性消息的分發方法包括對 於初始請求消息、外部系統產生關聯碼的非初始請求消息和集群系統產生關 聯碼的非初始請求消息，通過解析關聯碼，並查詢關聯碼與事務處理伺服器 編號的映射關係獲取需要分發的事務處理伺服器編號進行分發。對於一個消 息中攜帶多個關聯碼的情況，事務分發伺服器確定關聯碼的優先級或系統設 定的分發規則進行一定次序的下發。具體如圖2所示，集群系統分發請求消 息的方法包括以下步驟
步驟201,事務分發伺服器從外部系統接收請求消息；
步驟202,事務分發伺服器判斷所述請求消息是否是初始請求消息；如 果是，轉到步驟203;否則，所述請求消息是非初始請求消息，轉到步驟204;
步驟203,事務分發伺服器解析出所述初始請求消息中攜帶的關聯碼， 根據所述關聯碼選擇一事務處理伺服器並將所述初始請求消息發送至選擇 出的此事務處理伺服器；轉到步驟205;
步驟204，事務分發伺服器將非初始請求消息發送至處理與此非初始請 求消息相關聯的初始請求消息的事務處理伺服器上；轉到步驟205;
步驟205，事務處理伺服器對從所述事務分發伺服器接收到的請求消息 進行處理；流程結束；
具體實施例中，圖1所示的系統典型適用於電信增值業務的集群系統， 下面結合電信增值業務集群系統具體實施例對本發明技術方案進行詳細的描述。
如圖l所示，事務分發伺服器只有一套設備採用雙機模式，負責接收業
務引擎發來的鑑權請求消息並分發到事務處理伺服器上；接收事務處理服務 器返回的鑑權響應消息並轉發給業務引擎。事務處理伺服器具有多臺功能完 全相同的設備採用單機模式，每臺設備互為備份。事務處理伺服器負責接收 事務分發伺服器轉發來的鑑權請求消息，進行認證、鑑權、計費處理，並將 處理結果返回給事務分發伺服器。
電信增值業務系統主要涉及鑑權批價請求消息和鑑權批價確認請求消 息流程。鑑權批價確認處理流程需要使用鑑權批價請求處理流程中保存的數 據，二者通過鑑權請求消息中全局唯一的識別標識字^殳(即關聯碼)進行關 聯，識別標識欄位由業務引擎產生並通過鑑權批價請求消息和鑑權批價確認 請求消息傳遞給電信增值業務系統。
下面根據請求消息的不同類別進行說明
請求消息是點播類業務消息時，事務處理伺服器可以生成事務關聯標識 作為關聯碼用於標識用戶發起的點糹番並保存相關定購關係，此事務關聯標識 通過事務處理伺服器發送的鑑權批價響應消息傳遞給事務分發伺服器，再由 事務分發伺服器進一步發送給業務引擎。業務引擎可以多次使用此事務關聯 標識向集群系統發送消息，集群系統根據此事務關聯標識獲知由此事務關聯 標識所關聯的多個上行消息的相關定購關係。
請求消息是定購類業務消息時，事務處理伺服器可以生成二次確認接入 碼作為關聯碼。集群系統通過簡訊將二次確認接入碼通知用戶，用戶發送回 復的內容到二次確認接入碼進行定購確認。集群系統根據此二次確認接入碼 獲知由此二次確認接入碼所關聯的請求消息的相關定購關係。
請求消息是組合類業務消息時，事務處理伺服器可以生成組合業務流水 號作為關聯碼用於關聯多個請求消息。集群系統根據此組合業務流水號獲知 由此組合業務流水號所關聯的多個請求消息的臨時緩存數據。
事務處理伺服器將上述鑑權批價確認流程、點播流程、組合流程、二次 確認流程的請求消息涉及的臨時數據都保存在事務處理伺服器的內存中。並且，事務處理伺服器生成事務關聯標識、組合業務流水號、二次確認接入碼 時，在事務關聯標識、組合業務流水號、二次確認接入碼的比特位的一位或 多位中攜帶事務處理伺服器編號。
圖3是電信增值業務集群系統分發請求消息的方法流程圖，在此具體實 施例中，以例關聯碼的末位與事務處理伺服器編號為映射關係進行說明，具
體包括以下步驟
步驟301,事務分發伺服器接收到業務引擎發來的鑑權請求消息，進行 消息的解析。
步驟302,事務分發伺服器根據消息解析結果，判斷鑑權請求消息是否 帶組合業務流水號，如果攜帶組合業務流水號，則根據組合業務流水號的末 位找到對應的事務處理伺服器進行請求消息分發；如果沒有攜帶組合業務流 水號，則轉到步驟303。
步驟303,事務分發伺服器根據消息解析結果，判斷鑑權請求消息是否 帶事務關聯標識；如果攜帶事務關聯標識，則根據事務關聯標識的末位找到 對應的事務處理伺服器進行請求消息分發；如果沒有攜帶事務關聯標識，則 轉到步驟304。
步驟304，事務分發伺服器根據消息解析結果，判斷鑑權請求消息中的 接入碼是否是二次確認接入碼，如果是則根據接入碼的末位找到對應的事務 處理伺服器進行請求消息分發；如果不是二次確認接入碼，則轉到步驟305。
步驟305，事務分發伺服器根據鑑權請求消息中攜帶的關聯碼查詢緩存， 獲取內存中保存的事務處理伺服器編號。如果根據關聯碼查詢到緩存中保存 的事務處理伺服器編號則分發到相應的事務處理伺服器上；如果查詢不到緩 存，則轉到步驟306。
步驟306,事務分發伺服器根據鑑權請求消息中攜帶的其它關聯碼的末 位與事務處理伺服器的映射關係，獲取事務處理伺服器編號，並將鑑權請求 消息分發到對應的事務處理伺服器上；轉到步驟307。
步驟307，如果分發事務處理伺服器正常，則分髮結束。如果分發事務處理伺服器異常，事務分發伺服器將鑑權請求消息輪詢分發到其他事務處理 伺服器上，事務分發伺服器緩存關聯碼與事務處理伺服器編號的關係數據。 流程結束。
綜上所述，本發明中基於一套雙機的事務分發伺服器和多臺單機的事務 處理伺服器集群系統，最大限度地利用設備資源降低成本，並有效地擴展了 應用系統的處理能力，同時解決了事務性集群系統中關聯消息分發問題，通 過系統集群大大提升整體處理能力，為電信增值業務等系統實現數據集中、 處理集中提供了堅實的基礎。
當然，本發明還可有其他多種實施例，在不背離本發明精神及其實質的 情況下，熟悉本領域的技術人員當可根據本發明做出各種相應的改變和變 形，但這些相應的改變和變形都應屬於本發明所附的權利要求的保護範圍。
權利要求
1、一種進行多節點事務處理的集群系統，其特徵在於，包括一事務分發伺服器以及與所述分發伺服器相連的多個事務處理伺服器；所述事務分發伺服器，用於從外部系統接收到請求消息後，對所述請求消息進行判斷，所述請求消息是初始請求消息時，解析出所述初始請求消息中攜帶的關聯碼，根據所述關聯碼選擇一事務處理伺服器並將所述初始請求消息發送至選擇出的此事務處理伺服器；所述事務處理伺服器，用於對從所述事務分發伺服器接收到的所述請求消息進行處理。
2、 如權利要求1所述的集群系統，其特徵在於，所述事務分發伺服器，還用於接收到所述請求消息對所述請求消息進行 判斷後，所述請求消息是非初始請求消息時，將所述非初始請求消息發送至 處理與所述非初始請求消息相關聯的初始請求消息的事務處理伺服器上。
3、 如權利要求2所述的集群系統，其特徵在於，所述事務分發伺服器，還用於判斷接收到所述請求消息是非初始請求消 息後，解析出所述非初始請求消息中攜帶的關聯碼，並判斷所述非初始請求 消息的關聯碼由外部系統產生時，根據所述關聯碼確定一事務處理伺服器並 將所述非初始請求消息發送至選擇出的此事務處理伺服器。
4、 如權利要求2所述的集群系統，其特徵在於，所述事務處理伺服器，還用於在處理初始請求消息時，根據此事務處理 伺服器的編號生成關聯碼用於標識後續的非初始請求消息；所述事務分發伺服器，還用於判斷接收到所述請求消息是非初始請求消 息後，解析出所述非初始請求消息中攜帶的關聯碼，並判斷所述非初始請求 消息的關聯碼由事務處理伺服器產生時，根據所述關聯碼確定一事務處理服 務器並將所述非初始請求消息發送至選擇出的此事務處理伺服器。
5、 如權利要求4所述的集群系統，其特徵在於，所述事務處理伺服器，還用於在所述集群系統是電信增值業務集群系統 時，對接收到的初始請求消息為點播類業務消息時，生成事務關聯標識作為關聯碼；對接收到的初始請求消息為定購類業務消息時，生成二次確認接入 碼作為關聯碼；對接收到的初始請求消息為組合類業務消息時，生成組合業 務流水號作為關聯碼。
6、 如權利要求1至5中任一權利要求所述的集群系統，其特徵在於，關聯碼與事務處理伺服器的映射關係具體是所述關聯碼的比特位中的 一位或多位與事務處理伺服器編號相對應。
7、 如權利要求1至5中任一權利要求所述的集群系統，其特徵在於，所述事務分發伺服器採用雙機模塊，所述事務處理伺服器採用單機模 式，所述事務處理伺服器互為備份。
8、 權利要求1所述的集群系統的請求消息分發方法，包括事務分發伺服器將從外部系統接收的請求消息發送至選擇出的事務處 理伺服器；所述事務處理伺服器接收到所述請求消息後，對所述請求消息進 行判斷，所述請求消息是初始請求消息時，解析出所述初始請求消息中攜帶 的關聯碼，根據所述關聯碼選擇一事務處理伺服器並將所述初始請求消息發 送至選擇出的此事務處理伺服器；所述事務處理伺服器對從所述事務分發服 務器接收到的所述請求消息進行處理。
9、 如權利要求8所述的方法，其特徵在於，所述事務分發伺服器接收到所述請求消息對所述請求消息進行判斷後， 所述請求消息是非初始請求消息時，將所述非初始請求消息發送至處理與所 述非初始請求消息相關聯的初始請求消息的事務處理伺服器上；具體包括 判斷接收到所述請求消息是非初始請求消息後，解析出所述非初始請求消息 中攜帶的關聯碼，並判斷所述非初始請求消息的關聯碼由外部系統產生時， 根據所述關聯碼確定一事務處理伺服器並將所述非初始請求消息發送至選 擇出的此事務處理伺服器。
10、如權利要求9所述的方法，其特徵在於，所述事務處理伺服器在處理初始請求消息時，根據此事務處理伺服器的編號生成關聯碼用於標識後續的非初始請求消息；所述事務分發伺服器判斷 接收到所述請求消息是非初始請求消息後，解析出所述非初始請求消息中攜 帶的關聯碼，並判斷所述非初始請求消息的關聯碼由事務處理伺服器產生 時，根據所述關聯碼確定一事務處理伺服器並將所述非初始請求消息發送至 選擇出的此事務處理伺服器。
全文摘要
本發明提供了一種進行多節點事務處理的集群系統及請求消息分發方法，包括一事務分發伺服器以及與所述分發伺服器相連的多個事務處理伺服器；事務分發伺服器，用於從外部系統接收到請求消息後，對所述請求消息進行判斷，所述請求消息是初始請求消息時，解析出所述初始請求消息中攜帶的關聯碼，根據所述關聯碼選擇一事務處理伺服器並將所述初始請求消息發送至選擇出的此事務處理伺服器；事務處理伺服器，用於對從所述事務分發伺服器接收到的所述請求消息進行處理。本發明可擴展應用系統的處理能力，降低系統的建設成本，保證系統的安全可靠性，同時解決事務性集群系統的關聯性消息分發問題，保證多節點事務性集群系統的正常運行及可靠性。
文檔編號H04W84/08GK101605301SQ20091015195
公開日2009年12月16日 申請日期2009年7月8日 優先權日2009年7月8日
發明者史美康, 黃小軍 申請人:中興通訊股份有限公司