Linux網(wǎng)絡(luò)編程——tcp并發(fā)服務(wù)器(多進程)

一爬橡、tcp并發(fā)服務(wù)器概述
一個好的服務(wù)器,一般都是并發(fā)服務(wù)器(同一時刻可以響應(yīng)多個客戶端的請求)。并發(fā)服務(wù)器設(shè)計技術(shù)一般有:多進程服務(wù)器、多線程服務(wù)器挠唆、I/O復(fù)用服務(wù)器等。

二嘱吗、多進程并發(fā)服務(wù)器
Linux 環(huán)境下多進程的應(yīng)用很多,其中最主要的就是網(wǎng)絡(luò)/客戶服務(wù)器玄组。多進程服務(wù)器是當客戶有請求時,服務(wù)器用一個子進程來處理客戶請求谒麦。父進程繼續(xù)等待其它客戶的請求俄讹。這種方法的優(yōu)點是當客戶有請求時,服務(wù)器能及時處理客戶弄匕,特別是在客戶服務(wù)器交互系統(tǒng)中颅悉。對于一個 TCP 服務(wù)器,客戶與服務(wù)器的連接可能并不馬上關(guān)閉,可能會等到客戶提交某些數(shù)據(jù)后再關(guān)閉迁匠,這段時間服務(wù)器端的進程會阻塞剩瓶,所以這時操作系統(tǒng)可能調(diào)度其它客戶服務(wù)進程,這比起循環(huán)服務(wù)器大大提高了服務(wù)性能城丧。
發(fā)達
tcp多進程并發(fā)服務(wù)器
TCP 并發(fā)服務(wù)器的思想是每一個客戶機的請求并不由服務(wù)器直接處理延曙,而是由服務(wù)器創(chuàng)建一個子進程來處理。

tcp多進程并發(fā)服務(wù)器參考代碼:

#include <stdio.h>  
#include <stdlib.h>  
#include <string.h>                         
#include <unistd.h>  
#include <sys/socket.h>  
#include <netinet/in.h>  
#include <arpa/inet.h>      
  
/************************************************************************ 
函數(shù)名稱:   void main(int argc, char *argv[]) 
函數(shù)功能:   主函數(shù)亡哄,用進程建立一個TCP Echo Server 
函數(shù)參數(shù):   無 
函數(shù)返回:   無 
************************************************************************/  
int main(int argc, char *argv[])  
{  
    unsigned short port = 8080;     // 本地端口   
  
    //1.創(chuàng)建tcp套接字  
    int sockfd = socket(AF_INET, SOCK_STREAM, 0);     
    if(sockfd < 0)  
    {  
        perror("socket");  
        exit(-1);  
    }  
      
    //配置本地網(wǎng)絡(luò)信息  
    struct sockaddr_in my_addr;  
    bzero(&my_addr, sizeof(my_addr));     // 清空     
    my_addr.sin_family = AF_INET;         // IPv4  
    my_addr.sin_port   = htons(port);     // 端口  
    my_addr.sin_addr.s_addr = htonl(INADDR_ANY); // ip  
      
    //2.綁定  
    int err_log = bind(sockfd, (struct sockaddr*)&my_addr, sizeof(my_addr));  
    if( err_log != 0)  
    {  
        perror("binding");  
        close(sockfd);        
        exit(-1);  
    }  
      
    //3.監(jiān)聽枝缔,套接字變被動  
    err_log = listen(sockfd, 10);   
    if(err_log != 0)  
    {  
        perror("listen");  
        close(sockfd);        
        exit(-1);  
    }  
      
    while(1) //主進程 循環(huán)等待客戶端的連接  
    {  
          
        char cli_ip[INET_ADDRSTRLEN] = {0};  
        struct sockaddr_in client_addr;  
        socklen_t cliaddr_len = sizeof(client_addr);  
          
        // 取出客戶端已完成的連接  
        int connfd = accept(sockfd, (struct sockaddr*)&client_addr, &cliaddr_len);  
        if(connfd < 0)  
        {  
            perror("accept");  
            close(sockfd);  
            exit(-1);  
        }  
          
        pid_t pid = fork();  
        if(pid < 0){  
            perror("fork");  
            _exit(-1);  
        }else if(0 == pid){ //子進程 接收客戶端的信息,并發(fā)還給客戶端  
            /*關(guān)閉不需要的套接字可節(jié)省系統(tǒng)資源蚊惯, 
              同時可避免父子進程共享這些套接字 
              可能帶來的不可預(yù)計的后果 
            */  
            close(sockfd);   // 關(guān)閉監(jiān)聽套接字愿卸,這個套接字是從父進程繼承過來  
          
            char recv_buf[1024] = {0};  
            int recv_len = 0;  
              
            // 打印客戶端的 ip 和端口  
            memset(cli_ip, 0, sizeof(cli_ip)); // 清空  
            inet_ntop(AF_INET, &client_addr.sin_addr, cli_ip, INET_ADDRSTRLEN);  
            printf("----------------------------------------------\n");  
            printf("client ip=%s,port=%d\n", cli_ip,ntohs(client_addr.sin_port));  
              
            // 接收數(shù)據(jù)  
            while( (recv_len = recv(connfd, recv_buf, sizeof(recv_buf), 0)) > 0 )  
            {  
                printf("recv_buf: %s\n", recv_buf); // 打印數(shù)據(jù)  
                send(connfd, recv_buf, recv_len, 0); // 給客戶端回數(shù)據(jù)  
            }  
              
            printf("client_port %d closed!\n", ntohs(client_addr.sin_port));  
            close(connfd);    //關(guān)閉已連接套接字  
            exit(0);  
              
        }  
        else if(pid > 0){    // 父進程  
            close(connfd);    //關(guān)閉已連接套接字  
        }  
    }  
      
    close(sockfd);  
      
    return 0;  
}  

運行結(jié)果:


最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市截型,隨后出現(xiàn)的幾起案子趴荸,更是在濱河造成了極大的恐慌,老刑警劉巖宦焦,帶你破解...
    沈念sama閱讀 223,002評論 6 519
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件发钝,死亡現(xiàn)場離奇詭異顿涣,居然都是意外死亡,警方通過查閱死者的電腦和手機酝豪,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,357評論 3 400
  • 文/潘曉璐 我一進店門涛碑,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人孵淘,你說我怎么就攤上這事蒲障。” “怎么了夺英?”我有些...
    開封第一講書人閱讀 169,787評論 0 365
  • 文/不壞的土叔 我叫張陵晌涕,是天一觀的道長。 經(jīng)常有香客問我痛悯,道長余黎,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 60,237評論 1 300
  • 正文 為了忘掉前任载萌,我火速辦了婚禮惧财,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘扭仁。我一直安慰自己垮衷,他們只是感情好,可當我...
    茶點故事閱讀 69,237評論 6 398
  • 文/花漫 我一把揭開白布乖坠。 她就那樣靜靜地躺著搀突,像睡著了一般。 火紅的嫁衣襯著肌膚如雪熊泵。 梳的紋絲不亂的頭發(fā)上仰迁,一...
    開封第一講書人閱讀 52,821評論 1 314
  • 那天,我揣著相機與錄音顽分,去河邊找鬼徐许。 笑死,一個胖子當著我的面吹牛卒蘸,可吹牛的內(nèi)容都是我干的雌隅。 我是一名探鬼主播,決...
    沈念sama閱讀 41,236評論 3 424
  • 文/蒼蘭香墨 我猛地睜開眼缸沃,長吁一口氣:“原來是場噩夢啊……” “哼恰起!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起趾牧,我...
    開封第一講書人閱讀 40,196評論 0 277
  • 序言:老撾萬榮一對情侶失蹤村缸,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后武氓,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體梯皿,經(jīng)...
    沈念sama閱讀 46,716評論 1 320
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 38,794評論 3 343
  • 正文 我和宋清朗相戀三年县恕,在試婚紗的時候發(fā)現(xiàn)自己被綠了东羹。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 40,928評論 1 353
  • 序言:一個原本活蹦亂跳的男人離奇死亡忠烛,死狀恐怖属提,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情美尸,我是刑警寧澤冤议,帶...
    沈念sama閱讀 36,583評論 5 351
  • 正文 年R本政府宣布,位于F島的核電站师坎,受9級特大地震影響恕酸,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜胯陋,卻給世界環(huán)境...
    茶點故事閱讀 42,264評論 3 336
  • 文/蒙蒙 一蕊温、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧遏乔,春花似錦义矛、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,755評論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至捻激,卻和暖如春制轰,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背铺罢。 一陣腳步聲響...
    開封第一講書人閱讀 33,869評論 1 274
  • 我被黑心中介騙來泰國打工艇挨, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人韭赘。 一個月前我還...
    沈念sama閱讀 49,378評論 3 379
  • 正文 我出身青樓缩滨,卻偏偏與公主長得像,于是被迫代替她去往敵國和親泉瞻。 傳聞我的和親對象是個殘疾皇子脉漏,可洞房花燭夜當晚...
    茶點故事閱讀 45,937評論 2 361

推薦閱讀更多精彩內(nèi)容