[發(fā)明專利]一種分布式代理的鏈路復用的方法

在審

• 申請?zhí)枺?/td>: 201710080060.2
• 申請日: 2017-02-15
• 公開（公告）號: CN106878304A
• 公開（公告）日: 2017-06-20
• 發(fā)明（設計）人: 張志君;厲啟鵬;郭凌旭;葉飛;王梓;馬云龍;姜寧;王恒;范廣民;梅崢;李西太;王躍
• 申請（專利權）人: 國網天津市電力公司;國家電網公司;北京科東電力控制系統(tǒng)有限責任公司;南京南瑞集團公司
• 主分類號: H04L29/06
• 分類號: H04L29/06;H04L29/08
• 代理公司: 天津盛理知識產權代理有限公司12209
• 代理人: 王來佳

技術領域

本發(fā)明涉及電力系統(tǒng)通信技術領域，特別是涉及一種分布式代理的鏈路復用的方法。

背景技術

近期特高壓建設的快速推進，區(qū)域間電網聯(lián)系更加密切，一體化調度的特征日趨明顯。智能電網調度控制系統(tǒng)中需要跨機構進行數(shù)據交互的進程越來越多，所以不同調度機構代理間存在大量TCP連接。

遠程服務代理是智能電網調度控制系統(tǒng)中的一個通訊基礎模塊，可以實現(xiàn)不同調度機構或者不同區(qū)之間的數(shù)據交互，為構建廣域全景的智能電網調度系統(tǒng)提供進程間通信的基礎設施。目前遠程服務代理已經在國、分、省三級調控機構實現(xiàn)了部署,支撐了大量的調度業(yè)務，包括遠程畫面瀏覽、遠程數(shù)據庫訪問、告警信息遠程推送等?，F(xiàn)有技術中，代理采用獨占鏈路模式，調度機構A的客戶端訪問調度機構B服務的過程為，客戶端先與本地代理建立TCP連接，本地代理與遠程代理建立TCP連接，遠程代理通過調度B的服務總線連接服務程序。服務程序的響應報文通過遠程代理轉發(fā)給本地代理，再由本地代理回發(fā)給客戶端。每有一個的客戶端訪問服務，就要建立1條TCP連接。

在當前獨占鏈路模式下，TCP連接占用了系統(tǒng)大量的連接句柄、CPU、內存、網絡等資源，嚴重影響代理程序的穩(wěn)定運行。

因此，目前急需一種共享鏈路的方法，兩個不同調度機構間理論上只存在兩條TCP連接，使分布式代理更加穩(wěn)定、高效地運行。

發(fā)明內容

為解決上述技術問題，在共享鏈路的模式下，兩個不同調度機構間理論上只存在兩條TCP連接，以支持代理間的雙向通信。跨區(qū)域的客戶端和服務程序以邏輯會話的形式進行數(shù)據交互，不同的會話復用一條物理TCP鏈路。共享鏈路模式可以極大程度降低不同區(qū)域間代理的連接數(shù)，從而降低代理程序的負荷。

為實現(xiàn)上述發(fā)明目的，本發(fā)明提供一種加強分布式代理運行穩(wěn)定性和高效性的鏈路復用方法。

本發(fā)明解決其技術問題是采取以下技術方案實現(xiàn)的：

一種分布式代理的鏈路復用的方法，不同區(qū)域調度機構使用動態(tài)代理服務形成分布式代理，本地客戶端訪問異地調度機構的應用時，本地代理服務作為輸出代理，異地代理服務作為輸入代理，分布式代理在兩個代理服務之間建立兩條TCP鏈路，分別為正向鏈路和反向鏈路，并創(chuàng)建一個會話，會話的請求報文通過正向鏈路傳輸至異地調度機構的動態(tài)代理服務，會話的響應報文通過反向鏈路傳輸至本地調度機構的動態(tài)代理服務；

當所述異地調度機構的客戶端訪問本地的應用時，分布式代理創(chuàng)建另一個會話，會話的請求報文通過所述反向鏈路傳輸至本地調度機構的動態(tài)代理服務，會話的響應報文通過所述正向鏈路傳輸至異地調度機構的動態(tài)代理服務；

所述TCP鏈路為長連接，建立后不會主動關閉。

進一步地，所述輸出代理包括客戶端處理模塊、會話數(shù)據緩存模塊和數(shù)據轉發(fā)模塊，其中，客戶端處理模塊監(jiān)聽客戶端請求，如果有客戶端請求則創(chuàng)建線程處理該請求，將客戶端請求按照代理會話協(xié)議ASP重新封裝報文，更新到輸入緩存，等待輸出緩存的信號；

會話數(shù)據緩存模塊存儲本地動態(tài)代理服務同異地調度機構間的會話數(shù)據，所述會話數(shù)據包括客戶端的請求報文會話數(shù)據、服務端的響應報文和控制報文的會話數(shù)據；

數(shù)據轉發(fā)模塊包括若干收發(fā)數(shù)據的工作線程和鏈路管理線程，工作線程收發(fā)一個地區(qū)內的會話數(shù)據，鏈路管理線程對工作線程進行管理。

進一步地，所述輸入代理包括數(shù)據轉發(fā)模塊、會話緩存模塊和服務端處理模塊，所述數(shù)據轉發(fā)模塊接收客戶端的請求數(shù)據，轉發(fā)至服務端處理模塊，所述服務端處理模塊通過服務線程與應用程序建立連接，服務線程將請求轉發(fā)給應用程序，并將應用程序的響應報文更新至會話緩存的響應緩存區(qū)。

進一步地，所述代理會話協(xié)議ASP保證代理兩端準確識別每一個數(shù)據報文的來源、類型及目的，并傳輸控制命令及錯誤信息，所述報文格式由依次順序的設定特定字節(jié)長度的會話編號、區(qū)域號、服務號、報文類型、優(yōu)先級、控制位、錯誤號和報文長度組成。

進一步地，所述客戶端處理模塊包括客戶端監(jiān)聽器和線程池，所述線程池有若干個客戶端工作線程cworker，客戶端監(jiān)聽器負責實時監(jiān)聽客戶端請求，當有新的客戶端請求時，所述監(jiān)聽器從線程池中分配一個cworker線程響應所述新的客戶端，cworker線程與客戶端建立連接后，接受客戶端報文，并按照代理會話協(xié)議ASP封裝客戶端報文，放到相應區(qū)域的會話緩存區(qū)中。