网络并发服务器设计

　　　　　　　　　　　　网络并发服务器设计

#include <stdio.h>
#include <sys/types.h>   
#include <sys/socket.h>
#include <string.h>
#include <netinet/in.h>

#include <unistd.h>

#define portnum 3333

int main()
{
    int sockfd;
    int new_fd;
    char buffer[128];
    int sin_size;
    struct sockaddr_in server_addr;
    struct sockaddr_in client_addr;
    int nbyte=10;    //表示服务器打印前十个字节
    int pid;
    
    //1.创建套接字
    if((sockfd = socket(AF_INET,SOCK_STREAM,0)) == -1)
    {
        printf("creat socket error!
");
        exit(1);
    }
    
    //2.1设置绑定的地址
    bzero(&server_addr,sizeof(struct sockaddr_in)); 
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(portnum);
    server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
    
    //2.2绑定地址
    bind(sockfd, (struct sockaddr *)(&server_addr),sizeof(struct sockaddr));

    //3.监听端口
    listen(sockfd,5);
    
    while(1)
    {
        //4.等待连接
        sin_size = sizeof(struct sockaddr);
        new_fd = accept(sockfd,(struct sockaddr *)(&client_addr),&sin_size);
        printf("server get connection %s
",inet_ntoa(client_addr.sin_addr));
        
        //创建子进程，由子进程处理数据通讯
49         if((pid = fork())== 0)
50         {
51             //5.接受数据
52             recv(new_fd,buffer,128,0);
53             buffer[nbyte] = '';
54             printf("server receive : %s
",buffer);
55             close(new_fd);
56             close(sockfd);
57             exit(0);
58         }
59         else if(pid<0)
60             printf("fork error!
");
    
        //6.结束连接
        close(new_fd);
    }
    close(sockfd);
}

 与TCP服务器程序相比较添加以上特殊颜色的代码即可实现并发服务器设计：TCP服务器程序设计