国产一级a片免费看高清,亚洲熟女中文字幕在线视频,黄三级高清在线播放,免费黄色视频在线看

打開APP
userphoto
未登錄

開通VIP,暢享免費電子書等14項超值服

開通VIP
c/c++實現(xiàn)一個密集型server/socket/多路復(fù)用/select
c/c++實現(xiàn)一個密集型server/socket/多路復(fù)用/select  作一個tcp的服務(wù)程序,同時可能有大量的客戶端連上來,希望分別記住各個socket
誰有數(shù)據(jù)過來,就讀出來,放到一個請求隊列--這些事情用一個線程完成
另外有一個結(jié)果隊列,如果結(jié)果里包含了socket的編號,用一個線程專門:
取出來按編號找回原來發(fā)送者socket,發(fā)回給原來的客戶端
還有一個就是處理線程(池),它取出請求隊列里的一個請求,進(jìn)行處理,
把處理結(jié)果放入結(jié)果隊列
不知道有沒有現(xiàn)成的框架?
網(wǎng)上只找到一些很。。。的:
http://fanqiang.chinaunix.net/a4/b7/20010508/112359.html
Linux網(wǎng)絡(luò)編程--9. 服務(wù)器模型
http://linuxc.51.net 作者:hoyt (2001-05-08 11:23:59)
    學(xué)習(xí)過《軟件工程》吧.軟件工程可是每一個程序員"必修"的課程啊.如果你沒有學(xué)習(xí)過, 建議你去看一看. 在這一章里面,我們一起來從軟件工程的角度學(xué)習(xí)網(wǎng)絡(luò)編程的思想.在我們寫程序之前, 我們都應(yīng)該從軟件工程的角度規(guī)劃好我們的軟件,這樣我們開發(fā)軟件的效率才會高. 在網(wǎng)絡(luò)程序里面,一般的來說都是許多客戶機(jī)對應(yīng)一個服務(wù)器.為了處理客戶機(jī)的請求, 對服務(wù)端的程序就提出了特殊的要求.我們學(xué)習(xí)一下目前最常用的服務(wù)器模型. 
循環(huán)服務(wù)器:循環(huán)服務(wù)器在同一個時刻只可以響應(yīng)一個客戶端的請求 
并發(fā)服務(wù)器:并發(fā)服務(wù)器在同一個時刻可以響應(yīng)多個客戶端的請求 

9.1 循環(huán)服務(wù)器:UDP服務(wù)器 
UDP循環(huán)服務(wù)器的實現(xiàn)非常簡單:UDP服務(wù)器每次從套接字上讀取一個客戶端的請求,處理, 然后將結(jié)果返回給客戶機(jī). 
可以用下面的算法來實現(xiàn). 
   socket(...);
   bind(...);
   while(1)
    {
         recvfrom(...);
         process(...);
         sendto(...);
   }
因為UDP是非面向連接的,沒有一個客戶端可以老是占住服務(wù)端. 只要處理過程不是死循環(huán), 服務(wù)器對于每一個客戶機(jī)的請求總是能夠滿足. 
9.2 循環(huán)服務(wù)器:TCP服務(wù)器 
TCP循環(huán)服務(wù)器的實現(xiàn)也不難:TCP服務(wù)器接受一個客戶端的連接,然后處理,完成了這個客戶的所有請求后,斷開連接. 
算法如下: 
        socket(...);
        bind(...);
        listen(...);
        while(1)
        {
                accept(...);
                while(1)
                {
                        read(...);
                        process(...);
                        write(...);
                }
                close(...);
        }
TCP循環(huán)服務(wù)器一次只能處理一個客戶端的請求.只有在這個客戶的所有請求都滿足后, 服務(wù)器才可以繼續(xù)后面的請求.這樣如果有一個客戶端占住服務(wù)器不放時,其它的客戶機(jī)都不能工作了.因此,TCP服務(wù)器一般很少用循環(huán)服務(wù)器模型的. 
9.3 并發(fā)服務(wù)器:TCP服務(wù)器 
為了彌補(bǔ)循環(huán)TCP服務(wù)器的缺陷,人們又想出了并發(fā)服務(wù)器的模型. 并發(fā)服務(wù)器的思想是每一個客戶機(jī)的請求并不由服務(wù)器直接處理,而是服務(wù)器創(chuàng)建一個 子進(jìn)程來處理. 
算法如下: 
  socket(...);
  bind(...);
  listen(...);
  while(1)
  {
        accept(...);
        if(fork(..)==0)
          {
              while(1)
               {        
                read(...);
                process(...);
                write(...);
               }
           close(...);
           exit(...);
          }
        close(...);
  }     
TCP并發(fā)服務(wù)器可以解決TCP循環(huán)服務(wù)器客戶機(jī)獨占服務(wù)器的情況. 不過也同時帶來了一個不小的問題.為了響應(yīng)客戶機(jī)的請求,服務(wù)器要創(chuàng)建子進(jìn)程來處理. 而創(chuàng)建子進(jìn)程是一種非常消耗資源的操作. 
9.4 并發(fā)服務(wù)器:多路復(fù)用I/O 
為了解決創(chuàng)建子進(jìn)程帶來的系統(tǒng)資源消耗,人們又想出了多路復(fù)用I/O模型. 
首先介紹一個函數(shù)select 
 int select(int nfds,fd_set *readfds,fd_set *writefds,
                fd_set *except fds,struct timeval *timeout)
 void FD_SET(int fd,fd_set *fdset)
 void FD_CLR(int fd,fd_set *fdset)
 void FD_ZERO(fd_set *fdset)
 int FD_ISSET(int fd,fd_set *fdset)
一般的來說當(dāng)我們在向文件讀寫時,進(jìn)程有可能在讀寫出阻塞,直到一定的條件滿足. 比如我們從一個套接字讀數(shù)據(jù)時,可能緩沖區(qū)里面沒有數(shù)據(jù)可讀(通信的對方還沒有發(fā)送數(shù)據(jù)過來),這個時候我們的讀調(diào)用就會等待(阻塞)直到有數(shù)據(jù)可讀.如果我們不 希望阻塞,我們的一個選擇是用select系統(tǒng)調(diào)用. 只要我們設(shè)置好select的各個參數(shù),那么當(dāng)文件可以讀寫的時候select回"通知"我們 說可以讀寫了. readfds所有要讀的文件文件描述符的集合 
writefds所有要的寫文件文件描述符的集合 
exceptfds其他的服要向我們通知的文件描述符 
timeout超時設(shè)置. 
nfds所有我們監(jiān)控的文件描述符中最大的那一個加1 
在我們調(diào)用select時進(jìn)程會一直阻塞直到以下的一種情況發(fā)生. 1)有文件可以讀.2)有文件可以寫.3)超時所設(shè)置的時間到. 
為了設(shè)置文件描述符我們要使用幾個宏. FD_SET將fd加入到fdset 
FD_CLR將fd從fdset里面清除 
FD_ZERO從fdset中清除所有的文件描述符 
FD_ISSET判斷fd是否在fdset集合中 
使用select的一個例子 
int use_select(int *readfd,int n)
{
   fd_set my_readfd;
   int maxfd;
   int i;
   
   maxfd=readfd[0];
   for(i=1;i    if(readfd[i]>maxfd) maxfd=readfd[i];
   while(1)
   {
        /*   將所有的文件描述符加入   */
        FD_ZERO(&my_readfd);
        for(i=0;i            FD_SET(readfd[i],*my_readfd);
        /*     進(jìn)程阻塞                 */
        select(maxfd+1,& my_readfd,NULL,NULL,NULL); 
        /*        有東西可以讀了       */
        for(i=0;i          if(FD_ISSET(readfd[i],&my_readfd))
              {
                  /* 原來是我可以讀了  */ 
                        we_read(readfd[i]);
              }
   }
}
使用select后我們的服務(wù)器程序就變成了. 

        初始話(socket,bind,listen);
        
    while(1)
        {
        設(shè)置監(jiān)聽讀寫文件描述符(FD_*);   
        
        調(diào)用select;
        
        如果是傾聽套接字就緒,說明一個新的連接請求建立
             { 
                建立連接(accept);
                加入到監(jiān)聽文件描述符中去;
             }
       否則說明是一個已經(jīng)連接過的描述符
                {
                    進(jìn)行操作(read或者write);
                 }
                        
        }               
多路復(fù)用I/O可以解決資源限制的問題.著模型實際上是將UDP循環(huán)模型用在了TCP上面. 這也就帶來了一些問題.如由于服務(wù)器依次處理客戶的請求,所以可能會導(dǎo)致有的客戶 會等待很久. 
9.5 并發(fā)服務(wù)器:UDP服務(wù)器 
人們把并發(fā)的概念用于UDP就得到了并發(fā)UDP服務(wù)器模型. 并發(fā)UDP服務(wù)器模型其實是簡單的.和并發(fā)的TCP服務(wù)器模型一樣是創(chuàng)建一個子進(jìn)程來處理的 算法和并發(fā)的TCP模型一樣. 
除非服務(wù)器在處理客戶端的請求所用的時間比較長以外,人們實際上很少用這種模型. 

9.6 一個并發(fā)TCP服務(wù)器實例 
#include 
#include 
#include 
#include 
#include 
#define MY_PORT         8888
int main(int argc ,char **argv)
{
 int listen_fd,accept_fd;
 struct sockaddr_in     client_addr;
 int n;
 
 if((listen_fd=socket(AF_INET,SOCK_STREAM,0))<0)
  {
        printf("Socket Error:%s\n\a",strerror(errno));
        exit(1);
  }
 
 bzero(&client_addr,sizeof(struct sockaddr_in));
 client_addr.sin_family=AF_INET;
 client_addr.sin_port=htons(MY_PORT);
 client_addr.sin_addr.s_addr=htonl(INADDR_ANY);
 n=1;
 /* 如果服務(wù)器終止后,服務(wù)器可以第二次快速啟動而不用等待一段時間  */
 setsockopt(listen_fd,SOL_SOCKET,SO_REUSEADDR,&n,sizeof(int));
 if(bind(listen_fd,(struct sockaddr *)&client_addr,sizeof(client_addr))<0)
  {
        printf("Bind Error:%s\n\a",strerror(errno));
        exit(1);
  }
  listen(listen_fd,5);
  while(1)
  {
   accept_fd=accept(listen_fd,NULL,NULL);
   if((accept_fd<0)&&(errno==EINTR))
          continue;
   else if(accept_fd<0)
    {
        printf("Accept Error:%s\n\a",strerror(errno));
        continue;
    }
  if((n=fork())==0)
   {
        /* 子進(jìn)程處理客戶端的連接 */
        char buffer[1024];
        close(listen_fd);
        n=read(accept_fd,buffer,1024);
        write(accept_fd,buffer,n);
        close(accept_fd);
        exit(0);
   }
   else if(n<0)
        printf("Fork Error:%s\n\a",strerror(errno));
   close(accept_fd);
  }
你可以用我們前面寫客戶端程序來調(diào)試著程序,或者是用來telnet調(diào)試 
 
 

http://www.csdn.com.cn/program/6713.htm
Linux網(wǎng)絡(luò)服務(wù)器
   瀏覽選項: 大中小  顏色 默認(rèn) 灰度 橄欖色 綠色 藍(lán)色 褐色 紅色   
 
  
 
 
     Linux系統(tǒng)網(wǎng)絡(luò)服務(wù)器模型主要有兩種:并發(fā)服務(wù)器和循環(huán)服務(wù)器。所謂并發(fā)服務(wù)器就是在同一個時刻可以處理來自多個客戶端的請求;循環(huán)服務(wù)器是指服務(wù)器在同一時刻指可以響應(yīng)一個客戶端的請求。而且對于TCP和UDP套接字,這兩種服務(wù)器的實現(xiàn)方式也有不同的特點。
1、TCP循環(huán)服務(wù)器:首先TCP服務(wù)器接受一個客戶端的連接請求,處理連接請求,在完成這個客戶端的所有請求后斷開連接,然后再接受下一個客戶端的請求。
   創(chuàng)建TCP循環(huán)服務(wù)器的算法如下:
    socket(……);   //創(chuàng)建一個TCP套接字
    bind(……);      //邦定公認(rèn)的端口號
    listen(……);  //傾聽客戶端連接
    while(1)          //開始循環(huán)接收客戶端連接
   {
                accept(……);//接收當(dāng)前客戶端的連接
                while(1)
                 {                    //處理當(dāng)前客戶端的請求
                         read(……);
                         process(……);
                          write(……);
                 }
                close(……);   //關(guān)閉當(dāng)前客戶端的連接,準(zhǔn)備接收下一個客戶端連接
    }
TCP循環(huán)服務(wù)器一次只處理一個客戶端的請求,如果有一個客戶端占用服務(wù)器不放時,其它的客戶機(jī)連接請求都得不到及時的響應(yīng)。因此,TCP服務(wù)器一般很少用循環(huán)服務(wù)器模型的。
本站僅提供存儲服務(wù),所有內(nèi)容均由用戶發(fā)布,如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容,請點擊舉報。
打開APP,閱讀全文并永久保存 查看更多類似文章
猜你喜歡
類似文章
《Python程序設(shè)計》第10章 網(wǎng)絡(luò)編程
用Socket編程之TCP/IP通信,你會了嗎?
UDP協(xié)議(User Datagram Protocol)
Linux IO多路轉(zhuǎn)接——UDP通信
LINUX同機(jī)器下進(jìn)程間UDP通信
幾種TCP連接中出現(xiàn)RST的情況( 比較詳細(xì))
更多類似文章 >>
生活服務(wù)
分享 收藏 導(dǎo)長圖 關(guān)注 下載文章
綁定賬號成功
后續(xù)可登錄賬號暢享VIP特權(quán)!
如果VIP功能使用有故障,
可點擊這里聯(lián)系客服!

聯(lián)系客服