网络编程（二）TCP多线程服务器编程详解

上一篇文章：
网络编程（一)TCP单进程服务器编程详解
而这一篇主要介绍多线程服务器编程
注：这里多线程编程使用的是c++11标准里面的跨平台方法。我前面的博客也详细介绍了这种多线程编程方法的学习，这里就不加赘述，只介绍多线程服务器这个使用场景。
C++新特性（六）多线程（1）线程启动、结束，创建线程、join，detach，线程传参详解

前面已经介绍了单线程服务器编程的一个例子，为了实现一个服务器能够并发响应多个客户端的请求，这里引入多线程的方法：
将原来的单线程服务器改造成多线程服务器只需要改动下面两个地方
1，因为listen()监听函数过后，服务器的ip与端口就会暴露在网络中，网络中连接的各个客户端就可以连接该服务器，而所有的连接请求都会存储在监听文件描述符对应的读缓冲区中，每执行一次accept，就会从该监听文件描述符对应的读缓冲区中读取一个连接，因此，如果是多线程服务器，应该在主线程中将accept函数包含在一个while(1)循环中，让主线程不断从该缓冲区中接收连接。
2，当accept函数执行完以后，就要有对应的子线程处理accept函数返回的客户端，因此，在while循环内部，每当执行完accept成功以后，就创建一个子线程，让该线程去处理该客户端。并且注意子线程创建完以后，让他与主线程detach()。子线程内部的流程就是与客户端互相交流的一些代码。
具体一个例子如下：

// server.c
#include 
#include 
#include 
#include 
#include 
#include 
using namespace std;

void deal_w_r(struct sockaddr_in cliaddr,int cfd)
{
     // 打印客户端的地址信息
    char ip[24] = {0};
    printf("客户端的IP地址: %s, 端口: %dn",
           inet_ntop(AF_INET, &cliaddr.sin_addr.s_addr, ip, sizeof(ip)),
           ntohs(cliaddr.sin_port));

    // 5. 和客户端通信
    while(1)
    {
        // 接收数据
        char buf[1024];
        memset(buf, 0, sizeof(buf));
        int len = read(cfd, buf, sizeof(buf));
        if(len > 0)
        {
            printf("%d客户端say: %sn",ntohs(cliaddr.sin_port), buf);
            write(cfd, buf, len);
        }
        else if(len  == 0)
        {
            printf("%d客户端断开了连接...n",ntohs(cliaddr.sin_port));
            break;
        }
        else
        {
            perror("read");
            break;
        }
    }

    close(cfd);
}

int main()
{
    // 1. 创建监听的套接字
    int lfd = socket(AF_INET, SOCK_STREAM, 0);
    if(lfd == -1)
    {
        perror("socket");
        exit(0);
    }

    // 2. 将socket()返回值和本地的IP端口绑定到一起
    struct sockaddr_in addr;
    addr.sin_family = AF_INET;
    addr.sin_port = htons(5000);   // 大端端口
    // INADDR_ANY代表本机的所有IP, 假设有三个网卡就有三个IP地址
    // 这个宏可以代表任意一个IP地址
    // 这个宏一般用于本地的绑定操作
    addr.sin_addr.s_addr = INADDR_ANY;  // 这个宏的值为0 == 0.0.0.0
//    inet_pton(AF_INET, "192.168.237.131", &addr.sin_addr.s_addr);
    int ret = bind(lfd, (struct sockaddr*)&addr, sizeof(addr));
    if(ret == -1)
    {
        perror("bind");
        exit(0);
    }

    // 3. 设置监听
    ret = listen(lfd, 128);
    if(ret == -1)
    {
        perror("listen");
        exit(0);
    }

    // 4. 阻塞等待并接受客户端连接
    struct sockaddr_in cliaddr;
    int clilen = sizeof(cliaddr);
    while(1)
    {
        int cfd = accept(lfd, (struct sockaddr*)&cliaddr, (socklen_t*)&clilen);
        if(cfd == -1)
        {
            perror("accept");
            exit(0);
        }
        thread obj(deal_w_r,cliaddr,cfd);
        obj.detach();
    } 
    close(lfd);

    return 0;
}

注意：在vscode中有可能识别不了c++11标准里面的thread，对于thread可能会标红线，报编译错误，因此需要点击该红线，编辑"includePath”设置，设置c的标准为c11，c++标准为c++11。并且编译的时候记得加入参数
-std=c++11
-lpthread

g++ server.cpp -std=c++11 -lpthread -o s