1. 程式人生 > >多執行緒實現伺服器與多個客戶端通訊,客戶端之間相互不干擾

多執行緒實現伺服器與多個客戶端通訊,客戶端之間相互不干擾

1,服務端建立ServerSocket繫結埠號,迴圈呼叫accept()方法

2,客戶端建立一個socket並請求和伺服器端連線

3,伺服器端接受客戶端請求,建立socket與該客戶建立連線

4,兩個socket在一個單獨的執行緒上通話

5,伺服器端繼續等待新的連線

也就是說當有一個新的客戶端與服務端連線,就建立一個新的socket並在這個執行緒裡面通訊。

客戶端主要程式碼:

char name[30]={0};
    printf("請輸入伺服器的主機名或者ip\n");
    scanf("%s",name);
    struct hostent *h;
    //獲取伺服器資訊
    h=gethostbyname(name);
    if(NULL==h)
    {
        perror("geyhostbyname");
        exit(1);
    }
    //初始化套接字
    int sockfd=socket(AF_INET,SOCK_STREAM,0);
    if(-1==sockfd)
    {
        perror("socket");
        exit(2);
    }
    struct sockaddr_in server_addr;
    server_addr.sin_family=AF_INET;
    server_addr.sin_port=htons(portnum);
    server_addr.sin_addr=*((struct in_addr *)h->h_addr_list[0]);
    if(-1==connect(sockfd,(struct sockaddr *)&server_addr,sizeof(server_addr)))
    {
        perror("connect");
        exit(3);
    }

伺服器主要程式碼:


    //初始化套接字
    int sockfd=socket(AF_INET,SOCK_STREAM,0);
    if(-1==sockfd)
    {
        perror("socket");
        exit(1);
    }
    //繫結埠和ip;
    struct sockaddr_in server_addr;   //struct sockaddr_in為結構體型別 ,server_addr為定義的結構體   
    server_addr.sin_family=AF_INET;   //Internet地址族=AF_INET(IPv4協議) 
    server_addr.sin_port=htons(portnum);  //將主機位元組序轉化為網路位元組序 ,portnum是埠號
    (server_addr.sin_addr).s_addr=htonl(INADDR_ANY);//IP地址
    if(-1==bind(sockfd,(struct sockaddr *)&server_addr,sizeof(server_addr)))  //套接字與埠繫結
    {
        perror("bind");
        exit(6);
    }
    //開啟監聽
    if(-1==listen(sockfd,5)) //5是最大連線數,指伺服器最多連線5個使用者
    {
        perror("listen");
        exit(7);
    }
    while(1)
    {
        struct sockaddr_in client_addr;
        int size=sizeof(client_addr);
        int new_fd=accept(sockfd,(struct sockaddr *)&client_addr,&size);  //sockfd伺服器的socket描述字,&client_addr指向struct sockaddr *的指標,&size指向協議地址長度指標

        if(-1==new_fd)
        {
            perror("accept");
            continue;       //進行下一次迴圈
        }
        printf("accept client ip:%s:%d\n",inet_ntoa(client_addr.sin_addr),client_addr.sin_port);
        //inet_ntoa將一個十進位制網路位元組序轉換為點分十進位制IP格式的字串。
        int ret;
        int pthread_id;
        pthread_create((pthread_t *)&pthread_id,NULL,net_thread,(void *)&new_fd);
        if(-1==ret)
        {
            perror("pthread_create");
            close(new_fd);
            continue;
        }
    }
    close(sockfd);