11.1.2 文件传输和接口设计

@小白鸽

876人浏览 · 2025-08-21 17:37:44

@小白鸽 · 2025-08-21 17:37:44 发布

1 网络模型

1.1 网络模型框图

核心原理：

可以开多个subReactor，每个subReactor对应一个线程
mainReactor负责处理新连接，并将新连接均匀分配给subReactor，后续该新连接由对应的 subReactor处理read，send等操作。
ThreadPool的线程池是不是只给单一的subReactor使用，而是可以给多个subReactor同时使用。

线程池的线程在执行任务的时候，数据回发给客户端是通过TcpConnection的 send接口，但需要注意的是，此时的send接口不是直接调用Linux的网络发送接口，而是先把数据缓存起来，由 subReactor来发送数据。

1.2 网络模型核心类

对于muduo的核心类和函数，这里我们只讲解涉及到的类和函数。

Channel

Channel：处理socket fd描述符，封装read_callback 、 write_callback 、 close_callback 、 error_callback 等IO事件

EpollPoller

EpollPoller：负责监听文件描述符事件是否触发以及返回发生事件的文件描述符以及具体事件的模块就是 Poller。在multi-reactor模型中，有多少reactor就有多少EpollPoller，EpollPoller给外部提供的最重要的方法：

TimeStamp poll(int timeoutMs, ChannelList *activeChannels)

这个函数可以说是Poller的核心了，当外部调用 poll 方法的时候，该方法底层其实是通过 epoll_wait 获取这个事件监听器上发生事件的fd及其对应发生的事件，我们知道每个fd都是由一个Channel封装的，通过哈希表 channels_ 可以根据fd找到封装这个fd的Channel。将事件监听器监听到该fd发生的事件写进这个 Channel中的revents成员变量中。然后把这个Channel装进 activeChannels 中（它是一个 vector）。这样，当外界调用完 poll 之后就能拿到事件监听器的监听结果 （ activeChannels_ ）。

EventLoop

EventLoop：EpollPoller是封装了和事件监听有关的方法和成员，调用一次 Poller::poll 方法它就能给你返回事件监听器的监听结果（发生事件的fd 及其发生的事件），EventLoop则是负责实现“循环”，负责驱动 “循环”的重要模块！！Channel和Poller其实相当于EventLoop的手下，EventLoop整合封装了二者并向上提供了更方便的接口来使用。

EventLoopThread：实际的线程，EventLoop的循环工作在EventLoopThread线程。

void EventLoopThread::threadFunc()
{
EventLoop loop;
....
loop.loop(); // EventLoop循环工作
...
}

或者主线程里

int main(int argc, char *argv[]) {
    ....
    EventLoop loop; //主循环
    ....
    HttpServer server(&loop, addr, "HttpServer", num_event_loops);
    server.start();
    //主线程的
    loop.loop(); //main reactor
    return 0;
}

TcpServer

tcp的网络服务，基于muduo开发必须掌握其函数接口的作用。

void setThreadNum(int numThreads)：设置io线程数量
void start()：启动服务
void setConnectionCallback(const ConnectionCallback& cb)：设置新连接和断开连接回调
void setMessageCallback(const MessageCallback& cb)：设置收到数据的回调
void setWriteCompleteCallback(const WriteCompleteCallback& cb)：设置写数据发送完毕的事件

连接的删除可以断点：TcpConnection::connectDestroyed()，后续触发TcpConnection析构后，在析构函数里也会析构 socket_ 最终调用：sockets::close

ThreadPool

线程池，我们可以用做业务线程池。常用函数：

void start(int numThreads)：设置线程池的线程数量，并启动线程池

void run(Task task)：把任务放入线程池执行，比如：

thread_pool_.run(std::bind(&CHttpConn::OnRead, http_conn, buf));

2 代码框架

如何从0添加代码

要添加新应用就是在这application层级的CMakeLists.txt添加即可，比如现在我们要基于muduo从0构建图床项目，我们写成

add_subdirectory(tc_http_srv)

然后在application层级新建tc_http_srv目录，并添加main.cc和CMakeLists.txt。即是：

// main.cc
#include <iostream>
int main()
{
    std::cout << "hello tuchuang\n";
    return 0;
}

CMakeLists.txt

ADD_EXECUTABLE(tc_http_srv main.cc)

在tc-src/build目录下重新编译：

编译出来新的应用程序，后续我们基于tc_http_srv开始沟通图床项目。

后续CMakeLists.txt还涉及的函数，下面举例，实际目录按项目要求来：

# AUX_SOURCE_DIRECTORY 查找在某个路径下的所有源文件，并可以取别名为比如BASE_LIST
# CMAKE_CURRENT_SOURCE_DIR 代表当前处理的源文件目录的路径
AUX_SOURCE_DIRECTORY(${CMAKE_CURRENT_SOURCE_DIR}/base BASE_LIST)
# 包含的头文件路径INCLUDE_DIRECTORIES
#INCLUDE_DIRECTORIES(/usr/include/fastdfs /usr/include/fastcommon
/usr/local/include/hiredis /usr/include/mysql)
INCLUDE_DIRECTORIES(${CMAKE_CURRENT_SOURCE_DIR}/base)
#顶层路径 CMAKE_SOURCE_DIR
INCLUDE_DIRECTORIES(${CMAKE_SOURCE_DIR})

#muduo库文件路径
#muduo库文件路径
LINK_DIRECTORIES(${CMAKE_SOURCE_DIR}/lib)
# 依赖其他库时要加上对应的库名
TARGET_LINK_LIBRARIES(tc_http_srv muduo_net mysqlclient pthread)

CMAKE_CURRENT_SOURCE_DIR：当前正在处理的源目录的路径.

CMAKE_SOURCE_DIR：最外层CMakeLists.txt所在目录