SCO UNIX網(wǎng)絡(luò)編程技術(shù)在監(jiān)控進程中的應(yīng)用

sdccf

SCO UNIX網(wǎng)絡(luò)編程技術(shù)在監(jiān)控進程中的應(yīng)用
（南京通信工程學(xué)院計算機室 李清 210016）
---- 現(xiàn)在許多通信網(wǎng)監(jiān)控系統(tǒng)都采用分級監(jiān)控系統(tǒng)，如圖1所示。上級監(jiān)控中心接收下級監(jiān)控中心的數(shù)據(jù)，并對下級監(jiān)控中心實施監(jiān)視和控制。每級監(jiān)控中心都配有監(jiān)控軟件，主要有服務(wù)器軟件和客戶機軟件。服務(wù)器軟件主要包括數(shù)據(jù)處理軟件和監(jiān)控進程，下面就SCO UNIX環(huán)境下監(jiān)控進程的編制進行說明。


---- 在SCO UNIX環(huán)境下編制監(jiān)控進程通常采用兩種方法，并發(fā)服務(wù)器和重復(fù)服務(wù)器處理。
---- 所謂并發(fā)服務(wù)器就是監(jiān)控進程在接收到客戶的一個連接請求時，便產(chǎn)生一個進程專門與其進行通信并作相應(yīng)處理，其程序流程如圖2。在此期間，由于每產(chǎn)生一個子進程，其便擁有與父進程同樣的資源，該方式下，來一個請求便產(chǎn)生一個子進程，當申請連接的請求超過一定數(shù)目，產(chǎn)生的子進程數(shù)達到一定量時，系統(tǒng)運行很慢，幾乎不能正常工作，因此并發(fā)服務(wù)器適于與客戶間的短暫通信，通信完畢后即斷開連接，結(jié)束相應(yīng)子進程。
---- 在一些大型通信網(wǎng)監(jiān)控系統(tǒng)中，通常要求客戶機全天候與服務(wù)器相連接以保證能實時進行監(jiān)控，而且這些監(jiān)控系統(tǒng)中要監(jiān)視（或請求服務(wù)）的客戶機都比較多，按照并發(fā)服務(wù)器方式處理不能保證進程的正常運行。我們在SCO UNIX環(huán)境下測試，當連接的 Int initsockid,newsockid;
if(initsockid=socket(…))int initsockid, newsockid
int flags=1;
if(initsockid=socket(…))
---- 客戶機超過10個時，系統(tǒng)運行異常，甚至出現(xiàn)死機。為了解決這個問題，采用第二種方法，即重復(fù)服務(wù)器處理，并將輪詢和非阻塞方式相結(jié)合，其程序流程如圖3
---- 所謂重復(fù)服務(wù)器處理就是當服務(wù)器接收到客戶機的連接請求時，并不產(chǎn)生專門子進程，而是直接進行處理，這里便存在以下兩種特殊情況：
---- （1）客戶機只請求連接，并不進行數(shù)據(jù)傳輸。
---- （2）客戶機請求連接后，進行大量數(shù)據(jù)傳輸。
---- 這兩種情況在實時監(jiān)控系統(tǒng)中有一個共同點是一旦連接上，除非客戶斷開連接，否則連接不能斷開。
---- 在第一種情況下，若采用阻塞方式，則服務(wù)器一直等待已連接的客戶機發(fā)送數(shù)據(jù)，這樣，一方面不能及時接收其它客戶機的連接請求，進行數(shù)據(jù)傳輸，進行實時性監(jiān)控；另一方面，服務(wù)器處于閑置狀態(tài)，造成資源浪費。而采用非阻塞方式則避免了上述情況，在非阻塞方式下，當連接的客戶機沒有數(shù)據(jù)傳輸時，服務(wù)器便轉(zhuǎn)去處理別的客戶機的請求。
---- 在第二種情況下，若服務(wù)器一旦與客戶機相連后便接收其傳來的數(shù)據(jù)，那么當客戶機傳輸?shù)臄?shù)據(jù)量大時，接收和處理數(shù)據(jù)將占據(jù)一定時間，其間其它客戶機就只能等待，不能得到及時處理。采用輪詢法則可解決客戶機長時間等待問題。
---- 輪詢法的關(guān)鍵就是數(shù)據(jù)分段處理，每次以一個確定單位接收和處理客戶機發(fā)來的數(shù)據(jù)，此單位大小取決于具體要連接的客戶機數(shù)及傳輸數(shù)據(jù)報文的長度。為了保證服務(wù)器和客戶機一次連接傳輸?shù)臄?shù)據(jù)能在同一次連接過程中完成（事實上也就是通過分配的同一個socket號進行接收），增加了一個輔助表。該表有客戶機的IP地址，每次連接分配的socket號，以及其它信息。服務(wù)器每次接收到客戶機連接請求后，便為其分配一個socket號，將其填入到輔助表對應(yīng)的表項中，當下次輪詢到此客戶機時，服務(wù)器根據(jù)客戶機的IP地址從輔助表中取出其對應(yīng)的socket號，并根據(jù)此socket號進行數(shù)據(jù)接收和發(fā)送。輔助表中分配給客戶機的socket號一直保留至接收到該客戶機新的連接請求止。
---- 以下是一個具體實例。 #include
#include
#include
#include
#include
#include
#define MAX-LINKS        20 /* 所監(jiān)控的客戶機數(shù)目 */
#define PORTNUM                2330/*端口號*/
struct com-buf/*輔助表*/
{ struct m-table
  { char jkip[13];
   char tz[5];
   int msgsock;
   int key;
  } m-table[MAX-LINKS];
  int skdb,sock;
}*comd;
int link-accept(s)
/**非阻塞方式接收客戶機的連接請求 **/
int s; /* server socket */
{ int i, msgsock, flags=1; /* flags=1 非阻塞 */
struct sockaddr-in monitor;/*客戶機 IP*/
if((msgsock=accept(s, (struct sockaddr)&monitor,
&sizeof(monitor)))m-table.
   jkip,inet-ntoa(monitor.sin-addr))==0)
   { if (comd- >m-table.key==1)
      close(comd- >m-table.msgsock);
ioctl(msgsock, FIONBIO,&flags); /* 置非阻塞方式 */
comd- >m-table.msgsock=msgsock
comd- >m-table.key=1
strcpy(a22, comd- >m-table.tz);
break;
   }
  }
  return 1;
  close(s);
}
void link-read()
/*非阻塞輪詢方式接收客戶機傳來的數(shù)據(jù)*/
{ int msgsock, status, i;
char work[250];
for(i=0;im-table.key==0) continue;
/*無連接則進行下一次輪詢*/
  msgsock=comd->m-table.msgsock；
  /*從輔助表中取分配的socket號*/
  bzero(work, sizeof(work));
  /*數(shù)據(jù)接收的單位長度為sizeof(work)*/
  if((status=recv(msgsock, work,
   sizeof(work),0))sock=sock;/*服務(wù)器的socket號*/
  bzero(&serve, sizeof(serve));
  serve.sin-family=AF-INET;
  serve.sin-addr.s-addr=INADDR-ANY;
  serve.sin-port=htons (portnum);
  if(bind(sock, (struct sockaddr
  *)&serve, sizeof(serve))
-


本文來自ChinaUnix博客，如果查看原文請點：http://blog.chinaunix.net/u/31/showart_509550.html