libev实现Io复用及定时器事件服务器

news2025/7/13 3:12:05

客户端和服务器都绑定在了enp2s0网卡，需要SERVER_IP和SERVER_PORT改为其ip，注意不能是127.0.0.1，因为这个是lo虚拟网口。

安装libev

sudo apt-get install libev-dev

客户端：

#include <iostream>
#include <string>
#include <cstring>
#include <unistd.h>
#include <fcntl.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <net/if.h>
#include <ev.h>

#define SERVER_IP "192.168.35.212" // 服务器 IP，替换为实际值
#define SERVER_PORT 6015
#define CLIENT_PORT 6014
#define BUFFER_SIZE 1024

struct ClientContext {
    int sockfd;
    struct sockaddr_in server_addr;
    ev_io io_watcher;
    ev_timer timer_watcher;
};

// 接收数据的回调函数
static void recv_cb(EV_P_ ev_io *w, int revents) {
    ClientContext *ctx = static_cast<ClientContext*>(w->data);
    char buffer[BUFFER_SIZE];
    struct sockaddr_in from_addr;
    socklen_t addr_len = sizeof(from_addr);

    ssize_t len = recvfrom(ctx->sockfd, buffer, BUFFER_SIZE, 0,
                           (struct sockaddr*)&from_addr, &addr_len);
    if (len < 0) {
        if (errno == EAGAIN || errno == EWOULDBLOCK) return; // 暂无数据
        perror("recvfrom failed");
        ev_break(EV_A_ EVBREAK_ALL);
        return;
    }
    buffer[len] = '\0';
    std::cout << "Received from server: " << buffer << std::endl;
}

// 发送数据的回调函数（定时器触发）
static void send_cb(EV_P_ ev_timer *w, int revents) {
    ClientContext *ctx = static_cast<ClientContext*>(w->data);
    std::string message = "Hello from client at " + std::to_string(time(nullptr));
    ssize_t sent = sendto(ctx->sockfd, message.c_str(), message.size(), 0,
                          (struct sockaddr*)&ctx->server_addr, sizeof(ctx->server_addr));
    if (sent < 0) {
        perror("sendto failed");
        ev_break(EV_A_ EVBREAK_ALL);
        return;
    }
    std::cout << "Sent to server: " << message << std::endl;
}

int main() {
    // 创建 UDP socket
    int sockfd = socket(AF_INET, SOCK_DGRAM, 0);
    if (sockfd < 0) {
        perror("socket creation failed");
        return 1;
    }

    // 设置 socket 为非阻塞
    int flags = fcntl(sockfd, F_GETFL, 0);
    fcntl(sockfd, F_SETFL, flags | O_NONBLOCK);

    // 绑定到本地 enp2s0 网卡
    struct sockaddr_in local_addr;
    memset(&local_addr, 0, sizeof(local_addr));
    local_addr.sin_family = AF_INET;
    local_addr.sin_addr.s_addr = INADDR_ANY; // 绑定任意 IP
    local_addr.sin_port = htons(CLIENT_PORT);

    struct ifreq ifr;
    strncpy(ifr.ifr_name, "enp2s0", IFNAMSIZ-1);
    if (setsockopt(sockfd, SOL_SOCKET, SO_BINDTODEVICE, (char*)&ifr, sizeof(ifr)) < 0) {
        perror("SO_BINDTODEVICE failed");
        close(sockfd);
        return 1;
    }

    if (bind(sockfd, (struct sockaddr*)&local_addr, sizeof(local_addr)) < 0) {
        perror("bind failed");
        close(sockfd);
        return 1;
    }

    // 设置服务器地址
    struct sockaddr_in server_addr;
    memset(&server_addr, 0, sizeof(server_addr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(SERVER_PORT);
    if (inet_pton(AF_INET, SERVER_IP, &server_addr.sin_addr) <= 0) {
        perror("inet_pton failed");
        close(sockfd);
        return 1;
    }

    // 初始化 libev 事件循环
    struct ev_loop *loop = EV_DEFAULT;
    ClientContext ctx;
    ctx.sockfd = sockfd;
    ctx.server_addr = server_addr;

    // 设置接收数据的 watcher
    ev_io_init(&ctx.io_watcher, recv_cb, sockfd, EV_READ);
    ctx.io_watcher.data = &ctx;
    ev_io_start(loop, &ctx.io_watcher);

    // 设置定时器，每 100ms 发送一次
    ev_timer_init(&ctx.timer_watcher, send_cb, 0.1, 0.1); // 初次延迟 100ms，之后每 100ms
    ctx.timer_watcher.data = &ctx;
    ev_timer_start(loop, &ctx.timer_watcher);

    std::cout << "Client started, bound to enp2s0, sending to " << SERVER_IP << ":" << SERVER_PORT << std::endl;

    // 运行事件循环
    ev_run(loop, 0);

    // 清理
    close(sockfd);
    return 0;
}

服务器：

#include <iostream>
#include <string>
#include <cstring>
#include <unistd.h>
#include <fcntl.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <net/if.h>
#include <ev.h>

#define SERVER_PORT 6015
#define CLIENT_IP "192.168.35.212" // 客户端 IP，替换为实际值
#define CLIENT_PORT 6014
#define BUFFER_SIZE 1024

struct ServerContext {
    int sockfd;
    struct sockaddr_in client_addr;
    ev_io io_watcher;
    ev_timer timer_watcher;
};

// 接收数据的回调函数
static void recv_cb(EV_P_ ev_io *w, int revents) {
    ServerContext *ctx = static_cast<ServerContext*>(w->data);
    char buffer[BUFFER_SIZE];
    struct sockaddr_in from_addr;
    socklen_t addr_len = sizeof(from_addr);

    ssize_t len = recvfrom(ctx->sockfd, buffer, BUFFER_SIZE, 0,
                           (struct sockaddr*)&from_addr, &addr_len);
    if (len < 0) {
        if (errno == EAGAIN || errno == EWOULDBLOCK) return; // 暂无数据
        perror("recvfrom failed");
        ev_break(EV_A_ EVBREAK_ALL);
        return;
    }
    buffer[len] = '\0';
    std::cout << "Received from client: " << buffer << std::endl;
}

// 发送数据的回调函数（定时器触发）
static void send_cb(EV_P_ ev_timer *w, int revents) {
    ServerContext *ctx = static_cast<ServerContext*>(w->data);
    std::string message = "Hello from server at " + std::to_string(time(nullptr));
    ssize_t sent = sendto(ctx->sockfd, message.c_str(), message.size(), 0,
                          (struct sockaddr*)&ctx->client_addr, sizeof(ctx->client_addr));
    if (sent < 0) {
        perror("sendto failed");
        ev_break(EV_A_ EVBREAK_ALL);
        return;
    }
    std::cout << "Sent to client: " << message << std::endl;
}

int main() {
    // 创建 UDP socket
    int sockfd = socket(AF_INET, SOCK_DGRAM, 0);
    if (sockfd < 0) {
        perror("socket creation failed");
        return 1;
    }

    // 设置 socket 为非阻塞
    int flags = fcntl(sockfd, F_GETFL, 0);
    fcntl(sockfd, F_SETFL, flags | O_NONBLOCK);

    // 绑定到本地 enp2s0 网卡
    struct sockaddr_in local_addr;
    memset(&local_addr, 0, sizeof(local_addr));
    local_addr.sin_family = AF_INET;
    local_addr.sin_addr.s_addr = INADDR_ANY; // 绑定任意 IP
    local_addr.sin_port = htons(SERVER_PORT);

    struct ifreq ifr;
    strncpy(ifr.ifr_name, "enp2s0", IFNAMSIZ-1);
    if (setsockopt(sockfd, SOL_SOCKET, SO_BINDTODEVICE, (char*)&ifr, sizeof(ifr)) < 0) {
        perror("SO_BINDTODEVICE failed");
        close(sockfd);
        return 1;
    }

    if (bind(sockfd, (struct sockaddr*)&local_addr, sizeof(local_addr)) < 0) {
        perror("bind failed");
        close(sockfd);
        return 1;
    }

    // 设置客户端地址
    struct sockaddr_in client_addr;
    memset(&client_addr, 0, sizeof(client_addr));
    client_addr.sin_family = AF_INET;
    client_addr.sin_port = htons(CLIENT_PORT);
    if (inet_pton(AF_INET, CLIENT_IP, &client_addr.sin_addr) <= 0) {
        perror("inet_pton failed");
        close(sockfd);
        return 1;
    }

    // 初始化 libev 事件循环
    struct ev_loop *loop = EV_DEFAULT;
    ServerContext ctx;
    ctx.sockfd = sockfd;
    ctx.client_addr = client_addr;

    // 设置接收数据的 watcher
    ev_io_init(&ctx.io_watcher, recv_cb, sockfd, EV_READ);
    ctx.io_watcher.data = &ctx;
    ev_io_start(loop, &ctx.io_watcher);

    // 设置定时器，每 100ms 发送一次
    ev_timer_init(&ctx.timer_watcher, send_cb, 0.1, 0.1); // 初次延迟 100ms，之后每 100ms
    ctx.timer_watcher.data = &ctx;
    ev_timer_start(loop, &ctx.timer_watcher);

    std::cout << "Server started, bound to enp2s0, sending to " << CLIENT_IP << ":" << CLIENT_PORT << std::endl;

    // 运行事件循环
    ev_run(loop, 0);

    // 清理
    close(sockfd);
    return 0;
}

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

【精品PPT】2025固态电池知识体系及最佳实践PPT合集（36份）.zip

【精品PPT】2025固态电池知识体系及最佳实践PPT合集（36份）.zip

精品推荐&#xff0c;2025固态电池知识体系及最佳实践PPT合集&#xff0c;共36份。供大家学习参考。 1、中科院化学所郭玉国研究员&#xff1a;固态金属锂电池及其关键材料.pdf 2、中科院物理所-李泓固态电池.pdf 3、全固态电池技术研究进展.pdf 4、全固态电池生产工艺.pdf 5、…
阅读更多...
如何计算设备电池工作时长？

如何计算设备电池工作时长？

目录 【mAh&#xff08;毫安时&#xff09;计算方法】 【Wh&#xff08;瓦时&#xff09;计算方法】 【为什么仅用电流&#xff08;mA&#xff09;和时间&#xff08;h&#xff09;就能计算电池使用时长&#xff08;mAh&#xff09;&#xff1f;】 1. mAh 的本质是“电荷量…
阅读更多...
抽象类及其特性

抽象类及其特性

目录 1、概念2、语法3、特性4、作用 1、概念 在面向对象中&#xff0c;所有对象都是通过类来描述的&#xff0c;但是并不是所有的类都可以用来描述对象。比如下述例子中的 Animal 类&#xff0c;Dog 类和 Cat 类是 Animal 类的子类&#xff0c;可以分别描述小狗和小猫&#xf…
阅读更多...
【教程】xrdp修改远程桌面环境为xfce4

【教程】xrdp修改远程桌面环境为xfce4

转载请注明出处&#xff1a;小锋学长生活大爆炸[xfxuezhagn.cn] 如果本文帮助到了你&#xff0c;欢迎[点赞、收藏、关注]哦~ 目录 xfce4 vs GNOME对比 配置教程 1. 安装 xfce4 桌面环境 2. 安装 xrdp 3. 配置 xrdp 使用 xfce4 4. 重启 xrdp 服务 5. 配置防火墙&#xff…
阅读更多...
利用python从零实现Byte Pair Encoding(BPE)：NLP 中的“变形金刚”

利用python从零实现Byte Pair Encoding(BPE)：NLP 中的“变形金刚”

BPE&#xff1a;NLP 界的“变形金刚”&#xff0c;从零开始的奇幻之旅 在自然语言处理&#xff08;NLP&#xff09;的世界里&#xff0c;有一个古老而神秘的传说&#xff0c;讲述着一种强大的魔法——Byte Pair Encoding&#xff08;BPE&#xff09;。它能够将普通的文本“变形…
阅读更多...
部署redis cluster

部署redis cluster

一。在所有的主机里面设置密码和文件地址 vi /etc/redis/6379.conf 注释&#xff1a;登陆则要使用auth 123456才可以进入redis 配置文件地址和超时时间 二。创建集群&#xff1a;上面主机为master&#xff0c;下面为slave&#xff0c;master和slave会随机分配 先写主节点&…
阅读更多...
基于springboot钻孔数据管理系统的设计与实现(源码+lw+部署文档+讲解)，源码可白嫖!

基于springboot钻孔数据管理系统的设计与实现(源码+lw+部署文档+讲解)，源码可白嫖!

摘要 本钻孔数据管理系统采用B/S架构&#xff0c;数据库是MySQL&#xff0c;网站的搭建与开发采用了先进的Java语言、Hadoop、数据可视化技术进行编写&#xff0c;使用了Spring Boot框架。该系统从两个对象&#xff1a;由管理员和用户来对系统进行设计构建。用户主要功能包括&…
阅读更多...
动态科技感html导航网站源码

动态科技感html导航网站源码

源码介绍 动态科技感html导航网站源码&#xff0c;这个设计完美呈现了科幻电影中的未来科技界面效果&#xff0c;适合展示技术类项目或作为个人作品集的入口页面&#xff0c;自适应手机。 修改卡片中的链接指向你实际的HTML文件可以根据需要调整卡片内容、图标和颜色要添加更…
阅读更多...
YOLOv11训练中精准率召回率与mAP@0.5的动态变化分析

YOLOv11训练中精准率召回率与mAP@0.5的动态变化分析

目标检测模型的训练过程涉及多个关键性能指标和损失函数的变化&#xff0c;这些数据能够直观反映模型的收敛速度、最终精度以及改进效果。本文旨在通过绘制YOLOv11模型在训练过程中的精准率&#xff08;Precision&#xff09;、召回率&#xff08;Recall&#xff09;、mAP0.5 、…
阅读更多...
Java常用工具算法-6--秘钥托管云服务AWS KMS

Java常用工具算法-6--秘钥托管云服务AWS KMS

前言&#xff1a; 之前我们介绍了一些常用的加密算法&#xff08;如&#xff1a;对称加密AES&#xff0c;非对称加密RSA&#xff0c;ECC等&#xff09;&#xff0c;不论是哪一种都需要涉及到秘钥的管理。通常的做法都是把秘钥放到配置文件中进行配置&#xff0c;但是对于一些高…
阅读更多...
11. Langchain输出解析（Output Parsers）：从自由文本到结构化数据

11. Langchain输出解析（Output Parsers）：从自由文本到结构化数据

引言&#xff1a;从"自由发挥"到"规整输出" 2025年某金融机构的合同分析系统升级前&#xff0c;AI生成的合同摘要需人工二次处理达47分钟/份。引入LangChain结构化解析后&#xff0c;处理时间缩短至3分钟。本文将详解如何用LangChain的解析器&#xff0c;…
阅读更多...
python reportlab模块----操作PDF文件

python reportlab模块----操作PDF文件

reportlab模块----操作PDF文件 一. 安装模块二. reportlab相关介绍三. 扩展canvas类四. 水平写入完整代码五. 垂直写入完整代码 一. 安装模块 pip install reportlab二. reportlab相关介绍 # 1. letter 生成A4纸张尺寸 from reportlab.lib.pagesizes import letter print(let…
阅读更多...
解锁基因密码之重测序（从测序到分析）

解锁基因密码之重测序（从测序到分析）

在生命科学的奇妙世界中&#xff0c;基因恰似一本记录着生命奥秘的“天书”&#xff0c;它承载着生物体生长、发育、衰老乃至疾病等一切生命现象的关键信息。而重测序技术&#xff0c;则是开启基因“天书”奥秘的一把神奇钥匙。 试想&#xff0c;你手中有一本经典书籍的通用版…
阅读更多...
TQTT_KU5P开发板教程---QSFP25G光口回环测试

TQTT_KU5P开发板教程---QSFP25G光口回环测试

文档实现功能介绍 本文档通过一个叫做ibert的IP&#xff0c;实现25G光口回环测试例子。工程新建方法请参考文档《流水灯》&#xff0c;其中只是将文件名进行修改。 Vivado 起始页&#xff08;或 file-->Project-->New 创建新工程(Create New Project) 向导起始页面 点…
阅读更多...
JVM虚拟机篇（七）：JVM垃圾回收器全面解析与G1深度探秘及四种引用详解

JVM虚拟机篇（七）：JVM垃圾回收器全面解析与G1深度探秘及四种引用详解

JVM垃圾回收器全面解析与G1深度探秘及四种引用详解 JVM虚拟机&#xff08;七&#xff09;&#xff1a;JVM垃圾回收器全面解析与G1深度探秘及四种引用详解一、JVM有哪些垃圾回收器1. Serial回收器2. ParNew回收器3. Parallel Scavenge回收器4. Serial Old回收器5. Parallel Old回…
阅读更多...
柑橘病虫害图像分类数据集OrangeFruitDaatset-8600

柑橘病虫害图像分类数据集OrangeFruitDaatset-8600

文章目录 1. 前言2. 数据类别介绍3. 数据集地址 1. 前言 柑橘&#xff0c;作为水果界的 “宠儿”&#xff0c;不仅以其酸甜可口的味道深受大众喜爱&#xff0c;更是在全球水果产业中占据着举足轻重的地位。无论是早餐中的一杯橙汁&#xff0c;还是下午茶里的柑橘甜点&#xff…
阅读更多...
深度学习总结（4）

深度学习总结（4）

张量积 张量积&#xff08;tensor product&#xff09;或点积&#xff08;dot product&#xff09;是最常见且最有用的张量运算之一。注意&#xff0c;不要将其与逐元素乘积&#xff08;*运算符&#xff09;弄混。在NumPy中&#xff0c;使用np.dot函数来实现张量积&#xff0c…
阅读更多...
利用CST Microwave Studio设计贴片天线

利用CST Microwave Studio设计贴片天线

利用CST Microwave Studio设计贴片天线的步骤如下&#xff0c;分为几个关键阶段&#xff1a; --- ### **1. 初始设置** - **新建项目**&#xff1a;打开CST&#xff0c;创建新项目&#xff08;File > New&#xff09;&#xff0c;选择“Antenna (Planar)”或“Microwave &…
阅读更多...
STM32之SG90舵机控制（附视频讲解）

STM32之SG90舵机控制（附视频讲解）

目录 前言&#xff1a; 一、硬件准备与接线 1.1 硬件清单 1.2 接线 二、 SG90舵机简介 1.1 外观 1.2 基本参数 1.3 引脚说明 1.4 控制原理 1.5 特点 1.6 常见问题 三、 单片机简介 四、 程序设计 4.1 定时器配置 4.2 角度控制函数 4.3 主函数调用 五、 总结 …
阅读更多...
（1）英特尔 RealSense T265（三）

（1）英特尔 RealSense T265（三）

文章目录 前言 4.4 地面测试 4.5 飞行测试 4.6 室内外实验 4.7 数据闪存记录 4.8 启动时自动运行 4.9 使用 OpticalFlow 进行 EKF3 光源转换 前言 Realsense T265 通过 librealsense 支持 Windows 和 Linux 系统。不同系统的安装过程差异很大&#xff0c;因此请参阅 gi…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023