手把手教你TCP server与多个client通信的方法

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 <= 0)
{
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 <= 0)
{
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 < 0)
{
perror("socket");
return -1;
}

/* 解除端口占用 */
if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval)) < 0)
{
perror("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)) < 0)
{
perror("bind");
close(server_fd);
return -1;
}

if(listen(server_fd, MAX_CONNECT_NUM) < 0)
{
perror("listen");
close(server_fd);
return -1;
}

return server_fd;
}

下面，我们使用INADDR_ANY来创建server。

INADDR_ANY：表示不确定地址，或所有地址、任意地址。也就是表示本机的所有IP，因为有些机子不止一块网卡，多网卡的情况下，这个就表示所有网卡ip地址的意思。