阅读量:0
文章目录
muduo源码编译安装
muduo依赖Boost库，所以我们应该先编译安装boost，方法如下：
https://blog.csdn.net/QIANGWEIYUAN/article/details/88792874
随后可以编译安装muduo，方法如下：
https://blog.csdn.net/QIANGWEIYUAN/article/details/89023980
muduo的底层其实就是采用nonblock io + one loop per thread 以及 epoll + 线程池的框架，采用sub-Reactor模式。
该方案的特点就是one loop per thread，有一个main reactor负载accept连接，然后把连接分发到某个sub reactor(采用round-robin的方式选择sub reactor)，该链接的所有操作都在那个sub reactor所处的线程中完成，多个链接可能被分派到多个线程中，以充分利用CPU。
Reactor poll的大小是固定的，根据CPU的核心数目确定
//设置EventLoop的线程个数，底层通过EventLoopThreadPool线程池管理线程类EventLoopThread _server.setThreadNum(10); 一个Base IO thread负责accept新的连接，接收到新的连接以后，采用轮询的方式在reactor pool中找到合适的sub reactor将这个链接挂载上去，这个链接上的所有任务都在这个sub reactor上完成。
如果有过多的CPU I/O的计算任务，可以提交到创建的ThreadPool线程池中专门处理耗时的计算任务
muduo框架讲解
无论是什么语言，想要做到高并发，
首先要有一个IO线程，它里面有一个epoll，我们叫做main Reactor，它的作用就是建立新用户的连接，新用户的连接上之后，会把这些连接通过一定的负载算法分发给不同的工作线程。
这些工作线程就是用来处理已连接用户的读写事件，一般这些线程的数量会和CPU的核数对等。尽量做到高并发。
用IO复用的好处就是一个线程可以监听多个套接字，尤其是对于连接量大而活跃量少（一般都是这样的场景），所以epoll有非常大的性能优势。
如果工作线程的每一个epoll所监听的连接用户要做比较耗时的IO操作（传送文件、音视频），我们可以在工作线程内单独开一个线程。如果我们不单独开线程的话，工作线程会阻塞在IO操作中，无法监听其他依然注册在epoll树上的fd的读写时间。
muduo源代码有很多非常好的封装思想，里面大量得使用了智能指针、绑定器、函数对象、回调机制等等，可以做到模块化的解耦和软件的高内聚低耦合
muduo库编写服务器代码示例
muoduo库的使用需要链接 libmuduo_base.so libmuduo_net.so libpthread.so
动态库在linux系统默认的路径是/usr/lib/usr/local/lib
如果动态库放在这个路径下不需要在cmake中添加搜索路径，因为他们已经处于环境变量中。
//由于依赖关系的存在，net依赖于base，base依赖于pthread，连接顺序不能改变 -lmuduo_net -lmuduo_base -lpthread 使用实例代码如下：
/* muduo网络库给用户提供了两个主要的类 TcpServer：用于编写服务器程序的 TcpClient：用于编写客户端程序的 epoll + 线程池 好处：能够把网络IO的代码和业务代码区分开，muduo库已经把网络端的代码封装好了。 业务代码暴露在两个，我们也只关心这两件事： 用户的连接和断开 用户的可读写事件 */ #include <muduo/net/TcpServer.h> #include <muduo/net/EventLoop.h> #include <iostream> #include <functional> #include <string.h> using namespace std; using namespace muduo; using namespace muduo::net; using namespace placeholders; /*基于muduo网络库开发服务器程序 1.组合TcpServer对象 2.创建EventLoop事件循环对象的指针 3.明确TcpServer的构造函数需要什么参数，输出ChatServer的构造函数 4.在当前服务器类的构造函数中，注册处理连接的回调函数和处理读写事件的回调函数 5.设置合适的服务端线程数量，muduo库会自己划分I/O线程和worker线程 */ class ChatServer { public: ChatServer(EventLoop* loop, //事件循环 const InetAddress& listenAddr, //IP+Port const string& nameArg) //服务器名字 :_server(loop, listenAddr, nameArg), _loop(loop) { //给服务器注册用户连接的创建和断开回调 _server.setConnectionCallback(std::bind(&ChatServer::onConnection, this, _1)); //给服务器注册用户读写事件回调 _server.setMessageCallback(std::bind(&ChatServer::onMessage, this, _1, _2, _3)); //设置服务器端的服务线程 设置为2，1个IO线程，1个worker线程 _server.setThreadNum(2); } // 开启事件循环 void start() { _server.start(); } private: //专门处理用户的链接创建和断开 void onConnection(const TcpConnecitonPtr &conn) { if (conn->connected()) { cout << conn->peerAddress().toIpPort() << " -> " << << conn->localAddress().toIpPort() << "state:online" <<endl; } else { cout << conn->peerAddress().toIpPort() << " -> " << << conn->localAddress().toIpPort() << "state:offline" <<endl; conn->shutdown(); //连接断开后，回收fd资源close(fd) //_loop->quit(); //通知事件循环停止运行，这通常是在准备关闭服务器或者结束程序时执行的操作 } } //专门处理用户的读写事件 void onMessage(const TcpConnection &conn, //这是我们的连接，可以读数据也可以写数据 Buffer *buf, // 用户的缓冲区 Timestamp time) { //接受数据的时间信息 string buf = buffer->retrieveAllAsString(); //可以把其中接收到的数据全部接收到自己的字符串当中 cout << "recv data: " << buf << " time: " << time.toString() << endl; conn->send(buf); } TcpServer _server; //#1 EventLoop *_loop; //#2 把它看作epoll } int main () { EventLoop loop; //epoll InetAddress addr("127.0.0.1", 10000); ChatServer server(&loop, addr, "ChatServer"); server.start(); //listenfd epollctl=>epoll loop.loop; //epoll_wait以阻塞方式等待新用户连接，已连接用户的读写事件等 return 0; } 代码解析
以上代码就已经实现了一个高性能高并发的服务器程序，muduo库已经为我们把网络端封装好了，我们只需要进行应用层业务逻辑的代码编写。
在例子中，其实我们只需要关注两个函数的编写：
void onConnection(const TcpConnecitonPtr &conn); void onMessage(const TcpConnection &conn, //这是我们的连接，可以读数据也可以写数据 Buffer *buf, // 用户的缓冲区 Timestamp time) //接受数据的时间信息 也就是用户连接的创建和断开回调函数、用户读写事件回调。
用户连接的创建和断开回调函数
//专门处理用户的链接创建和断开 void onConnection(const TcpConnecitonPtr &conn) { if (conn->connected()) { cout << conn->peerAddress().toIpPort() << " -> " << << conn->localAddress().toIpPort() << "state:online" <<endl; } else { cout << conn->peerAddress().toIpPort() << " -> " << << conn->localAddress().toIpPort() << "state:offline" <<endl; conn->shutdown(); //连接断开后，回收fd资源close(fd) //_loop->quit(); //通知事件循环停止运行，这通常是在准备关闭服务器或者结束程序时执行的操作 } } 本案例中，我们在连接后打印远端的相关信息，断开后打印远端相关信息（这里就是典型的业务层逻辑）。
用户读写事件回调
这里写的是接受读缓冲区（读缓冲区的数据是客户端写入的）的数据，并且打印到终端。
//专门处理用户的读写事件 void onMessage(const TcpConnection &conn, //这是我们的连接，可以读数据也可以写数据 Buffer *buf, // 用户的缓冲区 Timestamp time) { //接受数据的时间信息 string buf = buffer->retrieveAllAsString(); //可以把其中接收到的数据全部接收到自己的字符串当中 cout << "recv data: " << buf << " time: " << time.toString() << endl; conn->send(buf); } 如果是浏览器的话，在这里我们在读写事件回调中去解析浏览器的http消息，然后根据http的请求，组织http响应在发送回给浏览器（这就是所谓的业务代码）。
使用vscode编译程序
配置c_cpp_properties.json
按F1，这里可以把配置的对话框打印出来
{ "configurations": [ { "name": "Linux", "includePath": [ "${workspaceFolder}/**$" ], "defines": [], "compilerPath": "/usr/bin/gcc", "cStandard": "c11", "intelliSenseMode": "clang-x64" } ], "version": 4 } 这里的配置文件中，若果我们去执行一条编译命令，需要写
//gcc -I头文件搜索路径 -L库文件搜索路径 -lmuduo_net库名称 一般我们可以在"includePath": []中加头文件、库文件的搜索路径（/usr/include /usr/local/include默认包含），库的名称在配置tasks.json；
还可以添加C++标准"cppStandard": "c++17"；
配置tasks.json
ctrl+shift+B(build)可以看到构建项目的配置文件，点击齿轮即可
在这里有一个tasks.json配置文件。
"version": "2.0.0", "tasks": [ { "type": "shell", "label": "g++ build active file", "command": "user/bin/g++", "arg": [ "-g", "${file}", "-o", "${fileDirname}/${fileBasenameNoExtension}", ] "options": { "cwd": "/bsr/bin" }, "problemMatcher": [ "$gcc" ], "group": "build" } ] 我们的-lmuduo_net库名称就是写在tasks.json文件中的"arg"里
"arg": [ "-g", "${file}", "-o", "${fileDirname}/${fileBasenameNoExtension}", "-lmuduo_net", "-lmuduo_base", "-lpthread" ] 配置launch.json
只有调试的时候采用，我们最好使用gdb调试
编译
配置好c_cpp_properties.json和配置tasks.json后。
ctrl+shift+B(build)然后直接点击蓝色的地方而不是点击齿轮，就可以进行编译啦。
总结
这样，我们就很简单得写出了一个健壮的、基于事件驱动的、IO复用的高并发高性能服务器。
