日期:2014-05-16  浏览次数:20777 次

Linux源码-TCP网络服务器的实现

/*********************************************ABOUT FILE*********************************************
***File Name:CycleTCPServer
***Purpose: 循环tcp服务端程序
***Note:网络服务器就两大类:循环服务和并发服务。首先,循环网络服务器编程实现的步骤是这样的:这种服务
 器模型是典型循环服务,如果不加上多进程/线程技术,此种服务吞吐量有限,大家都可以看到,如果前一个连
 接服务数据没有收发完毕后面的连接没办法处理。所以一般有多进程技术,对一个新连接启用一个新进程去处
 理,而监听socket继续监听。
***Wrote By: DanyLin
***Date Time: 2013-08-24
***Note: 任何人可以任意复制代码并运用这些文档,当然包括你的商业用途,但请遵循GPL
****************************************************************************************************/

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

int main(int argc, char ** argv)

{
 int sockfd,new_fd;
 struct sockaddr_in my_addr;
 struct sockaddr_in their_addr;
 unsigned int sin_size, myport, lisnum;
 
 if(argv[1])
  myport = atoi(argv[1]);
 else
  myport = 7838;


    if(argv[2])
     lisnum = atoi(argv[2]);
    else
     lisnum = 2;
   
    if ((sockfd = socket(PF_INET, SOCK_STREAM, 0)) == -1)
    {
     perror("socket");
     exit(1);
    }

    my_addr.sin_family=PF_INET;
    my_addr.sin_port=htons(myport);
    my_addr.sin_addr.s_addr = INADDR_ANY;
    bzero(&(my_addr.sin_zero), 0);
   
    if(bind(sockfd, (struct sockaddr *)&my_addr, sizeof(struct sockaddr)) == -1)
    {
     perror("bind");
     exit(1);
    }
   
    if (listen(sockfd, lisnum) == -1)
    {
     perror("listen");
     exit(1);
    }

    while(1)
    {
     sin_size = sizeof(struct sockaddr_in);
        if ((new_fd = accept(sockfd, (struct sockaddr *)&their_addr, &sin_size)) == -1)
        {
         perror("accept");
         continue;
        }

        printf("server: got connection from %s\n",inet_ntoa(their_addr.sin_addr));

        if (!fork())
        {
         if (send(new_fd, "Hello, world!\n", 14, 0) == -1)
         {
          perror("send");
                close(new_fd);
                exit(0);
            }

        }
       
        close(new_fd);
        waitpid(-1,NULL,WNOHANG);
    }
}

 

/*********************************************ABOUT FILE*********************************************