当前位置: 首页 > news >正文

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

客户端和服务器都绑定在了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.dtcms.com/a/120684.html

相关文章:

  • linux提权进阶 环境变量劫持提权 nfs提权
  • spark架构和RDD相关概念
  • 蓝桥杯-小明的背包(动态规划-Java)
  • #无类域间路由(快速复习版)
  • 宝塔面板面试内容整理-性能监控
  • 建筑工程管理系统功能模块概览
  • 【MySQL 数据库】增删查改操作CRUD(上)
  • Elasticsearch 系列专题 - 第一篇:Elasticsearch 入门
  • Ansible的使用3
  • 大数据技术之SPARK
  • 潮玩宇宙大逃杀游戏源码搭建部署二开,可切换单多杀boss模式
  • 怎么构造思维链数据?思维链提示工程的五大原则
  • 区块链是怎么存储块怎么找到前一个块
  • 如何向ESL阿联酋航运发送EDI CODECO报文?
  • DeepSeek 助力 Vue3 开发:打造丝滑的日历(Calendar)
  • 基于STM32、HAL库的IP6525S快充协议芯片简介及驱动程序设计
  • java基础语法(3)数组
  • CTF web入门之信息收集
  • Maven和MyBatis学习总结
  • Windows10系统更改盘符
  • 【力扣hot100题】(080)爬楼梯
  • 【JavaScript】异步编程
  • 图解AUTOSAR_SWS_FunctionInhibitionManager
  • 重新定义PPT创作!ChatPPT发布全球首个AI PPT专用MCP Server
  • 函数作为返回值输出
  • OSI七层模型的封装及解包分用的过程
  • 智能客服系统中的意图识别与分类技术详解
  • 供应链建模大师相关操作笔记——报错可能原因
  • DNS域名解析(以实操为主)
  • 从 macos 切换到 windows 上安装的工具类软件