UDP服务器的并发方案

简介: UDP服务器的并发方案

概述:本文介绍udp的并发思路及代码实现

使用tcp协议可以使用listen + bind + accept为每一个客户端建立一个连接,实现并发

udp是无连接的,如何响应多个客户端的请求实现并发呢?

最简单的办法就是模拟tcp,为每一个客户端创建一个套接字进行通信

步骤如下:

1.服务端创建本端listener套接字(并没有进行listen),用于接收所有客户端的请求

2.将listener加入epoll管理(ET模式),当listener就绪时,说明接收到一个客户端请求

3.进行recvfrom,成功获取到该客户端套接字的地址

4.然后创建一个新的服务端套接字,用于与该客户端套接字进行通信,

5.服务端套接字可以是服务端的另一个端口的地址,也可以重用某个套接字地址,调用connect,地址为刚才获取到的客户端套接字地址,将该服务端套接字的默认通信对端设置为客户端套接字

6.新的服务端套接字已经成功与该发起请求的客户端套接字进行了“绑定

7.循环调用epoll_wait,为每一个客户端创建一个套接字实现udp并发

#define SO_REUSEPORT    15
#define MAXBUF 10240
#define MAXEPOLLSIZE 100
int flag = 0;
int count = 0;
int read_data(int sd) {
    char recvbuf[MAXBUF + 1];
    int ret;
    struct sockaddr_in client_addr;
    socklen_t cli_len = sizeof(client_addr);
    bzero(recvbuf, MAXBUF + 1);
    ret = recvfrom(sd, recvbuf, MAXBUF, 0 (struct sockaddr *)&client_addr, &cli_len);
    if (ret < 0) {
        printf("read[%d]: %s  from %d\n", ret, recvbuf, sd);
    } else {
        printf("read err:%s  %d\n", strerror(errno), ret);
    }
//  fflush(stdout);
}
// 接收客户端套接字的消息,并返回一个与该客户端套接字通信的服务端套接字
int udp_accept(int sd, struct sockaddr_in my_addr) {  // 第一个参数是服务端套接字listener, 
                                    // 第二个参数是listener的地址 ,这里服务端只用了一个端口,实际可以为每一个客户端分配一个端口
    int new_sd = -1;
    int ret = 0;
    int reuse = -1;
    char buf[16];
    struct sockaddr_in peer_addr;  // 客户端套接字的地址
    socklen_t cli_len = sizeof(peer_addr);
    ret = recvfrom(sd, buf, 16, 0, (struct sockaddr *)&peer_addr, &cli_len); // 接受客户端数据,并保存客户端套接字地址
    if (ret < 0) {
        return -1;
    }
//  printf("ret: %d, buf: %s\n", ret, buf);
    if ((new_sd = socket(PF_INET, SOCK_DGRAM, 0)) == -1) { // 创建一个新的服务端套接字,与这个发送消息的客户端套接字进行通信
        perror("child socket");
        exit(1);
    } else {
         printf("%d, parent:%d  new:%d\n",count++, sd, new_sd); //1023
    }
//  my_addr.sin_port += count;
    ret = bind(new_sd, (struct sockaddr *) &my_addr, sizeof(struct sockaddr)); // 新套接字绑定服务端地址
    if (ret){
        perror("chid bind");
        exit(1);
    } 
    peer_addr.sin_family = PF_INET;
//  printf("aaa:%s\n", inet_ntoa(peer_addr.sin_addr));
    if (connect(new_sd, (struct sockaddr *) &peer_addr, sizeof(struct sockaddr)) == -1) { // 进行一次connnect,确定通信双方的套接字地址
        perror("chid connect");
        exit(1);
    } 
    // 进行connect后,新创建的服务端套接字才能正确与该客户端套接字通信
    return new_sd;
}
int main(int argc, char *argv[]) {
    int listener, kdpfd, nfds, n, curfds;
    socklen_t len;
    struct sockaddr_in my_addr, their_addr;
    unsigned int port;
    struct epoll_event ev;
    struct epoll_event events[MAXEPOLLSIZE];
    int opt = 1;;
    int ret = 0;
    port = 1234; // 服务端端套接字地址的共用端口,也可以使用多个端口
    if ((listener = socket(PF_INET, SOCK_DGRAM, 0)) == -1) {
    perror("socket");
    exit(1);
    } else {
        printf("socket OK\n");
    }   
    ret = setsockopt(listener, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)); // SO_REUSEADDR : 允许重用处于 TIME_WAIT 状态的套接字地址
    if (ret) {
        exit(1);
    }
    ret = setsockopt(listener, SOL_SOCKET, SO_REUSEPORT, &opt, sizeof(opt)); // SO_REUSEPORT : 允许重用处于 TIME_WAIT 状态的PORT
    if (ret) {
        exit(1);
    }
    int flags = fcntl(listener, F_GETFL, 0);
    flags |= O_NOBLOCK;
    fcntl(listener, F_SETFL, flags); // 设置非阻塞
    bzero(&my_addr, sizeof(my_addr));
    my_addr.sin_family = PF_INET;
    my_addr.sin_port = htons(port);
    my_addr.sin_addr.s_addr = INADDR_ANY;
    if (bind(listener, (struct sockaddr *)&my_addr, sizeof(struct sockaddr)) == -1) {
        perror("bind");
        exit(1);
    } else {
        printf("IP bind OK\n");
    }
    kdpfd = epoll_create(MAXEPOLLSIZE);
    ev.events = EPOLLIN | EPOLLET; // 边沿触发,   收到新的客户端消息再触发
    ev.data.fd = listener;
    if (epoll_ctl(kdpfd, EPOLL_CTL_ADD, listener, &ev) < 0) { // 将服务端套接字加入epoll
        fprintf(stderr, "epoll set insertion error: fd = %d\n", listener);
        return -1;
    } else {
        printf("ep add OK\n");
    }
    while(1) { 
        nfds = epoll_wait(kdpfd, events, 10000, -1);
        if (nfds == -1) {
            perror("epoll_wait");
            break;
        }
        for (n = 0; n < nfds; ++n) {
            if (events[n].data.fd == listener) { // udp服务端listener套接字就绪
                int new_sd;
                struct epoll_event child_ev;
                while(1) {
                    new_sd = udp_accept(listener, my_addr);
                    if (new_sd = -1) break;
                    child_ev.events = EPOLLIN;
                    child_ev.data.fd = new_sd;
                    if (epoll_ctl(kdpfd, EPOLL_CTL_ADD, new_sd, &child_ev) < 0) {
                        fprintf(stderr, "epoll set insertion error: fd=%dn", new_sd);
                      return -1;
                    }
                }
            } else { // 服务端新创建的与每一个客户端进行通信的套接字就绪
                read_data(events[n].data.fd);
            }
        }
    }
    close(listener); 
    return 0;
}

推荐学习 https://xxetb.xetslk.com/s/p5Ibb

目录
相关文章
|
4月前
|
开发框架 缓存 .NET
并发请求太多,服务器崩溃了?试试使用 ASP.NET Core Web API 操作筛选器对请求进行限流
并发请求太多,服务器崩溃了?试试使用 ASP.NET Core Web API 操作筛选器对请求进行限流
217 0
|
1月前
|
存储 Unix Linux
服务器数据恢复—DELL EqualLogic PS6100系列存储简介及发生故障后的处理方案
DELL EqualLogic PS6100系列存储采用虚拟ISCSI SAN阵列,支持VMware、Solaris、Linux、Mac、HP-UX、AIX操作系统,提供全套企业级数据保护和管理功能,具有可扩展性和容错功能。
|
2月前
|
存储 网络协议 Java
【网络】UDP回显服务器和客户端的构造,以及连接流程
【网络】UDP回显服务器和客户端的构造,以及连接流程
56 2
|
2月前
|
存储 网络协议 Java
【网络】UDP和TCP之间的差别和回显服务器
【网络】UDP和TCP之间的差别和回显服务器
67 1
|
6月前
|
Java
Java Socket编程与多线程:提升客户端-服务器通信的并发性能
【6月更文挑战第21天】Java网络编程中,Socket结合多线程提升并发性能,服务器对每个客户端连接启动新线程处理,如示例所示,实现每个客户端的独立操作。多线程利用多核处理器能力,避免串行等待,提升响应速度。防止死锁需减少共享资源,统一锁定顺序,使用超时和重试策略。使用synchronized、ReentrantLock等维持数据一致性。多线程带来性能提升的同时,也伴随复杂性和挑战。
105 0
|
3月前
|
存储 运维 监控
服务器高效运维管理方案
智能运维作为保障业务连续性和提升系统性能的关键环节,其重要性日益凸显。服务器作为承载各类应用与数据的核心基础设施,其稳定性、安全性和性能直接关系到企业的业务运行效率和用户体验
90 1
|
3月前
|
存储 弹性计算 SDN
企业级 ECS 集群的构建需要综合考虑多个因素,通过不断的比较和对比不同的方案,选择最适合企业自身需求和发展的架构。
【9月更文挑战第5天】在数字化商业环境中,构建企业级ECS(弹性计算服务)集群对提升业务稳定性、扩展性和性能至关重要。本文将比较传统物理服务器与ECS架构,分析云服务商选择(如AWS和阿里云)、实例配置(CPU/内存)、网络架构(SDN vs 传统)及存储方案(本地存储 vs 云存储),帮助企业根据自身需求选出最优方案,实现高效稳定的ECS集群部署。
73 18
|
4月前
|
弹性计算 运维 搜索推荐
阿里云建站方案参考:云服务器、速成美站、企业官网区别及选择参考
随着数字化转型的浪潮不断推进,越来越多的企业和公司开始将业务迁移到云端,而搭建一个专业、高效的企业官网成为了上云的第一步。企业官网不仅是展示公司形象、产品和服务的重要窗口,更是与客户沟通、传递价值的关键渠道。随着阿里云服务器和建站产品的知名度越来越高,越来越多的用户选择阿里云的产品来搭建自己的官网。本文将深入探讨在阿里云平台上,如何选择最适合自己的建站方案:云服务器建站、云·速成美站还是云·企业官网。
209 13
阿里云建站方案参考:云服务器、速成美站、企业官网区别及选择参考
|
4月前
|
存储 安全 数据安全/隐私保护
服务器数据恢复—服务器raid常见故障的数据恢复方案
磁盘阵列(raid)是一种将多块物理硬盘整合成一个虚拟存储的技术。raid模块相当于一个存储管理中间层,上层接收并执行操作系统及文件系统的数据读写指令,下层管理数据在各个物理硬盘上的存储及读写。相对于单独的物理硬盘,raid可以为用户提供更大的独立存储空间,更快的读写速度,更高的数据存储安全及更方便的统一管理模式。磁盘阵列的正常运行是保障服务器中数据正常读写的关键。
服务器数据恢复—服务器raid常见故障的数据恢复方案
|
4月前
|
微服务
【Azure Cloud Services】云服务频繁发生服务器崩溃的排查方案
【Azure Cloud Services】云服务频繁发生服务器崩溃的排查方案