1. 程式人生 > >多程序併發C/S通訊基本模型及實現

多程序併發C/S通訊基本模型及實現

本例實現如下功能:
服務端接收來自客戶端傳送過來的字串,將小寫轉換為大寫後傳送回客戶端。
其中,每一個新客戶端連線後,服務端主程序為此客戶端建立一個子程序進行資料的處理。

多程序併發服務端程式碼

/*server.c*/
#include <stdio.h>
#include <string.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <signal.h>
#include <sys/wait.h>
#include <sys/types.h>
#include <stdlib.h> #include <errno.h> #include <sys/socket.h> #define BUFSIZE 666 #define SERV_PORT 8888 int main() { struct sockaddr_in servaddr, cliaddr; socklen_t cliaddr_len; int listenfd, connfd; char buf[BUFSIZE]; char str[INET_ADDRSTRLEN]; int i, n; pid_t pid; listenfd = socket(AF_INET, SOCK_STREAM, 0
); //開啟一個網路通訊埠,分配一個檔案描述符listenfd bzero(&servaddr, sizeof(servaddr)); //清空服務端套接字 servaddr.sin_family = AF_INET; //地址採用IPv4地址 servaddr.sin_addr.s_addr = htonl(INADDR_ANY);//地址從主機位元組順序轉換成網路位元組順序 servaddr.sin_port = htons(SERV_PORT); //埠號從主機位元組順序轉換成網路位元組順序 /*將檔案描述符listenfd和伺服器地址繫結在一起*/
bind(listenfd, (struct sockaddr*)&servaddr, sizeof(servaddr)); /*宣告listenfd處於監聽狀態,連結個數限制為5*/ listen(listenfd, 20); printf("等待連線....\n"); while(1){ cliaddr_len = sizeof(cliaddr); /*connfd檔案描述符用於和客戶端通訊,服務端呼叫accept()接受連線*/ connfd = accept(listenfd, (struct sockaddr*)&cliaddr, &cliaddr_len); pid = fork(); if(pid == 0){ //建立一個子程序處理資料 close(listenfd);//關閉子程序端的監聽 while(1){ /*從connfd檔案描述符指向的檔案讀取資料*/ n = read(connfd, buf, BUFSIZE); if(n == 0){ printf("另一端已關閉\n"); break; } /*服務端列印*/ printf("從地址%s 埠號%d 接收到資料\n", (char*)inet_ntop(AF_INET, &cliaddr.sin_addr, str, sizeof(str)), ntohs(cliaddr.sin_port)); /*將buf轉化為大寫後寫入connfd*/ for(i = 0; i < n;i++ ){ buf[i] = toupper(buf[i]); } write(connfd, buf, n); } close(connfd);//處理完畢關閉連線 exit(0); }else if(pid > 0){ //父程序 close(connfd);//任務交由子程序處理,父程序關閉 }else{ printf("fork err\n"); } if(n == 0 || n == -1){ break; } } return 0; }

多程序併發客戶端程式碼

/*client.c*/
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <netinet/in.h>

#define BUFSIZE 666
#define SERV_PORT 8888

int main(int argc, char *argv[])
{
    struct sockaddr_in servaddr;
    char buf[BUFSIZE];
    int sockfd, n;

    sockfd = socket(AF_INET, SOCK_STREAM, 0);

    bzero(&servaddr, sizeof(servaddr));
    servaddr.sin_family = AF_INET;
    inet_pton(AF_INET, "127.0.0.1", &servaddr.sin_addr);
    servaddr.sin_port = htons(SERV_PORT);
    /*連線伺服器*/
    connect(sockfd, (struct sockaddr*)&servaddr, sizeof(servaddr));

    while(fgets(buf, BUFSIZE, stdin) != NULL){
        write(sockfd, buf, strlen(buf));
        /*接收服務端資料*/
        n = read(sockfd, buf, BUFSIZE);
        if(n == 0){
            printf("server closed\n");
        }else{
            /*列印輸出buf*/
            write(STDOUT_FILENO, buf, n);
        }
    }

    close(sockfd);
    return 0;
}

執行測試

yu@ubuntu:~/Linux/219/duojincheng$ ls
client.c  server.c
yu@ubuntu:~/Linux/219/duojincheng$ gcc -o server server.c
yu@ubuntu:~/Linux/219/duojincheng$ gcc -o client client.c
yu@ubuntu:~/Linux/219/duojincheng$ ./server
等待連線....
從地址127.0.0.1 埠號32874 接收到資料
從地址127.0.0.1 埠號32874 接收到資料
從地址127.0.0.1 埠號32875 接收到資料
從地址127.0.0.1 埠號32874 接收到資料
從地址127.0.0.1 埠號32875 接收到資料

另開一終端執行客戶端:

yu@ubuntu:~/Linux/219/duojincheng$ ./client
hey guys
HEY GUYS
guole bye
GUOLE BYE

另開一終端執行客戶端:

yu@ubuntu:~/Linux/219/duojincheng$ ./client
nihao ma  wo hen hao ne
NIHAO MA  WO HEN HAO NE
zai jian
ZAI JIAN
ssssssssssssss
SSSSSSSSSSSSSS

這裡寫圖片描述