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

sdccf

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


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


本文來(lái)自ChinaUnix博客，如果查看原文請(qǐng)點(diǎn)：http://blog.chinaunix.net/u/31/showart_509550.html