300行代码看透libhv TcpServer：从接收连接到负载均衡全解析

【免费下载链接】libhv 🔥 比libevent/libuv/asio更易用的网络库。A c/c++ network library for developing TCP/UDP/SSL/HTTP/WebSocket/MQTT client/server. 项目地址: https://gitcode.com/gh_mirrors/li/libhv

你是否好奇高性能网络库如何处理成千上万的并发连接？作为比libevent更易用的网络库，libhv的TcpServer实现堪称教科书级范例。本文将带你拆解evpp/TcpServer.h的核心架构，掌握从套接字创建到事件分发的全流程，让你30分钟内理解高性能服务器的设计精髓。

TcpServer核心架构概览

libhv的TcpServer采用** acceptor-worker模型**，通过分离连接接收和数据处理提高并发能力。核心类关系如下：

关键组件分工：

• ** acceptor_loop **: 单独线程处理新连接接收
• ** worker_threads **: 线程池管理多个IO事件循环
• ** TSocketChannel **: 封装TCP连接的生命周期管理

初始化流程：从套接字创建到事件循环

1. 套接字创建与监听

evpp/TcpServer.h的createsocket方法通过系统调用创建并监听套接字：

int createsocket(int port, const char* host = "0.0.0.0") {
    listenfd = Listen(port, host);  // 封装socket/bind/listen系统调用
    if (listenfd < 0) return listenfd;
    this->host = host;
    this->port = port;
    return listenfd;
}

2. 线程模型配置

通过setThreadNum设置工作线程数，evpp/TcpServer.h：

void setThreadNum(int num) {
    worker_threads.setThreadNum(num);  // 配置工作线程池大小
}

线程模型支持三种模式：

• 单线程模式（num=0）：acceptor_loop同时处理连接和IO
• 多线程模式（num>0）：acceptor单独线程，IO由worker线程池处理
• 绑定CPU模式：通过环境变量HV_CPU_AFFINITY设置线程亲和性

3. 启动流程

start方法启动服务的完整流程evpp/TcpServer.h：

void start(bool wait_threads_started = true) {
    if (worker_threads.threadNum() > 0) {
        worker_threads.start(wait_threads_started);  // 启动工作线程池
    }
    acceptor_loop->runInLoop(std::bind(&TcpServerEventLoopTmpl::startAccept, this));
}

连接处理：从accept到数据收发

新连接接收流程

当有新连接到来时，evpp/TcpServer.h的onAccept回调被触发：

static void onAccept(hio_t* connio) {
    TcpServer* server = (TcpServer*)hevent_userdata(connio);
    hio_detach(connio);  // 从acceptor_loop分离
    EventLoopPtr worker_loop = server->worker_threads.nextLoop(server->load_balance);
    worker_loop->runInLoop(std::bind(&TcpServer::newConnEvent, connio));
}

负载均衡策略

evpp/TcpServer.h支持多种负载均衡算法：

• ** LB_RoundRobin **: 轮询分配（默认）
• ** LB_LeastConnections **: 最小连接优先
• ** LB_SourceAddressHash **: 源地址哈希

连接生命周期管理

newConnEvent完成连接初始化[evpp/TcpServer.h#L196]：

static void newConnEvent(hio_t* connio) {
    // 检查最大连接数
    if (server->connectionNum() >= server->max_connections) {
        hio_close(connio);
        return;
    }
    // 创建Channel对象
    const TSocketChannelPtr& channel = server->addChannel(connio);
    channel->status = SocketChannel::CONNECTED;
    // 设置读写回调
    channel->onread = server, &channel {
        server->onMessage(channel, buf);  // 触发用户消息回调
    };
}

事件循环：IO多路复用的实现

event/hloop.c实现了高效的事件循环，核心在hloop_run函数：

void hloop_run(hloop_t* loop) {
    loop->status = HLOOP_STATUS_RUNNING;
    while (loop->status != HLOOP_STATUS_STOP) {
        hloop_process_events(loop, HLOOP_MAX_BLOCK_TIME);
    }
}

事件处理流程：

1. ** hloop_process_ios **: 调用epoll/poll等IO多路复用接口
2. ** hloop_process_timers **: 处理定时事件
3. ** hloop_process_pendings **: 执行回调函数队列

连接事件分发

每个工作线程维护独立的事件循环，通过event/hloop.c的hio_attach实现连接在不同线程间的迁移：

void hio_attach(hloop_t* loop, hio_t* io) {
    // 将IO对象关联到目标事件循环
    io->loop = loop;
    loop->ios.ptr[io->fd] = io;
}

实战示例：构建高性能回显服务器

examples/tcp_echo_server.c展示了TcpServer的典型用法，核心代码：

// 1. 创建事件循环
hloop_t* loop = hloop_new(0);

// 2. 创建TCP服务器
hio_t* listenio = hloop_create_tcp_server(loop, "0.0.0.0", 1234, on_accept);

// 3. 设置连接回调
static void on_accept(hio_t* io) {
    hio_setcb_read(io, on_recv);  // 设置读回调
    hio_read_start(io);
}

// 4. 数据处理回调
static void on_recv(hio_t* io, void* buf, int readbytes) {
    hio_write(io, buf, readbytes);  // 回显数据
}

// 5. 启动事件循环
hloop_run(loop);

性能测试数据

在4核8G服务器上，该回显服务器性能表现：

• 并发连接数：10,000+
• 吞吐量：> 100,000 TPS
• 延迟：< 1ms（99分位）

高级特性解析

SSL/TLS加密通信

通过withTLS方法启用加密，evpp/TcpServer.h：

int withTLS(hssl_ctx_opt_t* opt = NULL) {
    tls = true;
    if (opt) {
        opt->endpoint = HSSL_SERVER;  // 配置服务端证书
        *tls_setting = *opt;
    }
    return 0;
}

证书配置示例：

hssl_ctx_opt_t ssl_opt;
ssl_opt.crt_file = "cert/server.crt";  // [cert/server.crt](https://link.gitcode.com/i/eec2b58d5f03ad96d80be0a5d45e383a)
ssl_opt.key_file = "cert/server.key";  // [cert/server.key](https://link.gitcode.com/i/8820b66addae12124baa9da35472e576)
server.withTLS(&ssl_opt);

自定义拆包协议

通过setUnpack设置应用层协议，evpp/TcpServer.h支持：

• 固定长度拆包
• 分隔符拆包（如\n\r）
• 头部长度字段拆包

示例配置：

unpack_setting_t setting = {
    .package_max_length = 1024,
    .mode = UNPACK_BY_DELIMITER,
    .delimiter = "\r\n",
    .delimiter_bytes = 2
};
server.setUnpack(&setting);

最佳实践与注意事项

1. ** 线程数配置 **: 工作线程数建议设为CPU核心数的1-2倍
2. ** 连接管理 **: 通过foreachChannel定期检测空闲连接
3. ** 内存管理 **: 配合onClose回调释放连接相关资源
4. ** 性能监控**: 启用DEBUG模式查看事件循环状态：

   htimer_add(loop, hloop_stat_timer_cb, 1000, INFINITE);  // 每秒打印状态
   

总结与进阶

通过本文你已掌握libhv TcpServer的核心设计：

• ** 线程模型 **: acceptor-worker分离处理连接与IO
• ** 事件驱动 **: 高效的IO多路复用实现
• ** 扩展性设计**: 模块化架构支持自定义协议

进阶学习建议：

1. 深入event/hloop.c理解事件循环实现
2. 研究examples/http_server_test.cpp学习HTTP协议扩展
3. 参与官方文档docs/cn/TcpServer.md的贡献

掌握这些知识后，你也能设计出支持10万级并发的高性能服务器。现在就动手修改examples/tcp_echo_server.c，尝试添加自定义协议支持吧！

点赞+收藏本文，关注作者获取更多libhv源码解析系列文章，下期将揭秘WebSocketServer的实现原理。

【免费下载链接】libhv 🔥 比libevent/libuv/asio更易用的网络库。A c/c++ network library for developing TCP/UDP/SSL/HTTP/WebSocket/MQTT client/server. 项目地址: https://gitcode.com/gh_mirrors/li/libhv