c++ 网络编程（二）TCP/IP linux 下多进程socket通信多个客户端与单个服务端交互代码实现回声服务器

原文作者：aircraft

原文链接：https://www.cnblogs.com/DOMLX/p/9612820.html

LINUX下：

一.服务端代码

下面用了多个close来关闭文件描述符，可能有的小伙伴会有疑惑。。。。我就说一句，创建进程的时候会把父进程的资源都复制一份，而你这个子进程只需要保留自己需要处理的资源，其他的自然要关闭掉，

不然父亲一个儿子一个待会打起来怎么办嘿嘿

注意了：就像进程间的通信需要属于操作系统的资源管道来进行，套接字也属于操作系统，所以创建新进程也还是只有原来的那个，复制的资源只不过是文件描述符而已，我们关闭的也是这个文件描述符

//基于多进程的并发服务器实现
//注：子进程会复制父进程拥有的所有资源
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <signal.h>
#include <sys/wait.h>

#define BUF_SIZE 30

void error_handling(char *message);
void read_childproc(int sig);

int main(int argc, char *argv[])
{
  //定义TCP连接变量
  int serv_sock;
  int clnt_sock;
  struct sockaddr_in serv_addr;
  struct sockaddr_in clnt_addr;
  socklen_t clnt_addr_size;
  int str_len;
  char buf[BUF_SIZE];
  //定义信号处理变量
  pid_t pid;
  struct sigaction act;
  int state;

  if(argc!=2)
  {
    exit(1);
  }
  //配置信号处理函数
  act.sa_handler=read_childproc;
  sigemptyset(&act.sa_mask);
  act.sa_flags=0;
  sigaction(SIGCHLD, &act, 0);

  //TCP套接字配置
  serv_sock=socket(PF_INET, SOCK_STREAM, 0);
  if(serv_sock == -1)
    error_handling("socket error!");

  memset(&serv_addr, 0, sizeof(serv_addr));
  serv_addr.sin_family = AF_INET;    //IPV4协议族
  serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);    //主机字节序（host）转换成网络字节序（net）（大端序）
  serv_addr.sin_port = htons(atoi(argv[1]));    //端口号
  if(bind(serv_sock, (struct sockaddr*) &serv_addr, sizeof(serv_addr)) == -1)
    error_handling("bind error");

  if(listen(serv_sock, 5) == -1)
    error_handling("listen error");

  while(1)
  {
    clnt_addr_size = sizeof(clnt_addr);
    clnt_sock=accept(serv_sock, (struct sockaddr*) &clnt_addr, &clnt_addr_size);
    if(clnt_sock == -1)
      continue;
    else
      puts("new client connected...");

    pid=fork();    //创建新进程
    if(pid==-1)
    {
      close(clnt_sock);
      continue;
    }
    if(pid==0)    //子进程运行区域
    {
      close(serv_sock);    //在子进程中要关闭服务器套接字文件描述符
      while((str_len=read(clnt_sock, buf, BUF_SIZE))!=0)
    write(clnt_sock, buf, str_len);

      close(clnt_sock);//执行完关闭自己的文件描述符
      puts("client disconnected...");
      return 0;
    }
    else    //父进程运行区域
    {
      //调用fork函数后，要将无关的套接字文件描述符关闭掉
      close(clnt_sock);
    }
  }

  close(serv_sock);
  return 0;
}

void error_handling(char *message)
{
  fputs(message, stderr);
  fputc(‘\n‘, stderr);
  exit(1);
}

//一旦有子进程结束就调用这个函数
void read_childproc(int sig)
{
  int status;
  pid_t id=waitpid(-1, &status, WNOHANG);//等待子进程终止
  if(WIFEXITED(status))
  {
    printf("remove proc id: %d \n", id);
    printf("child send: %d \n", WEXITSTATUS(status));
  }
}

二.客户端代码

这里说一下这里用多进程分割I/O（输入/输出）,是为了代码的分割提高程序优化，在输入数据的时候不需要考虑输出，在一个地方不用写两个地方的代码，虽然代码可能变多了，但是程序确实优化了，老经验的程序员就能体会到了

然后为什么write_routine里还要调用shutdown给服务端传输EOF，MAIN函数最后不是有close可以向服务端发送吗？？？这是因为我们创建了子进程，没有办法通过一次调用close传递EOF，不然会出大问题的！！所以自己在子进程里手工调用shutdown发送EOF，告诉服务端：“嘿哥们，我差不多要凉凉了下辈子有缘再见吧QAQ” 哈哈哈哈哈哈哈

//分割IO实现分割数据的收发过程
//父进程负责接收，子进程负责发送
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>

#define BUF_SIZE 30

void error_handling(char *message);
void read_routine(int sock, char *buf);
void write_routine(int sock, char *buf);

int main(int argc, char *argv[])
{
  int sock;
  pid_t pid;
  struct sockaddr_in serv_addr;
  int str_len;
  char buf[BUF_SIZE];

  if(argc!=3)
  {
    exit(1);
  }

  sock=socket(PF_INET, SOCK_STREAM, 0);
  if(sock == -1)
    error_handling("socket error!");

  memset(&serv_addr, 0, sizeof(serv_addr));
  serv_addr.sin_family = AF_INET;
  serv_addr.sin_addr.s_addr = inet_addr(argv[1]);
  serv_addr.sin_port = htons(atoi(argv[2]));

  if(connect(sock, (struct sockaddr*) &serv_addr, sizeof(serv_addr)) == -1)
    error_handling("connect error");
  else
    puts("Connected.....");

  pid=fork();
  if(pid==0)    //子进程写
    write_routine(sock, buf);
  else    //父进程读
    read_routine(sock, buf);

  close(sock);
  return 0;
}

void error_handling(char *message)
{
  fputs(message, stderr);
  fputc(‘\n‘, stderr);
  exit(1);
}

//这里实现读入有关代码
void read_routine(int sock, char* buf)
{
  while(1)
  {
    int str_len=read(sock, buf, BUF_SIZE);
    if(str_len==0)
      return;    //接受到EOF结束符时返回

    buf[str_len]=0;
    printf("message from server: %s \n", buf);
  }
}

//这里负责实现输出有关代码
void write_routine(int sock, char* buf)
{
  while(1)
  {
    fgets(buf, BUF_SIZE, stdin);
    if(!strcmp(buf, "q\n") || !strcmp(buf, "Q\n"))
    {
      shutdown(sock, SHUT_WR);
      return;
    }
    write(sock, buf, strlen(buf));
  }
}

同时多进程服务端也是有缺点的，每创建一个进程就代表大量的运算与内存空间占用，相互进程数据交换也很麻烦。。。那么怎么解决呢，在我后面的博客也许会给出答案-----hhhhhhh

参考书籍《TCP/IP网络编程---尹圣雨》

原文地址：https://www.cnblogs.com/DOMLX/p/9612820.html

时间： 2024-08-09 06:33:54

c++ 网络编程（二）TCP/IP linux 下多进程socket通信多个客户端与单个服务端交互代码实现回声服务器

c++ 网络编程（二）TCP/IP linux 下多进程socket通信多个客户端与单个服务端交互代码实现回声服务器的相关文章

网络编程学习笔记：linux下的socket编程

linux下的socket通信小程序分享

【网络编程】TCP/IP协议

2015/12/14 Python网络编程，TCP/IP客户端和服务器初探

Android之从TCP/IP、HTTP看Socket通信

linux网络编程基础——TCP/IP认识

Java 网络编程--------------------基于TCP/IP（加入多线程）

初试linux下的Socket通信（下）

linux网络编程之TCP/IP基础篇（一）

c++ 网络编程（二）TCP/IP linux 下多进程socket通信 多个客户端与单个服务端交互代码实现回声服务器

c++ 网络编程（二）TCP/IP linux 下多进程socket通信 多个客户端与单个服务端交互代码实现回声服务器的相关文章

c++ 网络编程（二）TCP/IP linux 下多进程socket通信多个客户端与单个服务端交互代码实现回声服务器

c++ 网络编程（二）TCP/IP linux 下多进程socket通信多个客户端与单个服务端交互代码实现回声服务器的相关文章