在构建网络应用时，常常会接触到各种网络协议，其中TCP（Transmission Control Protocol）作为一种面向连接、可靠的传输层协议，扮演着至关重要的角色。理解TCP协议及其在服务器开发中的应用，是每一位网络编程初学者的必经之路。

本系列文章旨在带领大家逐步深入TCP服务器的开发世界，从最基础的一对一连接通信开始，逐步探索更复杂、更高效的服务器模型。从零开始，手把手地编写第一个TCP服务器程序，亲身体验“开局一块砖，大厦全靠垒”的成就感。

在本文中，聚焦于TCP服务器的编写第一个TCP服务器程序，亲身体验“开局一块砖，大厦全靠垒”的成就感。

在本文中，聚焦于TCP服务器的起点——实现最简单的一对一连接通信。通过这个入门级的示例：

这将是探索TCP服务器演变之路的第一步。通过这个简单的例子，建立对TCP服务器工作原理的初步认知，为后续学习更高级的服务器模型（如多进程、多线程、IO多路复用等）打下坚实的基础。

本章在上一章节的基础上，添加多线程，为每个新接入的客户端分配线程，实现一个服务器程序处理多个客户端连接。

#include <pthread.h>
int pthread_create(
                 pthread_t *restrict tidp,   			//新创建的线程ID指向的内存单元。
                 const pthread_attr_t *restrict attr,		//线程属性
                 void *(*start_rtn)(void *), 			//线程函数的地址
                 void *restrict arg 				//线程函数所需的参数
                  );

终止调用线程，并通过retval返回一个值，该值（如果线程是可连接的）可用于调用

建立的任何尚未弹出的清理处理程序都会弹出（按与推送顺序相反的顺序）并执行。如果线程有任何特定于线程的数据，那么在执行清理处理程序之后，将以未指定的顺序调用相应的析构函数。

当线程终止时，进程共享资源（例如，互斥锁、条件变量、信号量和文件描述符）不会被释放，并且使用atexit()注册的函数也不会被调用。

在进程中的最后一个线程终止后，进程终止为调用

，出口状态为零；因此，进程共享资源被释放，并且使用

#include <pthread.h>

void pthread_exit(void *retval);

使用多线程方案，来一个连接请求则创建一个线程。

int listenfd=socket(AF_INET,SOCK_STREAM,0);
if(listenfd==-1){
    printf("errno = %d, %s\n",errno,strerror(errno));
    return SOCKET_CREATE_FAILED;
}

struct sockaddr_in server;
memset(&server,0,sizeof(server));

server.sin_family=AF_INET;
server.sin_addr.s_addr=htonl(INADDR_ANY);
server.sin_port=htons(LISTEN_PORT);

if(-1==bind(listenfd,(struct sockaddr*)&server,sizeof(server))){
    printf("errno = %d, %s\n",errno,strerror(errno));
    close(listenfd);
    return SOCKET_BIND_FAILED;
}

if(-1==listen(listenfd,BLOCK_SIZE)){
   printf("errno = %d, %s\n",errno,strerror(errno));
   close(listenfd);
   return SOCKET_LISTEN_FAILED;
}

struct sockaddr_in client;
memset(&client,0,sizeof(client));
socklen_t len=sizeof(client);
    
int clientfd=accept(listenfd,(struct sockaddr*)&client,&len);
if(clientfd==-1){
    printf("errno = %d, %s\n",errno,strerror(errno));
    close(listenfd);
    return SOCKET_ACCEPT_FAILED;
}

pthread_t thread;
if(0!=pthread_create(&thread,NULL,routine,&clientfd))
{
     printf("pthread_create failed");

}

（6）在线程函数里面接收数据。

char buf[BUFFER_LENGTH]={0};
ret=recv(clientfd,buf,BUFFER_LENGTH,0);
if(ret==0) {
     printf("connection dropped\n");

}
printf("recv --> %s\n",buf);

（7）在线程函数里面发送数据。

if(-1==send(clientfd,buf,ret,0))
{
    printf("errno = %d, %s\n",errno,strerror(errno));
}

#include <stdio.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>

#include <errno.h>
#include <string.h>
#include <unistd.h>

#include <pthread.h>

#define LISTEN_PORT     8888
#define BLOCK_SIZE      10
#define BUFFER_LENGTH   1024

enum ERROR_CODE{
    SOCKET_CREATE_FAILED=-1,
    SOCKET_BIND_FAILED=-2,
    SOCKET_LISTEN_FAILED=-3,
    SOCKET_ACCEPT_FAILED=-4
};

void *routine(void *arg)
{
    int clientfd=*((int*)arg);
    while(1)
    {
        // 5.
        char buf[BUFFER_LENGTH]={0};
        int ret=recv(clientfd,buf,BUFFER_LENGTH,0);
        if(ret==0) {
            printf("connection dropped\n");
            break;
        }
        
        printf("fd=%d recv --> %s\n",clientfd,buf);
        send(clientfd,buf,ret,0);
        
    }
    

    close(clientfd);
}

int main(int argc,char **argv)
{
    // 1.
    int listenfd=socket(AF_INET,SOCK_STREAM,0);
    if(listenfd==-1){
        printf("errno = %d, %s\n",errno,strerror(errno));
        return SOCKET_CREATE_FAILED;
    }

    // 2.
    struct sockaddr_in server;
    memset(&server,0,sizeof(server));

    server.sin_family=AF_INET;
    server.sin_addr.s_addr=htonl(INADDR_ANY);
    server.sin_port=htons(LISTEN_PORT);

    if(-1==bind(listenfd,(struct sockaddr*)&server,sizeof(server))){
        printf("errno = %d, %s\n",errno,strerror(errno));
        close(listenfd);
        return SOCKET_BIND_FAILED;
    }

    // 3.
    if(-1==listen(listenfd,BLOCK_SIZE)){
        printf("errno = %d, %s\n",errno,strerror(errno));
        close(listenfd);
        return SOCKET_LISTEN_FAILED;
    }

    printf("listen port: %d\n",LISTEN_PORT);
    struct sockaddr_in client;
    socklen_t len=sizeof(client);
    int clientfd=-1;
    
    while(1)
    {
        // 4.
        memset(&client,0,sizeof(client));
        clientfd=accept(listenfd,(struct sockaddr*)&client,&len);
        if(clientfd==-1){
            printf("errno = %d, %s\n",errno,strerror(errno));
            continue;
        }

        printf("accept successdul, fd = %d\n",clientfd);
        pthread_t thread;
        if(0!=pthread_create(&thread,NULL,routine,&clientfd))
        {
            printf("pthread_create failed");
            break;
        }
    }

    
    close(listenfd);

    return 0;
}

注意，由于使用了多线程，在编译时要加上 -lpthread 连接多线程库。

（1）自己实现一个TCP客户端。自己实现一个TCP客户端连接TCP服务器的代码，主要是连接服务器，发送数据、接收数据功能：

#include <stdio.h>
#include <sys/socket.h>

#include <netinet/in.h>
#include <arpa/inet.h>

#include <errno.h>
#include <string.h>

#include <unistd.h>
#include <stdlib.h>

#define BUFFER_LENGTH   1024

enum ERROR_CODE{
    SOCKET_CREATE_FAILED=-1,
    SOCKET_CONN_FAILED=-2,
    SOCKET_LISTEN_FAILED=-3,
    SOCKET_ACCEPT_FAILED=-4
};

int main(int argc,char** argv)
{
    if(argc<3)
    {
        printf("Please enter the server IP and port.");
        return 0;
    }
    printf("connect to %s, port=%s\n",argv[1],argv[2]);

    int connfd=socket(AF_INET,SOCK_STREAM,0);
    if(connfd==-1)
    {
        printf("errno = %d, %s\n",errno,strerror(errno));
        return SOCKET_CREATE_FAILED;

    }
    struct sockaddr_in serv;
    serv.sin_family=AF_INET;
    serv.sin_addr.s_addr=inet_addr(argv[1]);
    serv.sin_port=htons(atoi(argv[2]));
    socklen_t len=sizeof(serv);
    int rwfd=connect(connfd,(struct sockaddr*)&serv,len);
    if(rwfd==-1)
    {
        printf("errno = %d, %s\n",errno,strerror(errno));
        close(rwfd);
        return SOCKET_CONN_FAILED;
    }
    int ret=1;
    while(ret>0)
    {
        char buf[BUFFER_LENGTH]={0};
        printf("Please enter the string to send:\n");
        scanf("%s",buf);
        send(connfd,buf,strlen(buf),0);

        memset(buf,0,BUFFER_LENGTH);
        printf("recv:\n");
        ret=recv(connfd,buf,BUFFER_LENGTH,0);
        printf("%s\n",buf);
        
    }
    close(rwfd);
    return 0;
}

（2）Windows下可以使用NetAssist的网络助手工具

下载地址：http://old.tpyboard.com/downloads/NetAssist.exe

这里基于上一个章节的内容进行了升级，由原来的一对一连接通信升级为一对多连接通信，可以接受多个客户端同时连接，并为每个连接分配一个线程。

但是，使用多线程会有一个瓶颈，受CPU的核心数和内存大小线程，一台机器可以并发的线程数量是有限的，内存大小也是有限的；这个模式下1024个线程基本就是一台服务器机器的极限。

除了可以使用多线程实现一对多发服务外，还可以使用多进程来实现这个功能。这个我们将在下一个章节进行实现。

TCP服务器的演变过程：揭秘使用多线程实现一对多的TCP服务器

本系列文章旨在带领大家逐步深入TCP服务器的开发世界，从多线程探索更复杂、更高效的服务器模型。从零开始，手把手地编写第一个TCP服务器程序，亲身体验“开局一块砖，大厦全靠垒”的成就感。

编程语言

本文介绍TCP服务器开发，从一对一连接通信入手，讲解TCP协议基础及关键API。通过实例展示如何编写TCP服务器程序，实现接收与发送数据。进一步采用多线程方案，使服务器能处理多个客户端连接，提升并发能力，为深入学习更高级服务器模型打基础。

TCP服务器的演变过程：揭秘使用多线程实现一对多的TCP服务器

TCP服务器的演变过程：揭秘使用多线程实现一对多的TCP服务器

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐