当前位置：首页 > article >正文

muduo网络库2

article 2025/2/27 15:50:59

Muduo网络库：底层实质上为Linux的epoll + pthread线程池，且依赖boost库。 muduo的网络设计核心为一个线程一个事件循环，有一个main Reactor负载accept连接，然后把连接分发到某个sub Reactor(采用轮询的方式来选择sub Reactor)，该连接的所用操作都在那个sub Reactor所处的线程中完成。多个连接可能被分派到多个线程中，以充分利用CPU，Reactor poll的大小是固定的，根据CPU的数目确定。如果有过多的耗费CPU I/O的计算任务，可以提交到创建的ThreadPool线程池中专门处理耗时的计算任务。

1、 muduo网络库实例

muduo网络库实质为: epoll + 线程池，优点是能够将网络I/O的代码和业务代码分开。而业务代码主要分为：用户的连接和断开、用户的可读写事件两类。至于什么时候发生这些事件，由网络库进行上报，如何监听这些事件，都是网络库所封装好的，我们就可以快速进行项目开发。

muduo给用户提供了两个主要的类：
1、TcpServer：用于编写服务器程序。
2、TcpClient：用于编写客户端程序。

如何配置muduo网络库请参考：写文章-CSDN创作中心

muduo网络库服务器编程

基于muduo网络库开发服务器程序

组合TcpServer对象
创建EventLoop事件循环对象的指针
明确TcpServer构造函数需要什么参数，输出ChatServer的参数
在当前服务器类的构造函数当中，注册处理连接的回调函数和处理读写事件的回调函数

#include <muduo/net/TcpServer.h>
#include <muduo/net/EventLoop.h>
#include <iostream>
#include <functional>
#include <string>
using namespace std;
using namespace muduo;
using namespace muduo::net;
using namespace placeholders;

class ChatServer
{
public:
    ChatServer(EventLoop *loop,
               const InetAddress &serverAddr,
               const string &nameArg)
        : _server(loop, serverAddr, nameArg), _loop(loop)
    {
        // 注册连接回调
        _server.setConnectionCallback(std::bind(&ChatServer::onConnection, this, _1));

        // 注册消息回调
        _server.setMessageCallback(std::bind(&ChatServer::onMessage, this, _1, _2, _3));

        // 设置线程数量
        _server.setThreadNum(4); // 4个IO线程
    }

    void start()
    {
        _server.start();
    }

private:
    // 处理连接
    void onConnection(const TcpConnectionPtr &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;
        }
    }

    // 处理消息
    void onMessage(const TcpConnectionPtr &conn, Buffer *buffer, Timestamp time)
    {
        string buf = buffer->retrieveAllAsString();
        cout << "recv data: " << buf << " time: " << time.toString() << endl;
        conn->send(buf); // 回显消息
    }

    TcpServer _server;
    EventLoop *_loop;
};

int main()
{
    EventLoop loop;
    InetAddress addr("127.0.0.1", 9898); // 监听 127.0.0.1:9898
    ChatServer server(&loop, addr, "ChatServer");
    server.start(); // 启动服务器
    loop.loop();    // 事件循环
    return 0;
}

上面的代码简单的使用了muduo网络库实现了一个回显服务器，我们可以在linux系统终端中使用telnet命令让客户端连接。