一个基于tcp的socket代码，友们帮忙指点一下问题

嵌入式教父

下面代码是局域网server同client相互发送数据代码，代码问题是为什么只能互相发送一次数据，再发送，对方就收不到了，求教！
代码如下：
/******* 服务器程序  (server.c) ************/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <strings.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

int
main (int argc, char *argv[])
{
  int sockfd, new_fd, pid, nbytes;
  struct sockaddr_in server_addr;
  struct sockaddr_in client_addr;
  int sin_size, portnumber;
  char buffer[1024 * 1024] = { 0 };
  char hello[1024 * 1024] = { 0 };

  if (argc != 2)
    {
      fprintf (stderr, "Usage:%s portnumber\a\n", argv[0]);
      exit (1);
    }

  if ((portnumber = atoi (argv[1])) < 0)
    {
      perror ("atoi() error\n");
      exit (1);
    }

  /* 服务器端开始建立socket描述符 */
  if ((sockfd = socket (AF_INET, SOCK_STREAM, 0)) == -1)
    {
      perror ("socket() error\n");
      exit (1);
    }

  /* 服务器端填充 sockaddr结构  */
  bzero (&server_addr, sizeof (struct sockaddr_in));
  server_addr.sin_family = AF_INET;
  server_addr.sin_addr.s_addr = htonl (INADDR_ANY);
  server_addr.sin_port = htons (portnumber);

  /* 捆绑sockfd描述符  */
  if (bind
      (sockfd, (struct sockaddr *) (&server_addr),
       sizeof (struct sockaddr)) == -1)
    {
      perror ("bind() error\n");
      exit (1);
    }

  /* 监听sockfd描述符  */
  if (listen (sockfd, 5) == -1)
    {
      perror ("listen() error\n");
      exit (1);
    }

  while (1)
    {

      /* 服务器阻塞,直到客户程序建立连接  */
      sin_size = sizeof (struct sockaddr_in);
      if ((new_fd =
           accept (sockfd, (struct sockaddr *) (&client_addr),
                   &sin_size)) == -1)
        {
          perror ("accept() error\n");
          exit (1);
        }

      fprintf (stderr, "Server get connection from %s\n",
               inet_ntoa (client_addr.sin_addr));
      if ((pid = fork ()) < 0)
        {
          perror ("fork() error\n");
          exit (1);
        }
      else if (pid == 0)
        {
          if ((nbytes = read (new_fd, buffer, sizeof (buffer))) == -1)
            {
              perror ("read() error\n");
              exit (1);
            }
          buffer[nbytes] = '\0';
          fputs (buffer, stdout);
          close (new_fd);
        }
      else
        {
          fgets (hello, sizeof (hello), stdin);
          if (write (new_fd, hello, strlen (hello)) == -1)
            {
              perror ("write() error\n");
              exit (1);
            }

          /* 这个通讯已经结束     */
          close (new_fd);
        }
    }
  close (sockfd);
  exit (0);
}

=================================================================================

/******* 客户端程序  client.c ************/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <strings.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <netdb.h>
int
main (int argc, char *argv[])
{
  int sockfd, pid;
  char buffer[1024 * 1024] = { 0 };
  char hello[1024 * 1024] = { 0 };
  struct sockaddr_in server_addr;
  struct hostent *host;
  int portnumber, nbytes;

  if (argc != 3)
    {
      fprintf (stderr, "Usage:%s hostname portnumber\a\n", argv[0]);
      exit (1);
    }

  if ((host = gethostbyname (argv[1])) == NULL)
    {
      perror ("gethostbyname() error\n");
      exit (1);
    }

  if ((portnumber = atoi (argv[2])) < 0)
    {
      perror ("atoi() error\n");
      exit (1);
    }

  /* 客户程序开始建立 sockfd描述符  */
  if ((sockfd = socket (AF_INET, SOCK_STREAM, 0)) == -1)
    {
      perror ("socket() error\n");
      exit (1);
    }

  /* 客户程序填充服务端的资料       */
  bzero (&server_addr, sizeof (server_addr));
  server_addr.sin_family = AF_INET;
  server_addr.sin_port = htons (portnumber);
  server_addr.sin_addr = *((struct in_addr *) host->h_addr);

  /* 客户程序发起连接请求         */
  if (connect
      (sockfd, (struct sockaddr *) (&server_addr),
       sizeof (struct sockaddr)) < 0)
    {
      perror ("connect() error\n");
      exit (1);
    }
  /* 连接成功了           */
  if ((pid = fork ()) < 0)
    {
      perror ("fork() error\n");
    }
  else if (pid > 0)
    {

      while (1)
        {
          nbytes = read (sockfd, buffer, 1024);
          buffer[nbytes] = '\0';
          fputs (buffer, stdout);
        }
    }
  else
    {
      while (1)
        {
          fgets (hello, sizeof (hello), stdin);
          if (write (sockfd, hello, strlen (hello)) < 0)
            {
              perror ("write() error\n");
              exit (1);
            }

        }
    }
  /* 结束通讯     */
  close (sockfd);
  exit (0);
}

小兔吉

server端接收数据之后，你关闭了socket，建立的连接就终止了，然后while循环继续，阻塞在accept处。client端write函数应该报错了吧。

流氓无产者

server的child/father各自在干吗？child close了，father还在等输入
father应该只是在等 ，child要干现在child/father的干活

嵌入式教父

client端没报错，就是一直死在那，数据发不出去，收不到，不知道是客户端，还是服务端的问题回复 2# 小兔吉
，

   

嵌入式教父

不太明白，send，reciver都在子进程内完成吗？回复 3# 流氓无产者


   

xxwade

accept函数从监听队列中取出连接请求。server收到client信息后new_fd关闭，server与client断开连接。同时，new_fd关闭给该describer解锁，即可以修改new_fd指向的对象。而程序中并没有再次指定，所以它还是指向client_addr。由于之前的连接断开，server中子进程发送数据的方式其实是udp。因而客户端能够收到。而此后客户端再也没有connect服务器，因而服务器的监听队列中一直没有数据，即被阻塞在accpet处。

小兔吉

你的serve端与client端通信的处理不对称。

server端代码中，accept是处于while循环中的。
server端accept取出一个就绪的client连接，创建子进程读数据然后close socket，父进程则负责写数据然后close socket，因此进行一次读写数据之后，这个已连接的socket就无效了。进入下一次循环重新accept。

client端代码中，connect仅有一次，未处于循环中，也就是client这个进程与server只能建立一次连接。
建立连接后，由于server端进行一次读写之后关闭了已连接的socket，那么client端write函数实际上写入一个已关闭的socket句柄中，虽然没有报错。至于read函数，server端将socket关闭之后，应该会返回0，至于下一次read的行为，我也不清楚。
因此client端父子进程中的后续的read、write都与server端无关了。

不清楚你要写成那个样子。如果仅仅是一个client连接server的话，那server端也没必要把accept放到while中，只需要像client端那样将父子进程中read、write函数放到循环中处理就行了。你要处理多个client连接的话，那就把read、write处理都放到子进程中，父进程只负责循环accpet。

回复 4# 嵌入式教父


   

嵌入式教父

恩，这下明白了，非常感谢！讲的很透彻，让我对socket编程又有了更进一步的理解回复 7# 小兔吉


   

嵌入式教父

哦，明白了，这么个流程啊，谢谢，又学到不少 回复 6# xxwade


   

lxk899

回复 6# xxwade


   正解， 每次调用服务端accept后，客户机都要调用connect去连接的。所以只要在服务端把accept移到while之前就应该可以了吧。