Chinaunix首页 | 论坛 | 博客
  • 博客访问: 487011
  • 博文数量: 223
  • 博客积分: 0
  • 博客等级: 民兵
  • 技术积分: 2145
  • 用 户 组: 普通用户
  • 注册时间: 2014-03-01 10:23
个人简介

该坚持的时候坚持,该妥协的时候妥协,该放弃的时候放弃

文章分类

全部博文(223)

文章存档

2017年(56)

2016年(118)

2015年(3)

2014年(46)

我的朋友

分类: C/C++

2016-10-23 22:37:57

一、问题描述
TCP编程学习中,当打开tcp_server后,同时打开一个tcp_client不运行。再打开一个tcp_client发送数据后。
tcp_server没有响应,因为tcp_server建立和第一个tcp_client的连接后,一直在等待它的数据(阻塞状态)。
为了解决这个问题,我们需要创建子进程来接受数据,而父进程只要一直建立连接就行了。这样就能不断的处理数据了。

二、代码改写
tcp_server->tcp_server_fork.c:
  1. #include <sys/types.h>
  2. #include <sys/socket.h>
  3. #include <stdio.h>
  4. #include <strings.h>
  5. #include <arpa/inet.h>

  6. #define portnum 3333

  7. int main()
  8. {
  9.     int sockfd;
  10.     int new_fd;
  11.     struct sockaddr_in server_addr;
  12.     struct sockaddr_in client_addr;
  13.     char buffer[128];
  14.     int nbyte = 0;
  15.     int sin_size;
  16.     pid_t pid;

  17.     /*1.创建socket*/
  18.     if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
  19.     {
  20.          printf("create socket error!\n");
  21.          exit(1);
  22.     }

  23.     /*2.1设置要绑定的地址*/
  24.     bzero(&server_addr, sizeof(struct sockaddr_in));
  25.     server_addr.sin_family = AF_INET;
  26.     server_addr.sin_port = htons(portnum);
  27.     server_addr.sin_addr.s_addr = htonl(INADDR_ANY);

  28.     /*2.2.绑定地址*/
  29.     bind(sockfd, (struct sockaddr *)&server_addr, sizeof(struct sockaddr));

  30.     /*3.监听端口*/
  31.     listen(sockfd, 5);

  32.     while(1)
  33.     {
  34.     /*4.等待链接*/
  35.         sin_size = sizeof(struct sockaddr);
  36.         new_fd = accept(sockfd, (struct sockaddr *)&client_addr, &sin_size);
  37.         if(new_fd == -1)
  38.         {
  39.             printf("accept socket failed\n");
  40.             exit(1);
  41.         }
  42.         
  43.         printf("server get connection form %s\n", inet_ntoa(client_addr.sin_addr));
  44.         /*由子进程来处理数据通讯*/
  45.     if(pid = fork() == 0)
  46.         {
  47.             /*5.接收数据*/
  48.             nbyte = recv(new_fd, buffer, 128, 0);
  49.             buffer[nbyte] = '\0';
  50.             printf("server received : %s\n",buffer);
  51.             
  52.      /*6.结束链接*/
  53.             close(new_fd);
  54.      close(sockfd);
  55.      exit(0);
  56.         }
  57.     else if(pid < 0)
  58.     {
  59.      printf("fork error!\n");
  60.     }
  61.     }

  62.     close(sockfd);

  63.     return 0;
  64. }

阅读(654) | 评论(0) | 转发(0) |
0

上一篇:vim多行增加缩进

下一篇:守护进程

给主人留下些什么吧!~~