嵌入式中，TCP server如何与多个client通信？（附代码）-良许Linux教程网

在上一篇文章中，我们分享了嵌入式开发中TCP通信常用接口的使用封装。在示例中，我们只实现了简单的一对一通信。

然而，在实际开发中，TCP服务器需要支持与多个客户端同时进行通信。因此，本篇文章将分享实现一对多通信的方法，即TCP服务器并发处理。

实现TCP服务器并发处理的方式有多种，包括多进程和多线程。

由于多进程方式的开销较大，并不常用。因此，本篇文章将重点介绍多线程的方法来实现TCP服务器的并发处理。

简单的demo

tcp_server.c：

*左右滑动查看全部代码>>>*

#include 
#include "tcp_socket.h"

static pthread_t cli_data_proce_thread_tid;

static void *process_client_data(void *arg)
{
    int client_fd = *(int*)arg;

    while (1)
    {
        char buf[128] = {0};
        
        int recv_len = tcp_blocking_recv(client_fd, buf, sizeof(buf));
        if (recv_len printf("recv error!\n");
            tcp_close(client_fd);
            return NULL;
        }
        printf("client_fd = %d, recv : %s\n", client_fd, buf);

        int send_len = tcp_send(client_fd, buf, strlen(buf));
        if (send_len printf("send error!\n");
            tcp_close(client_fd);
            return NULL;
        }
        else
        {
            printf("send success! send: %s, send_len: %d\n", buf, send_len);
        }
        usleep(10 * 1000);
    }
}

int main(int argc, char **argv)
{
    printf("==================tcp server==================\n");
    int server_fd = tcp_init(NULL, 4321);

    while (1)
    {
        int new_fd = tcp_accept(server_fd);

        // 创建客户端数据处理线程
        int ret = pthread_create(&cli_data_proce_thread_tid, NULL, process_client_data, (void*)&new_fd);
        if(ret != 0)
        {
            perror("pthread_create");
            exit(EXIT_FAILURE);
        }
    }

    tcp_close(server_fd);

    return 0;
}

主线程，监听客户端连接；cli_data_proce_thread_tid线程处理客户端数据。下面我们创建4个client与该server进行连接。

首先，需要注意的是，我们创建tcp_server的方式为：

左右滑动查看全部代码>>>

int server_fd = tcp_init(NULL, 4321);
int tcp_init(const char* ip, int port)
{
    int optval = 1; 
    int server_fd = socket(AF_INET, SOCK_STREAM, 0);
    if (server_fd "socket");
        return -1;
    }

    /* 解除端口占用 */
    if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval)) "setsockopt\n");
  return -1;
 }

    struct sockaddr_in server_addr;
    bzero(&server_addr, sizeof(struct sockaddr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(port);
    if (NULL == ip)
    {
        server_addr.sin_addr.s_addr = htonl(INADDR_ANY); 
    }
    else
    {
        server_addr.sin_addr.s_addr = inet_addr(ip); 
    }

    if (bind(server_fd, (struct sockaddr*)&server_addr,sizeof(struct sockaddr)) "bind");
        close(server_fd);
        return -1;
    }

    if(listen(server_fd, MAX_CONNECT_NUM) "listen");
        close(server_fd);
        return -1;
    }

    return server_fd;
}