Libevent UDP开发指南

UDP 与 TCP 的核心区别

  1. 无连接:不需要建立/维护连接

  2. 不可靠:不保证数据包顺序和到达

  3. 高效:头部开销小,没有连接管理负担

  4. 支持广播/多播:可以向多个目标同时发送数据

一、基础UDP服务器实现

1. 创建 UDP 套接字

#include <event2/event.h>
#include <event2/listener.h>
#include <event2/bufferevent.h>
#include <arpa/inet.h>int create_udp_socket(int port) {int fd = socket(AF_INET, SOCK_DGRAM, 0);if (fd < 0) {perror("socket");return -1;}struct sockaddr_in sin;memset(&sin, 0, sizeof(sin));sin.sin_family = AF_INET;sin.sin_port = htons(port);sin.sin_addr.s_addr = htonl(INADDR_ANY);if (bind(fd, (struct sockaddr*)&sin, sizeof(sin)) < 0) {perror("bind");close(fd);return -1;}// 设置非阻塞evutil_make_socket_nonblocking(fd);return fd;
}

2. UDP 事件处理

void udp_read_cb(evutil_socket_t fd, short events, void *arg) {struct sockaddr_in client_addr;socklen_t addr_len = sizeof(client_addr);char buf[1500]; // 标准MTU大小ssize_t n;while ((n = recvfrom(fd, buf, sizeof(buf), 0,(struct sockaddr*)&client_addr, &addr_len)) > 0) {// 处理接收到的数据printf("Received %zd bytes from %s:%d\n", n, inet_ntoa(client_addr.sin_addr),ntohs(client_addr.sin_port));// 简单回显sendto(fd, buf, n, 0, (struct sockaddr*)&client_addr, addr_len);}if (n < 0 && errno != EAGAIN && errno != EWOULDBLOCK) {perror("recvfrom");}
}int main() {int udp_fd = create_udp_socket(8080);if (udp_fd < 0) return 1;struct event_base *base = event_base_new();struct event *udp_event = event_new(base, udp_fd, EV_READ | EV_PERSIST, udp_read_cb, NULL);event_add(udp_event, NULL);printf("UDP server started on port 8080\n");event_base_dispatch(base);event_free(udp_event);close(udp_fd);event_base_free(base);return 0;
}

3. UDP 服务器示例代码

#include <event2/event.h>
#include <event2/bufferevent.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <string.h>
#include <time.h>#define MAX_CLIENTS 10000
#define MAX_PACKET_SIZE 1500struct udp_client {struct sockaddr_in addr;time_t last_active;
};struct udp_server {struct event_base *base;int sockfd;struct event *ev;struct udp_client clients[MAX_CLIENTS];
};void udp_read_cb(evutil_socket_t fd, short events, void *arg) {struct udp_server *server = arg;char buf[MAX_PACKET_SIZE];struct sockaddr_in client_addr;socklen_t addr_len = sizeof(client_addr);ssize_t n = recvfrom(fd, buf, sizeof(buf), 0,(struct sockaddr*)&client_addr, &addr_len);if (n <= 0) return;// 查找或创建客户端记录struct udp_client *client = NULL;for (int i = 0; i < MAX_CLIENTS; i++) {if (memcmp(&server->clients[i].addr, &client_addr, addr_len) == 0) {client = &server->clients[i];break;}}if (!client) {// 查找空闲槽位for (int i = 0; i < MAX_CLIENTS; i++) {if (server->clients[i].last_active == 0) {client = &server->clients[i];memcpy(&client->addr, &client_addr, addr_len);break;}}}if (client) {client->last_active = time(NULL);// 业务处理printf("Received %zd bytes from %s:%d\n", n, inet_ntoa(client_addr.sin_addr),ntohs(client_addr.sin_port));// 回显sendto(fd, buf, n, 0, (struct sockaddr*)&client_addr, addr_len);} else {printf("Client limit reached, dropping packet\n");}
}struct udp_server* udp_server_create(int port) {struct udp_server *server = malloc(sizeof(struct udp_server));memset(server, 0, sizeof(*server));// 创建socketserver->sockfd = socket(AF_INET, SOCK_DGRAM, 0);if (server->sockfd < 0) {perror("socket");free(server);return NULL;}// 绑定地址struct sockaddr_in sin;memset(&sin, 0, sizeof(sin));sin.sin_family = AF_INET;sin.sin_port = htons(port);sin.sin_addr.s_addr = htonl(INADDR_ANY);if (bind(server->sockfd, (struct sockaddr*)&sin, sizeof(sin)) < 0) {perror("bind");close(server->sockfd);free(server);return NULL;}// 设置非阻塞evutil_make_socket_nonblocking(server->sockfd);// 创建事件基server->base = event_base_new();if (!server->base) {close(server->sockfd);free(server);return NULL;}// 创建事件server->ev = event_new(server->base, server->sockfd, EV_READ | EV_PERSIST, udp_read_cb, server);event_add(server->ev, NULL);return server;
}void udp_server_run(struct udp_server *server) {event_base_dispatch(server->base);
}void udp_server_free(struct udp_server *server) {if (!server) return;if (server->ev) event_free(server->ev);if (server->base) event_base_free(server->base);if (server->sockfd > 0) close(server->sockfd);free(server);
}int main() {struct udp_server *server = udp_server_create(8080);if (!server) return 1;printf("UDP server started on port 8080\n");udp_server_run(server);udp_server_free(server);return 0;
}

4. UDP 客户器示例代码 

#include <event2/event.h>
#include <event2/dns.h>
#include <event2/bufferevent.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <string.h>
#include <pthread.h>
#include <unistd.h>struct udp_client {struct event_base *base;struct evdns_base *dns;int sockfd;struct sockaddr_in server_addr;int connected;pthread_mutex_t lock;
};void udp_read_cb(evutil_socket_t fd, short events, void *arg) {struct udp_client *client = arg;char buf[1500];struct sockaddr_in from_addr;socklen_t addr_len = sizeof(from_addr);ssize_t n = recvfrom(fd, buf, sizeof(buf), 0,(struct sockaddr*)&from_addr, &addr_len);if (n > 0) {buf[n] = '\0';pthread_mutex_lock(&clie

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/diannao/76797.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

基于阿里云可观测产品构建企业级告警体系的通用路径与最佳实践

前言 1.1 日常生活中的告警 任何连续稳定运行的生产系统都离不开有效的监控与报警机制。通过监控&#xff0c;我们可以实时掌握系统和业务的运行状态&#xff1b;而报警则帮助我们及时发现并响应监控指标及业务中的异常情况。 在日常生活中&#xff0c;我们也经常遇到各种各样…

智能多媒体处理流水线——基于虎跃办公API的自动化解决方案

在内容爆炸的时代&#xff0c;多媒体文件处理&#xff08;图片压缩、视频转码、音频降噪&#xff09;已成为内容生产者的日常挑战。本文将演示如何基于虎跃办公的多媒体处理API&#xff0c;构建自动化处理流水线&#xff0c;实现&#xff1a; 批量文件智能分类格式自动转换质量…

01-STM32(介绍、工具准备、新建工程)p1-4

文章目录 工具准备和介绍硬件设备stm32简介和arm简介stm32简介STM32命名规则STM32选型STM32F103C8T6最小系统板引脚定义STM32启动配置STM32最小系统电路ARM简介 软件安装注册器件支持包安装ST-LINK驱动安装USB转串口驱动 新建工程创建stm32工程STM32工程编译和下载型号分类及缩…

【ABAP】REST/HTTP技术(一)

1、概念 1.1、SAP 如何提供 Http Service 如果要将 SAP 应用程序服务器 &#xff08;application server&#xff09;作为 http 服务提供者&#xff0c;需要定义一个类&#xff0c;这个类必须实现 IF_HTTP_EXTENSION 接口。IF_HTTP_EXTENSION 接口只有一个方法 HANDLE_REQUEST。…

[实战] linux驱动框架与驱动开发实战

linux驱动框架与驱动开发实战 Linux驱动框架与驱动开发实战一、Linux驱动框架概述1.1 Linux驱动的分类1.2 Linux驱动的基本框架 二、Linux驱动关键API详解2.1 模块相关API2.2 字符设备驱动API2.3 内存管理API2.4 中断处理API2.5 PCI设备驱动API 三、Xilinx XDMA驱动开发详解3.1…

1. hadoop 集群的常用命令

1.上传文件 1)hadoop fs -put words.txt /path/to/input/ 2)hdfs dfs -put words.txt /path/wc/input/ 2.获取hdfs中的文件 hadoop fs -get /path/wc/input/words.txt 3.合并下载多个文件 hadoop fs -getmerge /path/wc/input/words.txt /path/wc/input/words2.txt 4.查…

Keepalived+LVS+nginx高可用架构

注明&#xff1a;所有软件已经下载好&#xff0c;防火墙和SELinux已经全部关闭 一.搭建NFS 1.服务端 1.创建文件 [rootnfs ~]# mkdir -p /nfs/data 2、修改权限 [rootnfs ~]# chmod orw /nfs/data 3、写配置文件 [rootnfs ~]# cat /etc/exports /nfs/data 192.168.111.118(r…

深度学习处理文本(13)

我们使用基于GRU的编码器和解码器来在Keras中实现这一方法。选择GRU而不是LSTM&#xff0c;会让事情变得简单一些&#xff0c;因为GRU只有一个状态向量&#xff0c;而LSTM有多个状态向量。首先是编码器&#xff0c;如代码清单11-28所示。 代码清单11-28 基于GRU的编码器 fro…

HashMap 底层原理详解

1. 核心数据结构 JDK 1.7 及之前&#xff1a;数组 链表 JDK 1.8 及之后&#xff1a;数组 链表/红黑树&#xff08;链表长度 ≥8 时转红黑树&#xff0c;≤6 时退化为链表&#xff09; // JDK 1.8 的 Node 定义&#xff08;链表节点&#xff09; static class Node<K,V&g…

使用MySQL时出现 Ignoring query to other database 错误

Ignoring query to other database 错误 当在远程连接软件中输入MySQL命令出现该错误 导致错误原因是&#xff1a;登录mysql时账户名没有加上u 如果出现该错误&#xff0c;退出mysql&#xff0c;重新输入正确格式进入即可&#xff01;

哈尔滨工业大学:大模型时代的具身智能

大家好&#xff0c;我是樱木。 机器人在工业领域&#xff0c;已经逐渐成熟。具身容易&#xff0c;智能难。 机器人-》智能机器人&#xff0c;需要自主能力&#xff0c;加上通用能力。 智能机器人-》人类&#xff0c;这个阶段就太有想象空间了。而最受关注的-类人机器人。 如何…

Javascript代码压缩混淆工具terser详解

原始的JavaScript代码在正式的服务器上,如果没有进行压缩,混淆,不仅加载速度比较慢,而且还存在安全和性能问题. 因此现在需要进行压缩,混淆处理. 处理方案简单描述一下: 1. 使用 terser 工具进行 安装 terser工具: # npm 安装 npm install terser --save-dev# 或使用 yarn 安…

Java String 常用方法详解

目录 一、获取字符串信息(一)获取字符串长度(二)获取指定索引处的字符(三)获取子字符串二、字符串比较(一)比较字符串内容(二)忽略大小写比较三、字符串转换(一)转换为大写(二)转换为小写四、字符串查找(一)查找子字符串的位置(二)从指定位置开始查找五、字符…

Linux驱动开发练习案例

1 开发目标 1.1 架构图 操作系统&#xff1a;基于Linux5.10.10源码和STM32MP157开发板&#xff0c;完成tf-a(FSBL)、u-boot(SSBL)、uImage、dtbs的裁剪&#xff1b; 驱动层&#xff1a;为每个外设配置DTS并且单独封装外设驱动模块。其中电压ADC测试&#xff0c;采用linux内核…

leetcode-代码随想录-哈希表-赎金信

题目 题目链接&#xff1a;383. 赎金信 - 力扣&#xff08;LeetCode&#xff09; 给你两个字符串&#xff1a;ransomNote 和 magazine &#xff0c;判断 ransomNote 能不能由 magazine 里面的字符构成。 如果可以&#xff0c;返回 true &#xff1b;否则返回 false 。 maga…

精品可编辑PPT | “新基建”在数字化智慧高速公路中的支撑应用方案智慧建筑智慧交通解决方案施工行业解决方案

本文详细阐述了“新基建”在数字化智慧高速公路中的支撑应用方案&#xff0c;从政策背景出发&#xff0c;指出国家在交通领域的一系列发展规划和指导意见&#xff0c;强调了智慧交通建设的重要性。分析了当前高速公路存在的问题&#xff0c;如基础感知设施不足、协同水平低、服…

C语言求3到100之间的素数

一、代码展示 二、运行结果 三、感悟思考 注意: 这个题思路他是一个试除法的一个思路 先进入一个for循环 遍历3到100之间的数字 第二个for循环则是 判断他不是素数 那么就直接退出 这里用break 是素数就打印出来 在第一个for循环内 第二个for循环外

英语—四级CET4考试—蒙猜篇—匹配题

蒙猜方法一 匹配题的做题&#xff1a; 方法一&#xff1a; 首先&#xff0c;什么都不想&#xff0c;把问题中ing形式的&#xff0c;大写字母的&#xff0c;人名&#xff0c;地名&#xff0c;最后几个依次框起来。 然后&#xff0c;比如46题&#xff0c;口里默念meaningful lif…

股票日数据使用_未复权日数据生成前复权日周月季年数据

目录 前置&#xff1a; 准备 代码&#xff1a;数据库交互部分 代码&#xff1a;生成前复权 日、周、月、季、年数据 前置&#xff1a; 1 未复权日数据获取&#xff0c;请查看 https://blog.csdn.net/m0_37967652/article/details/146435589 数据库使用PostgreSQL。更新日…

系统与网络安全------Windows系统安全(6)

资料整理于网络资料、书本资料、AI&#xff0c;仅供个人学习参考。 共享文件夹 发布共享文件夹 Windows共享概述 微软公司推出的网络文件/打印机服务系统 可以将一台主机的资源发布给其他主机共有 共享访问的优点 方便、快捷相比光盘 U盘不易受文件大小限制 可以实现访问…