《電子技術應用》
您所在的位置:首頁 > 通信與網絡 > 業界動態 > 基于TCP/IP的多線程通信及其在遠程監控系統中的應用

基于TCP/IP的多線程通信及其在遠程監控系統中的應用

2009-05-19
作者:王金廉 謝劍英 賈 青

  摘 要: 提出了一種在Windows NT下基于TCP/IP協議的多線程通信的設計與實現方法,在此基礎上給出了多線程通信在蓄電池遠程監控系統中的應用實例。
  關鍵詞: 多線程 實時性 TCP/IP協議 遠程監控系統


  傳統的應用程序都是單線程的,即在程序運行期間,由單個線程獨占CPU的控制權,負責執行所有任務。在這種情況下,程序在執行一些比較費時的任務時,就無法及時響應用戶的操作,影響了應用程序的實時性能。在監控系統,特別是遠程監控系統中,應用程序往往不但要及時把監控對象的最新信息反饋給監視客戶(通過圖形顯示),還要處理本地機與遠程機之間的通信以及對控制對象的實時控制等任務,這時 ,僅僅由單個線程來完成所有任務,顯然無法滿足監控系統的實時性要求。在DOS系統下,這些工作可以由中斷來完成。而在Windows NT下,中斷機制對用戶是不透明的。為此,可引進多線程機制,主線程專門負責消息的響應,使程序能夠響應命令和其他事件。輔助線程可以用于完成其他比較費時的工作,如通信、圖形顯示和后臺打印等,這樣就不至于影響主線程的運行。
1 Windows NT 多線程概述
  Windows NT是一個真正的搶占式多任務操作系統。在Windows NT中,啟動一個應用程序就是啟動該應用程序的一個實例,即進程。進程由一個或多個線程構成,擁有內存和資源,但自己不能執行自己,而是進程中的線程被調度執行。進程至少要有一個線程,當創建一個進程時,就創建了一個線程,即主線程。主線程可以創建其他輔助線程,由主線程創建的線程又可創建線程。每個線程都可指定優先級,操作系統根據線程的優先級調度線程的執行。
  Windows NT中使用多線程的方法有三種:
  · 使用C多線程庫函數;
  · 使用CreateThread() 等Win32函數;
  · 使用MFC類。
  本文采用第三種方法。在Visual C++5.0 中,MFC應用程序用CWinThread 對象表示線程。基本操作如下:
  · 創建新線程:調用MFC全局函數AfxBeginThread( )創建新線程。AfxBeginThread( )啟動新線程并返回控制,然后,新線程和調用AfxBeginThread( )的線程同時運行。它的返回值為指向CWinThread對象的指針;
  · 暫停/恢復線程:調用CWinThread類成員函數SuspendThread( )暫停線程的運行,調用ResumeThread( )成員函數恢復線程的運行;
  · 終止線程:在線程內部可調用全局函數AfxEndThread( )終止線程的運行,否則,線程執行結束后,線程自動從線程函數返回并釋放線程占有的資源。
2 基于TCP/IP 的多線程編程
  TCP/IP是Internet上廣泛使用的一種協議,可用于異種機之間的互聯。TCP/IP協議本身是非常復雜的,然而在網絡編程中,程序員不必考慮TCP/IP的實現細節,只需利用協議的網絡編程接口Socket(亦稱套接字)即可。在Windows中,網絡編程接口是Windows Sockets,它包含標準的Berkley Sockets的功能調用的集合,以及為Windows 所做的一些擴展。TCP/IP協議的應用一般采用客戶/服務器模式,面向連接的應用調用如圖1所示。


  根據上述順序調用函數建立連接后,通信雙方便可交換數據[1]。然而,在調用帶*號的函數時,操作常會阻塞,特別是當套接字工作在同步阻塞模式(Blocking Mode)時。這時,程序無法響應任何消息。為了避免出現這種情況,本文引進輔助線程。在執行含有可能阻塞的函數的任務時,動態創建新的線程,專門處理該任務。主線程把任務交給輔助線程后,不再對輔助線程加以控制與調度。本文分別針對connect()、accept()、receive()、send()等可能阻塞的函數創建了相應的線程,如表1所示。


  多線程編程常常還要考慮線程間的通信。線程間的通信可以采用全局變量、指針參數和文件映射等方式。本文采用指針參數方式。在調用AfxBeginThread()函數時,通過傳遞指針參數的方式在主線程與輔助線程間通信。
  AfxBeiginThread( )函數的用法如下:
  CWinThread* AfxBeginThread( AFX_THREADPROC pfnThreadProc,
  LPVOID pParam,
  int nPriority=THREAD_PRIORITY_NORMAL,
  UINT nStackSize=0,
  DWORD dwCreateFlags=0,
  LPSECURITY_ATTRIBUTES lpSecurityAttrs=NULL );
  參數pfnThreadProc指定線程函數,必須如下定義:
  UINT MyControllingFunction( LPVOID pParam );
  參數pParam 是調用線程傳遞給線程函數pfnThreadProc的參數;
  其他參數一般只需采用缺省值。
  指針參數通信方式就是通過參數pParam在線程間通信的,它可為指向任何數據類型的指針。本文中,定義了一個名叫EXCHANGE_INFO的結構如下:
  typedef struct
  {  SOCKET sServerSocket;
    SOCKET *psClientSocket;
    SOCKADDR_IN *pClientAddr;
    BOOL *pbConnected;
    unsigned char *pucBuffer;
    int *pnMessageLen;
  } EXCHANGE_INFO;
  在需要通信時,先聲明一個結構變量,再把變量的指針作為pParam參數,調用AfxBeginThread((AFX_THREADPROC) CSocketThread::WaitForConnectThread, (LPVOID)& m_ExchangeInfo)函數即可。
  為了利用面向對象技術編程所具有的模塊性強、便于修改、可移植性好等優點,本文還把表1中的線程封裝為父類為CWinThread的自定義類CSocketThread中。還自定義了一個叫CSocketComm的新類,封裝了一些函數,如CreateSocket、ConnectToServer、WaitForClient、ReadMessage、SendMessage等,這些函數屏蔽了面向連接的通信程序的實現細節,如創建、連接、發送和接收等,在這些函數里,動態創建輔助線程。
  下面以CSocketComm類中的等待客戶連接請求的函數WaitForClient()為例,注釋說明多線程編程的具體細節。
  BOOL CSocketComm::WaitForClient()
  {
  if( m_bConnected ) return( TRUE );
  //配置bind函數的參數,即服務器的套接字地址結構
  SOCKADDR_IN Addr;
  memset( &Addr, 0, sizeof( SOCKADDR_IN ) );
  Addr.sin_family = AF_INET;
  Addr.sin_port = htons( m_nPort );
  Addr.sin_addr.s_addr = htonl( INADDR_ANY );
  //將套接字地址結構賦予套接字(綁定),以指定本地半相關
  int nReturnValue;
  nReturnValue = ::bind( m_sServerSocket, (LPSOCKADDR) &Addr,sizeof( SOCKADDR_IN ) );
  if( nReturnValue == SOCKET_ERROR ) return( FALSE );
   //配置傳給WaitForConnectThread線程函數的參數m_ExchangeInfo
  m_ExchangeInfo.sServerSocket = m_sServerSocket;
  m_ExchangeInfo.psClientSocket = &m_sClientSocket;
  m_ExchangeInfo.pClientAddr = &m_ClientAddr;
  m_ExchangeInfo.pbConnected = &m_bConnected;
  //以m_ExchangeInfo的指針為參數調用WaitforConnectThread線程等待客戶端連接
  AfxBeginThread((AFX_THREADPROC)CSocketThread::
  WaitForConnectThread, (LPVOID) & m_ExchangeInfo );
  return( TRUE );
  }
  //等待連接線程
  UINT CSocketThread::WaitForConnectThread(LPVOIDpParam)
  {
  EXCHANGE_INFO*pExchangeInfo=(EXCHANGE_INFO *) pParam;
  int nReturnValue, nClientAddrSize = sizeof( SOCKADDR_IN );
  //偵聽連接
  nReturnValue = ::listen(pExchangeInfo ->sServerSocket, 1 );
  if( nReturnValue == SOCKET_ERROR ) return( 0 );
  //阻塞調用accept,直至有客戶連接請求
  *pExchangeInfo->psClientSocket = ::accept(pExchangeInfo->sServerSocket, (LPSOCKADDR) pExchangeInfo ->pClientAddr, &nClientAddrSize );
  if( (*pExchangeInfo ->psClientSocket) != INVALID_SOCKET )
  //通過pExchangeInfo的指針在線程間通信
  *pExchangeInfo->pbConnected = TRUE;
  return( 0 );
  }
3 應用實例-高層協議的設計
  在電廠和電站中,為了保證安全工作,保護系統必不可少。保護系統的電源供應通常使用兩種方式。一般情況下,使用交流電系統對保護系統進行供電;當交流電系統出現故障時,立即使用后備的蓄電池系統對保護系統進行供電。為了對蓄電池系統進行監控和管理,以保證蓄電池在關鍵時刻能正常工作,設計了在Windows NT環境下具有遠程通訊功能和動態人機界面的智能蓄電池遠程監控系統 。該系統由蓄電池智能管理、充電機控制、母線絕緣在線檢測、聲光報警、系統組態、遠程通信等子系統組成,實現對蓄電池/充電機智能化遠程管理和控制,對整個系統的運行狀態進行實時監控,具有多媒體報警、事件處理、動態數據庫、趨勢畫面和動態畫面顯示、操作提前提醒等功能。系統框圖如圖2所示。在遠程通信模塊中,遠程監控機需把監控客戶的操作命令及時傳給本地機,本地機根據命令控制充電機,使之按照一定的方式工作,而本地機需定時向遠程監控機反饋實時的充電機狀態信息。它們之間的通信是基于TCP/IP的廣域網通信,而且,我們引進了多線程機制以保證系統具有良好的實時性。


  下面以其中的充電機控制系統為例談談如何使用CSocketComm類進行遠程通信。為簡單起見,假定本地機與遠程監控機之間通信的信息僅有下面三種類型:
  ·本地機接收到該命令后,控制充電機按照穩壓模式運行,輸出電壓為電壓給定值;
  ·本地機接收到該命令后,控制充電機按照穩流定時模式運行,輸出電流為電流給定值;
  ·本地機向遠程監控機發送充電機的實時狀態數據(包括輸出電壓、輸出電流、狀態指示和故障類型指示)。
  在基于TCP/IP的面向連接的網絡通信中,客戶與服務器之間傳送的是有序可靠的字節流(Byte Stream),所以程序員有必要在傳輸層TCP上定義自己的高層協議,設計幀結構,將字節流變成有意義的信息。在CSocketComm類中由AssembleMessage( )函數把數據組合成一定的幀結構。幀結構為:

  
  其中@為幀起始標志,#為幀終結標志
  對應的結構定義如下:
  typedef struct
  { int MessageType; //信息類型
  int ChargerNo; //充電機編號
  int DataNo; //數據類型
  float Data; //數據
  } MessageStruct;
  需要通信時,先聲明一個MessageStruct變量,根據信息內容對各成員變量賦值,傳給 AssembleMessage()函數組合成幀,再調用SendMessage()函數發送給接受方。接受方接到數據后,對數據內容的解釋,是由CSocketComm類中的AnalyzeMessage()函數完成的。AnalyzeMessage()函數返回一個MessageStruct變量。應用程序就可根據它的各成員變量控制充電機或動態顯示充電機的狀態。
  總之,把多線程機制引進通信,有利于提高應用程序的實時性,充分利用系統資源。對于大型的工程應用來說,不同的線程完成不同的任務,也有利于提高程序的模塊化,便于維護和擴展。本文給出了一種在Windows NT下基于TCP/IP協議的多線程通信的基本方法,根據該方法進行修改和擴充,便可設計出符合具體應用的高質量的多線程通信程序。
參考文獻
1 蔣東興,林鄂華.Windows Socket 網絡程序設計指南.北京:清華大學出版社,1995
2 Rajagopal Raj, Monica Subodh P.Windows NT4高級程序設計.北京:機械工業出版社,1998

本站內容除特別聲明的原創文章之外,轉載內容只為傳遞更多信息,并不代表本網站贊同其觀點。轉載的所有的文章、圖片、音/視頻文件等資料的版權歸版權所有權人所有。本站采用的非本站原創文章及圖片等內容無法一一聯系確認版權者。如涉及作品內容、版權和其它問題,請及時通過電子郵件或電話通知我們,以便迅速采取適當措施,避免給雙方造成不必要的經濟損失。聯系電話:010-82306118;郵箱:aet@chinaaet.com。
亚洲一区二区欧美_亚洲丝袜一区_99re亚洲国产精品_日韩亚洲一区二区
免费亚洲电影| 国内精品免费午夜毛片| 久久免费视频网| 亚洲欧美成人一区二区在线电影| 亚洲裸体俱乐部裸体舞表演av| 亚洲国产中文字幕在线观看| 久久精品30| 亚洲国产另类久久精品| 亚洲第一搞黄网站| 亚洲国产精品视频一区| 亚洲国产精品一区二区久| 久久精品国产77777蜜臀| 欧美在线视频一区| 久久精品国产久精国产思思| 久久精品二区| 亚洲精品国产精品乱码不99| 亚洲另类自拍| 一区二区三区国产在线观看| 一区二区三区四区五区精品| 亚洲视频欧美在线| 午夜激情综合网| 欧美一区二区三区在线免费观看| 小处雏高清一区二区三区| 欧美在线中文字幕| 久久婷婷丁香| 欧美激情精品久久久久久大尺度 | 99re热精品| 一区二区三区精品视频在线观看 | 国产精品久久久久久久午夜片| 国产精品久久久久久久久借妻| 国产精品久久久久毛片大屁完整版| 国产精品女主播一区二区三区| 国产欧美二区| 伊伊综合在线| 99国内精品久久| 亚洲特级片在线| 欧美在线国产| 亚洲精品一区中文| 亚洲欧美激情在线视频| 久久精品亚洲| 欧美激情一区三区| 国产精品国产| 激情综合激情| 日韩天堂av| 欧美亚洲一区三区| 亚洲精品少妇30p| 亚洲欧美999| 蜜桃伊人久久| 国产精品v片在线观看不卡| 国产一区二区按摩在线观看| 最新日韩中文字幕| 亚洲在线观看视频网站| 久久精品欧美日韩| 一区二区三区久久久| 久久九九热re6这里有精品| 欧美国产日韩在线| 国产毛片久久| 亚洲激情一区| 欧美一区二区三区在线免费观看| 99国产精品久久久久久久久久| 亚洲欧美一区二区激情| 美日韩精品视频| 国产精品日日摸夜夜添夜夜av| 在线观看亚洲精品| 亚洲永久精品国产| 亚洲人午夜精品免费| 欧美一区=区| 欧美日韩国产va另类| 国产有码在线一区二区视频| 99综合在线| 亚洲国产午夜| 久久成人18免费观看| 欧美日韩综合另类| 在线观看成人av| 亚洲欧美日韩国产一区二区| 亚洲乱码国产乱码精品精| 久久久999精品视频| 欧美性猛交xxxx乱大交退制版| 亚洲大片免费看| 午夜在线视频一区二区区别| 亚洲视频一区二区| 欧美成人精品福利| 国产有码在线一区二区视频| 亚洲一级二级| 制服丝袜亚洲播放| 欧美成人精品高清在线播放| 国产一区二区在线观看免费| 亚洲午夜精品一区二区| 这里是久久伊人| 欧美国产精品人人做人人爱| 国产一区二区三区在线观看视频| 亚洲素人在线| 亚洲小少妇裸体bbw| 欧美精品久久一区| 亚洲国产成人不卡| 亚洲高清不卡在线观看| 久久精品国产一区二区电影| 国产精品久久久久久久久搜平片| 亚洲精品乱码久久久久久蜜桃91| 亚洲经典三级| 久久亚洲综合色| 国产一区欧美日韩| 欧美一级淫片aaaaaaa视频| 香蕉久久夜色精品| 国产精品久久久久影院亚瑟| 在线一区二区三区四区| 亚洲少妇中出一区| 欧美日本二区| 亚洲人体偷拍| 一区二区欧美在线观看| 欧美另类变人与禽xxxxx| 亚洲国产天堂网精品网站| 91久久精品国产91性色tv| 老司机精品导航| 亚洲高清在线精品| 亚洲精品欧美激情| 欧美国产日本| 亚洲美女在线国产| 这里只有精品电影| 欧美亚州在线观看| 亚洲性人人天天夜夜摸| 性感少妇一区| 国产亚洲精品aa| 欧美在线综合视频| 久久蜜桃精品| 在线成人www免费观看视频| 亚洲激情视频在线播放| 欧美国产日韩亚洲一区| 亚洲人人精品| 亚洲午夜久久久久久尤物| 国产精品成人va在线观看| 亚洲一区不卡| 久久久www| 在线看欧美日韩| 洋洋av久久久久久久一区| 欧美日韩一卡| 亚洲欧美日韩在线| 久久精品国产久精国产一老狼| 韩国福利一区| 亚洲麻豆视频| 欧美视频在线观看一区| 亚洲欧美卡通另类91av | 激情久久中文字幕| 亚洲精品中文字| 欧美日韩在线视频一区| 亚洲免费在线观看| 久久久久高清| 91久久在线播放| 亚洲一区二区三区在线| 国产视频综合在线| 91久久黄色| 欧美性大战久久久久久久蜜臀| 亚洲欧美视频一区| 裸体丰满少妇做受久久99精品| 亚洲国产裸拍裸体视频在线观看乱了中文| 日韩视频免费在线| 国产精品久久久久久妇女6080| 性视频1819p久久| 欧美好骚综合网| 亚洲综合日韩在线| 免费的成人av| 亚洲一区二区三区午夜| 久久网站免费| 一区二区激情| 久久婷婷国产综合国色天香| 亚洲精品中文字幕女同| 欧美一区二视频在线免费观看| 亚洲电影在线免费观看| 亚洲一区高清| 在线观看一区| 小黄鸭精品密入口导航| 亚洲国产片色| 久久国产日韩| 日韩午夜剧场| 老牛国产精品一区的观看方式| 99在线热播精品免费| 久久精品123| 日韩视频永久免费| 久久性色av| 亚洲视频axxx| 欧美国产第一页| 欧美一级视频精品观看| 欧美日韩视频第一区| 久久精品一二三| 国产精品麻豆成人av电影艾秋| 亚洲黄一区二区| 国产欧美一区二区白浆黑人| 亚洲蜜桃精久久久久久久| 国产一区二区毛片| 亚洲主播在线播放| 亚洲黄色精品| 久久伊人免费视频| 亚洲欧美在线网| 欧美日韩在线电影| 亚洲日本va在线观看| 国产一本一道久久香蕉| 亚洲自啪免费| 亚洲精品久久久久久下一站| 久久最新视频| 欧美影院一区|