視頻監控數據遠程傳輸的設計與實現

高志國,李巧鴿,高新鵬

(1.中原油田勘察設計研究院,河南濮陽 457001;2.中石化銷售華北分公司河南輸油管理處,鄭州 450015)

0 引 言

中原油田天然氣處理廠主要針對油田天然氣進行深冷加工處理,天然氣處理量1.2×106m3/d。由于該廠廠區范圍大,生產車間多且分散,按照中石化安全生產的統一要求,在各關鍵生產點安裝了視頻監控系統,并將數據遠傳至生產調度室監控中心。監控系統包括本地和遠程監控兩部分。在遠程監控中心和現場監控之間通過局域網絡連接。遠程監控中心可以任意對各個現場實行監控,既可以完成對現場視頻圖像數據的實時接收、解壓縮、播放、存儲以及控制該現場的攝像機切換,鏡頭、云臺動作,又可以接收處理現場的報警信息。

1 設計原理簡介

1.1 功能模塊介紹

遠程監控中心監控程序的設計主要涉及數據收發、分析處理及顯示等模塊。數據收發是控制臺程序的重要部分,如果沒有合理有效的收發模塊設計方案,將影響到其他模塊的正常運轉。為了提高監控中心的運行效率,確保通信快速有效地進行,將數據收發模塊做成了一個獨立的基于Win32的控制臺程序,采用了 Win32多線程編程技術和Socket網絡編程技術。

1.2 Socket編程技術

在網絡通信中最常用的協議是 TCP/IP協議簇。它已成為現代工廠生產網絡的工業標準。Socket(套接字)最早是Unix系統中采用 TCP/IP協議簇而提供的網絡通信接口,隨著計算機操作系統的發展,Windows操作系統也采用了Socket,提供了 Window API供開發人員調用。Windows Socket(簡稱 WinSock)編程接口是 Windows環境下最廣泛使用的網絡編程接口。

2 數據收發的設計與實現

2.1 視頻監控系統程序結構的設計

視頻監控系統程序設計如圖1所示。在服務器端分為2個功能模塊:通信模塊——數據收發程序;數據處理模塊——監控中心控制臺。遠程監控中心服務器運行兩個程序,數據收發程序和監控中心控制臺。

圖1 視頻監控系統基本結構

2.2 數據采集器程序的設計

數據收發程序主要有三個功能:與遠程服務器端通信;與控制臺通信;操作數據庫。與控制臺數據通信主要是利用 Windows消息進行的,利用ADO技術實現數據采集器對數據庫的操作;與遠程服務器通信采用Socket編程技術。如何有效地與遠程服務器端進行通信并將得到的數據有效地寫入數據庫,保證數據不丟失并傳送到控制臺是設計的核心和難點。

數據收發程序的線程設計如下:

a)主線程。初始化用于進行同步的事件變量,臨界區變量,共享資源等,并建立一個偵聽套接字,負責為新的服務器連接請求開啟線程,建立傳輸套接字。當主線程收到結束程序的信號時將為各個線程發出終止事件,等待各個線程的終止,并釋放資源。

b)遠程控制線程。用來負責向遠程服務器端發送控制命令。

c)遠程監視進程。用來負責監視所有遠程服務器端的運行狀況以及網絡狀況,從而實現在控制中心實時顯示服務器端的運行狀態。

d)數據傳輸線程。該線程的數目與遠程現場服務器端的數目相同,對應進行處理各個服務器發來的數據,將接收到的視頻流信息和報警信息入庫,并將接收到的數據發送給控制臺進行數據分析處理。

e)數據傳輸維護線程。將數據傳輸線程做一個鏈表,實時維護此鏈表中各個線程的有效性(負責記錄存在的線程,刪除終止的線程并釋放其資源,增加新建的線程)。該線程是為了解決數據傳輸線程復雜不易管理的問題,使得每一個線程都能夠正常運行。成功解決了實際應用中曾經存在的啟動多個線程的問題。具體執行過程如圖2所示。

圖2 數據收發模塊流程

2.3 數據收發程序的實現

2.3.1 定義的數據結構和重要的全局變量

首先定義了一個用于描述每一個服務器端信息的數據結構 ClientInfo和一個服務器鏈表ClientList,分別如下所示:

數據結構ClientInfo不但記錄了服務器的基本信息(如服務器端 IP),還記錄了與該服務器端通信所對應的套接字標識sd和用于接收處理該服務器視頻流的線程標識 ThreadID,目的是為了在程序運行過程中可以有效地控制系統的線程和套接字的開關情況。字段send_time和rec_time字段主要是用來察看遠程服務器端運行狀態用的。當rec_time或send_time與當前時間超過一定間隔時需要重新向服務器端發送狀態請求數據包以檢測其運行狀態。ClientList是以ClientInfo為節點的鏈表結構。g_ci_list是系統定義的一個ClientList的全局指針變量,用來指向保存與控制中心正常連接的遠程現場服務器列表。

另外定義的一個數據結構NewClientInfor和一個全局變量g_nci用來保存新連接請求的服務器端的基本信息。定義如下:typedef struct_ NewClientInfor{

2.3.2 線程的啟動

創建一個新的線程是使用 WinAPI函數CreateThread。該函數的系統聲明如下:

每一個線程定義其實現函數之后,通過在主線程中調用Creat Thread函數即開啟了該線程。

2.3.3 網絡通信的實現

對遠程服務器數據的發送接收采用的是TCP套接字。由于多個線程和現場服務器端通信時用到同一個套接字,為了有效地對套接字進行使用,將其設定為非阻塞模式(Nonblocking),采用Select模型,利用 select函數,判斷套接字上是否存在數據,或者能否向一個套接字寫入數據。具體實現如下:

3 結束語

該方案利用多線程和套接字技術成功地解決了遠程控制中心對多個現場監視的數據收發任務。該方案也適合類似于服務器和多服務器進行數據采集和控制的任何模型。線程間同步以及線程生存期內的維護是多線程編程應該注意的關鍵問題。由于多個線程同時需要對同一個套接字的使用,使用了非阻塞套接字模式和select模型,避免了在套接字處于非鎖定模式中時,產生WSAEWOULDBLOCK錯誤。

[1] 劉富強.數字視頻監控系統開發及應用[M].北京:機械工業出版社,2003.

[2] J EFFREY R.Windows高級編程指南[M].王書洪,劉光明譯.北京:清華大學出版社,1999.

[3] ANTHONYJ.Windows網絡編程技術[M].京京工作室譯.北京:機械工業出版社,2000.

[4] 黃杰生.結合消息隊列機制的多線程TCP通信開發平臺[J].計算機應用研究,2004,(5):247-249.

[5] 李納瑩.利用MFC多線程技術開發基于UDP數據廣播的局域網絡會議程序[J].電腦編程技巧與維護,2004,(2):24.

[6] 蔡翠平,宋曉霞,蘇學濤.多媒體計算機網絡通信技術應用[M].北京:北京大學出版社,2007.

[7] 劉直芳,王運瓊.數字圖象處理與分析[M].北京:清華大學出版社,2006.