AI 助理
备案控制台
开发者社区 云计算 文章 正文

并发服务器三种实现方式之进程、线程和select

2018-09-19 1978
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 这篇主要介绍如何实现并发服务器，主要通过三种方式：进程、线程和select函数来分别实现。

前言：刚开始学网络编程，都会先写一个客户端和服务端，不知道你们有没有试一下：再打开一下客户端，是连不上服务端的。还有一个问题不知道你们发现没：有时启服务器，会提示“Address already in use”，过一会就好了，想过为啥么？在这篇博客会解释这个问题。

但现实的服务器都会连很多客户端的，像阿里服务器等，所以这篇主要介绍如何实现并发服务器，主要通过三种方式：进程、线程和select函数来分别实现。

　一、进程实现并发服务器
先说下什么是并发服务器吧？不是指有多个服务器同时运行，而是可以同时连接多个客户端。

先简单说下原理吧，先画个图，如下：
_1
先要搞清楚通信的流程，图上参数说明：

　　lfd：socket函数的返回值，就是监听描述符

　　cfd1/cfd2/cfd3:accept函数的返回值，用通信的套接字

　　server：服务器

　　client：客户端

　　socket通信过程中，总共有几个套接字呢？答：三个，客户端一个，服务器两个。

根据上图来大致说明一下流程：

客户端创建一个套接字描述符，用于通信，服务器先用socket函数创建套接字，用于监听客户端，然后调用accept函数，会返回一个套接字，用于通信的。图上就是，client1先通过cfd与server建立连接，然后与cfd1建立连接通信，这时lfd就空闲了，再监听客户端，client2再与lfd连接，再跟cfd2通信。client3也是如此。

现在问题就是。如何创建多个进程与客户端通信呢？通过循环创建子进程就可以实现这个问题

服务端程序，如下：

#include <stdio.h>
#include <string.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <signal.h>
#include <sys/wait.h>
#include <ctype.h>
#include <unistd.h>

#include "wrap.h"

#define MAXLINE 8192
#define SERV_PORT 8000

void do_sigchild(int num)
{
    while (waitpid(0, NULL, WNOHANG) > 0)
        ;
}

int main(void)
{
    struct sockaddr_in servaddr, cliaddr;
    socklen_t cliaddr_len;
    int listenfd, connfd;
    char buf[MAXLINE];
    char str[INET_ADDRSTRLEN];
    int i, n;
    pid_t pid;
    struct sigaction newact;

    newact.sa_handler = do_sigchild;
    sigemptyset(&newact.sa_mask);
    newact.sa_flags = 0;
    sigaction(SIGCHLD, &newact, NULL);    //建立信号，处理子进程退出

    listenfd = Socket(AF_INET, SOCK_STREAM, 0);

    // int opt = 1;
    //setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));    //端口复用

    bzero(&servaddr, sizeof(servaddr));
    servaddr.sin_family = AF_INET;
    servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
    servaddr.sin_port = htons(SERV_PORT);

    Bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr));

    Listen(listenfd, 20);

    printf("Accepting connections ...\n");
    while (1) {
        cliaddr_len = sizeof(cliaddr);
        connfd = Accept(listenfd, (struct sockaddr *)&cliaddr, &cliaddr_len);
        pid = fork();
        if (pid == 0) {
            Close(listenfd);
            while (1) {
                n = Read(connfd, buf, MAXLINE);
                if (n == 0) {
                    printf("the other side has been closed.\n");
                    break;
                }
                printf("received from %s at PORT %d\n",
                        inet_ntop(AF_INET, &cliaddr.sin_addr, str, sizeof(str)),ntohs(cliaddr.sin_port));
                for (i = 0; i < n; i++)
                    buf[i] = toupper(buf[i]);
                Write(STDOUT_FILENO, buf, n);
                Write(connfd, buf, n);
            }
            Close(connfd);
            return 0;
        } else if (pid > 0) {
            Close(connfd);
        }  else
            perr_exit("fork");
    }
    return 0;
}

客户端程序如下：

/* client.c */
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <netinet/in.h>
#include <arpa/inet.h>

#include "wrap.h"

#define MAXLINE 8192
#define SERV_PORT 8000

int main(int argc, char *argv[])
{
    struct sockaddr_in servaddr;
    char buf[MAXLINE];
    int sockfd, n;

    sockfd = Socket(AF_INET, SOCK_STREAM, 0);

    bzero(&servaddr, sizeof(servaddr));
    servaddr.sin_family = AF_INET;
    inet_pton(AF_INET, "127.0.0.1", &servaddr.sin_addr);
    servaddr.sin_port = htons(SERV_PORT);

    Connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr));

    while (fgets(buf, MAXLINE, stdin) != NULL) {
        Write(sockfd, buf, strlen(buf));
        n = Read(sockfd, buf, MAXLINE);
        if (n == 0) {
            printf("the other side has been closed.\n");
            break;
        }
        else
            Write(STDOUT_FILENO, buf, n);
    }

    Close(sockfd);

    return 0;
}

演示效果，服务器可以同时处理两个客户端，如下：
_2

但我想再测试一下程序，执行./server,发现有个bind error,如下：
_3

下面来解释一下这个问题：

先来一张图片（出自UNP），如下：
_4

这张图将三次握手、四次挥手和TCP状态转换图，这些在我的这篇博客都由介绍，可以参考一下：https://www.cnblogs.com/liudw-0215/p/9661583.html

注意最后有一个TIME_WAIT状态，主动关闭一端会经历2MSL时长等待（大约40秒），再变为最开始的状态CLOSED。

复现上面的“bind error”，只需退出服务器，在启服务器，就会报出此错。因为主动关闭一端，会经历2MSL时长，端口IP会被占用，所以会报“bind error”。

但可能会问：为啥先退出客户端没有此问题？因为客户端没有调用bind函数地址结构，会“隐式”生成端口。

有没有方法可以解决这个问题呢？当然有的，调用函数setsockopt即可，服务端程序如下：

#include <stdio.h>
#include <string.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <signal.h>
#include <sys/wait.h>
#include <ctype.h>
#include <unistd.h>

#include "wrap.h"

#define MAXLINE 8192
#define SERV_PORT 8000

void do_sigchild(int num)
{
    while (waitpid(0, NULL, WNOHANG) > 0)
        ;
}

int main(void)
{
    struct sockaddr_in servaddr, cliaddr;
    socklen_t cliaddr_len;
    int listenfd, connfd;
    char buf[MAXLINE];
    char str[INET_ADDRSTRLEN];
    int i, n;
    pid_t pid;
    struct sigaction newact;

    newact.sa_handler = do_sigchild;
    sigemptyset(&newact.sa_mask);
    newact.sa_flags = 0;
    sigaction(SIGCHLD, &newact, NULL);    //建立信号，处理子进程退出

    listenfd = Socket(AF_INET, SOCK_STREAM, 0);

    int opt = 1;
    setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));    //端口复用

    bzero(&servaddr, sizeof(servaddr));
    servaddr.sin_family = AF_INET;
    servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
    servaddr.sin_port = htons(SERV_PORT);

    Bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr));

    Listen(listenfd, 20);

    printf("Accepting connections ...\n");
    while (1) {
        cliaddr_len = sizeof(cliaddr);
        connfd = Accept(listenfd, (struct sockaddr *)&cliaddr, &cliaddr_len);
        pid = fork();
        if (pid == 0) {
            Close(listenfd);
            while (1) {
                n = Read(connfd, buf, MAXLINE);
                if (n == 0) {
                    printf("the other side has been closed.\n");
                    break;
                }
                printf("received from %s at PORT %d\n",
                        inet_ntop(AF_INET, &cliaddr.sin_addr, str, sizeof(str)),ntohs(cliaddr.sin_port));
                for (i = 0; i < n; i++)
                    buf[i] = toupper(buf[i]);
                Write(STDOUT_FILENO, buf, n);
                Write(connfd, buf, n);
            }
            Close(connfd);
            return 0;
        } else if (pid > 0) {
            Close(connfd);
        }  else
            perr_exit("fork");
    }
    return 0;
}

二、线程实现并发服务器

理解了进程的方式，就是创建多个线程来实现，就不过多解释了，程序需要对线程有一定了解，之后我还会写篇博客来介绍线程，敬请期待哦。

服务器代码如下，有有详细的解释：

#include <stdio.h>
#include <string.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <ctype.h>
#include <unistd.h>
#include <fcntl.h>

#include "wrap.h"

#define MAXLINE 8192
#define SERV_PORT 8000

struct s_info {                     //定义一个结构体, 将地址结构跟cfd捆绑
    struct sockaddr_in cliaddr;
    int connfd;
};

void *do_work(void *arg)
{
    int n,i;
    struct s_info *ts = (struct s_info*)arg;
    char buf[MAXLINE];
    char str[INET_ADDRSTRLEN];      //#define INET_ADDRSTRLEN 16  可用"[+d"查看

    while (1) {
        n = Read(ts->connfd, buf, MAXLINE);                     //读客户端
        if (n == 0) {
            printf("the client %d closed...\n", ts->connfd);
            break;                                              //跳出循环,关闭cfd
        }
        printf("received from %s at PORT %d\n",
                inet_ntop(AF_INET, &(*ts).cliaddr.sin_addr, str, sizeof(str)),
                ntohs((*ts).cliaddr.sin_port));                 //打印客户端信息(IP/PORT)

        for (i = 0; i < n; i++) 
            buf[i] = toupper(buf[i]);                           //小写-->大写

        Write(STDOUT_FILENO, buf, n);                           //写出至屏幕
        Write(ts->connfd, buf, n);                              //回写给客户端
    }
    Close(ts->connfd);

    return (void *)0;
}

int main(void)
{
    struct sockaddr_in servaddr, cliaddr;
    socklen_t cliaddr_len;
    int listenfd, connfd;
    pthread_t tid;
    struct s_info ts[256];      //根据最大线程数创建结构体数组.
    int i = 0;

    listenfd = Socket(AF_INET, SOCK_STREAM, 0);                     //创建一个socket, 得到lfd

    bzero(&servaddr, sizeof(servaddr));                             //地址结构清零
    servaddr.sin_family = AF_INET;
    servaddr.sin_addr.s_addr = htonl(INADDR_ANY);                   //指定本地任意IP
    servaddr.sin_port = htons(SERV_PORT);                           //指定端口号 8000

    Bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr)); //绑定

    Listen(listenfd, 128);      //设置同一时刻链接服务器上限数

    printf("Accepting client connect ...\n");

    while (1) {
        cliaddr_len = sizeof(cliaddr);
        connfd = Accept(listenfd, (struct sockaddr *)&cliaddr, &cliaddr_len);   //阻塞监听客户端链接请求
        ts[i].cliaddr = cliaddr;
        ts[i].connfd = connfd;

        /* 达到线程最大数时，pthread_create出错处理, 增加服务器稳定性 */
        pthread_create(&tid, NULL, do_work, (void*)&ts[i]);
        pthread_detach(tid);                                                    //子线程分离,防止僵线程产生.
        i++;
    }

    return 0;
}

客户端代码如下：

/* client.c */
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include "wrap.h"

#define MAXLINE 80
#define SERV_PORT 8000

int main(int argc, char *argv[])
{
    struct sockaddr_in servaddr;
    char buf[MAXLINE];
    int sockfd, n;

    sockfd = Socket(AF_INET, SOCK_STREAM, 0);

    bzero(&servaddr, sizeof(servaddr));
    servaddr.sin_family = AF_INET;
    inet_pton(AF_INET, "127.0.0.1", &servaddr.sin_addr.s_addr);
    servaddr.sin_port = htons(SERV_PORT);

    Connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr));

    while (fgets(buf, MAXLINE, stdin) != NULL) {
        Write(sockfd, buf, strlen(buf));
        n = Read(sockfd, buf, MAXLINE);
        if (n == 0)
            printf("the other side has been closed.\n");
        else
            Write(STDOUT_FILENO, buf, n);
    }

    Close(sockfd);

    return 0;
}

三、select实现并发服务器
select和进程主要区别在于，进程是阻塞的，而select是交给内核自己来实现的，由于select比较复杂，参考另一篇博客：

文章来源：https://www.cnblogs.com/liudw-0215/p/9664204.html
推荐阅读：https://www.roncoo.com/article/index?title=%E5%B9%B6%E5%8F%91

文章标签：
网络协议
关键词：
云服务器 ECS并发
线程并发
并发线程
服务器进程
云服务器 ECS进程
调皮仔3683
目录
相关文章
aliyun5518910231-27881
|
7月前
|
存储 Linux API
【Linux进程概念】—— 操作系统中的“生命体”，计算机里的“多线程”
在计算机系统的底层架构中，操作系统肩负着资源管理与任务调度的重任。当我们启动各类应用程序时，其背后复杂的运作机制便悄然展开。程序，作为静态的指令集合，如何在系统中实现动态执行？本文带你一探究竟！
aliyun5518910231-27881
272 6
【Linux进程概念】—— 操作系统中的“生命体”，计算机里的“多线程”
蓝易云
|
5月前
|
并行计算 Linux
Linux内核中的线程和进程实现详解
了解进程和线程如何工作，可以帮助我们更好地编写程序，充分利用多核CPU，实现并行计算，提高系统的响应速度和计算效能。记住，适当平衡进程和线程的使用，既要拥有独立空间的'兄弟'，也需要在'家庭'中分享和并行的成员。对于这个世界，现在，你应该有一个全新的认识。
蓝易云
243 67
游客qf4jmczx4xu2y
|
9月前
|
调度 开发者 Python
深入浅出操作系统：进程与线程的奥秘
在数字世界的底层，操作系统扮演着不可或缺的角色。它如同一位高效的管家，协调和控制着计算机硬件与软件资源。本文将拨开迷雾，深入探索操作系统中两个核心概念——进程与线程。我们将从它们的诞生谈起，逐步剖析它们的本质、区别以及如何影响我们日常使用的应用程序性能。通过简单的比喻，我们将理解这些看似抽象的概念，并学会如何在编程实践中高效利用进程与线程。准备好跟随我一起，揭开操作系统的神秘面纱，让我们的代码运行得更加流畅吧！
游客qf4jmczx4xu2y
158 3
游客kufrkwrbkmpsa
|
6月前
|
SQL 监控 网络协议
YashanDB进程线程体系
YashanDB进程线程体系
游客kufrkwrbkmpsa
112 2
游客kufrkwrbkmpsa
|
6月前
|
数据库
【YashanDB知识库】服务器重启后启动yasom和yasagent进程时有告警
【YashanDB知识库】服务器重启后启动yasom和yasagent进程时有告警
游客kufrkwrbkmpsa
119 2
游客kufrkwrbkmpsa
|
6月前
|
数据库
【YashanDB知识库】服务器重启后启动yasom和yasagent进程时有告警
本文介绍了YashanDB在特定场景下的问题分析与解决方法。当使用yasboot重启数据库后，yasom和yasagent进程虽启动成功但出现告警，原因是缺少libnsl.so.1库文件或环境变量配置错误。解决步骤包括：检查系统中是否存在该库文件，若不存在则根据操作系统类型安装（有外网时通过yum或apt，无外网时创建符号链接），若存在则调整环境变量配置，并重新启动相关进程验证问题是否解决。
游客kufrkwrbkmpsa
130 2
技术小达人
|
8月前
|
消息中间件 调度
如何区分进程、线程和协程？看这篇就够了！
本课程主要探讨操作系统中的进程、线程和协程的区别。进程是资源分配的基本单位，具有独立性和隔离性；线程是CPU调度的基本单位，轻量且共享资源，适合并发执行；协程更轻量，由程序自身调度，适合I/O密集型任务。通过学习这些概念，可以更好地理解和应用它们，以实现最优的性能和资源利用。
技术小达人
249 11
站大爷
|
7月前
|
数据采集 Java 数据处理
Python实用技巧：轻松驾驭多线程与多进程，加速任务执行
在Python编程中，多线程和多进程是提升程序效率的关键工具。多线程适用于I/O密集型任务，如文件读写、网络请求；多进程则适合CPU密集型任务，如科学计算、图像处理。本文详细介绍这两种并发编程方式的基本用法及应用场景，并通过实例代码展示如何使用threading、multiprocessing模块及线程池、进程池来优化程序性能。结合实际案例，帮助读者掌握并发编程技巧，提高程序执行速度和资源利用率。
站大爷
342 0
软件求生
|
8月前
|
Java Linux 调度
硬核揭秘：线程与进程的底层原理，面试高分必备！
嘿，大家好！我是小米，29岁的技术爱好者。今天来聊聊线程和进程的区别。进程是操作系统中运行的程序实例，有独立内存空间；线程是进程内的最小执行单元，共享内存。创建进程开销大但更安全，线程轻量高效但易引发数据竞争。面试时可强调：进程是资源分配单位，线程是CPU调度单位。根据不同场景选择合适的并发模型，如高并发用线程池。希望这篇文章能帮你更好地理解并回答面试中的相关问题，祝你早日拿下心仪的offer！
软件求生
176 6
LuckiBit
|
9月前
|
消息中间件 Unix Linux
【C语言】进程和线程详解
在现代操作系统中，进程和线程是实现并发执行的两种主要方式。理解它们的区别和各自的应用场景对于编写高效的并发程序至关重要。
LuckiBit
310 6

热门文章

最新文章

  • 1
    阿里云服务器租用费用：包年包月、按量付费收费标准与活动价格参考
  • 2
    阿里云服务器ECS安装宝塔Linux面板、安装网站（新手图文教程）
  • 3
    2025最新阿里云优惠活动整理：个人、企业和学生用户，云服务器免费及活动清单
  • 4
    阿里云38元的轻量应用服务器2核2G200M带宽是什么意思？是不是独享的？
  • 5
    2025阿里云GPU服务器租赁价格：1个月、1小时和一年收费标准
  • 6
    2025阿里云服务器收费价格表：一年和1个月租赁费用清单
  • 7
    服务器核心组件：CPU 与 GPU 的核心区别、应用场景、协同工作
  • 8
    阿里云目前最便宜云服务器介绍：38元、99元、199元性能，选购攻略参考
  • 9
    如何在 ECS/EKS 集群中有效使用 Jenkins
  • 10
    阿里云服务器全解析：ECS是什么、应用场景、租用流程及优缺点分析
  • 1
    NodeJs——如何获取Windows电脑指定应用进程信息
    252
  • 2
    nodejs process进程
    131
  • 3
    MySQL——大量的deleted进程导致磁盘100%
    86
  • 4
    解锁Python多进程编程的超能力：并行计算的魔法与奇迹，探索处理器核心的秘密，让程序性能飞跃！
    108
  • 5
    python Process 多进程编程
    130
  • 6
    【在Linux世界中追寻伟大的One Piece】Linux进程概念
    163
  • 7
    探索操作系统的心脏：内核与进程管理
    112
  • 8
    Electron 开发过程中主进程的无法看到 console.log 输出怎么办
    966
  • 9
    Android 多进程情况下判断应用是否处于前台或者后台
    767
  • 10
    [go 面试] 深入理解进程、线程和协程的概念及区别
    284

    • 相关课程

    更多
  • ECS上云入门三部曲
  • 服务器硬件基础
  • Linux Web服务器Nginx搭建与配置
  • 7天玩转云服务器
  • 云服务器选型、迁云最佳实践
  • 云服务器ECS基本操作

    • 相关电子书

    更多
  • 如何运维千台以上游戏云服务器
  • 网站/服务器取证 实践与挑战
  • 多IO线程优化版

    • 相关实验场景

    更多
  • 基于ECS和NAS搭建个人网盘
  • 使用PolarDB和ECS搭建门户网站
  • 基于ECS搭建云上博客
  • 使用ECS和OSS搭建个人网盘
  • 基于ECS搭建FTP服务
    • 下一篇
    2025云栖大会，阿里云百炼邀请您的参与和见证