栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 系统运维 > 运维 > Linux

182-muduo网络库(陈硕)编程

Linux 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

182-muduo网络库(陈硕)编程

1、muduo网络库编程
  • muduo网络库的底层就是epoll加linux的pthread线程库。
  • 所以muduo库只能装在linux环境中。
  • muduo网络库的安装:https://blog.csdn.net/QIANGWEIYUAN/article/details/89023980

我们在做项目的时候,服务器一定要做到高并发,要用到muduo库。但是客户端只是向服务器请求服务,不需要高并发的性能要求。

2、基于muduo的客户端服务器编程

muduo网络库的编程很容易,要实现基于muduo网络库的服务器和客户端程序,只需要简单的组合TcpServer和TcpClient就可以,代码实现如下:

服务器类的开发

客户端实现

3、用muduo中的线程池做计算任务

采用muduo进行服务器编程,如果遇到需要开辟多线程单独来处理复杂的计算任务或者其它阻塞任务等,不需要直接调用pthread_create来创建线程,muduo库提供的ThreadPool线程池管理类已经把Linux的线程创建完全封装起来了,如果想研究源码,可以剖析muduo中ThreadPool.cc和Thread.cc。ThreadPool使用示例:

4、 muduo的日志系统

在开发软件产品过程中,日志的输出非常重要,可以记录很多软件运行过程中的信息,方便定位调试问题,跟踪统计信息等等,muduo库提供的日志级别有:

5、muduo网络库的多线程模型

网络服务器编程常用模型
【方案1】 : accept + read/write 不是并发服务器
【方案2】 : accept + fork - process-pre-connection 适合并发连接数不大,计算任务工作量大于fork的开销
【方案3】 :accept + thread thread-pre-connection 比方案2的开销小了一点,但是并发造成线程堆积过多
【方案4】: muduo的网络设计:reactors in threads - one loop per thread

  • 方案的特点是one loop per thread,一个线程一个事件循环。
  • 有一个main reactor负载accept连接,然后把连接分发到某个sub reactor(采用round-robin(轮询)的方式来选择sub reactor),该连接的所用操作都在那个sub reactor所处的线程中完成。
  • 多个连接可能被分派到多个线程中,以充分利用CPU。Reactor poll的大小是固定的,根据CPU的数目确定。
  • 读写操作都在epoll上完成。

  • 一个Base IO thread负责accept新的连接,接收到新的连接以后,使用轮询的方式在reactor pool中找到合适的sub reactor将这个连接挂载上去,这个连接上的所有任务都在这个sub reactor上完成。
  • 如果有过多的耗费CPU I/O的计算任务,可以提交到创建的ThreadPool线程池中专门处理耗时的计算任务。

【方案5】 : reactors in process - one loop pre processnginx服务器的网络模块设计,基于进程设计,采用多个Reactors充当I/O进程和工作进程,通过一把accept锁,完美解决多个Reactors的“惊群现象”。

我们要做到高并发:

  • 一般来说, 线程的数量和CPU的核数对等,做到高并发。
  • I/O复用的好处就是一个线程可以监听多个套接字。对于连接量大活跃量少的场景。
  • 工作线程会单独开一个线程做耗时的I/O操作,传送文件,音频之类的,这样当前的工作线程就可以及时做其他的依然注册在epoll上的socket的读写事件。
6、muduo中的reactor模型

reactor模型是什么?先看一下维基百科的标准解释:

从上面的描述,可以看出如下关键点:

  1. 事件驱动(event handling)
  2. 可以处理一个或多个输入源(one or more inputs)
  3. 通过Service Handler同步的将输入事件(Event)采用多路复用分发给相应的Request Handler(多个)处理
  • 涉及了反应堆reatctor和事件分发器demultiplexs,服务处理器service handle;
  • 大家在平时学习的时候,仅仅向epoll注册了一个套接字,当套接字发生事情的时候,才去解决它,并没有做合理的OOP封装;实际上可以向epoll上注册的每一个fd,也就是socket匹配一个任务处理器,相当于一个回调,当epoll监听到Socket/fd有事件发生时,可以匹配到fd对应的任务处理器service handle

*mainReactor: 接收客户端的连接;
acceptor对象: 封装了处理IO线程中处理新用户连接事件的类对象,然后通过轮询的方式分发到各个SubReator,子反应堆再进行编解码,读写操作。

7、muduo网络库服务器编程示例

首先,我们在vscode上,要链接的库有:

我们依赖muduo库链接写的函数。
链接的时候要这样写:

如何去配置这些东西?
我们打开vscode,我们在test文件夹下创建一个新的文件夹:testmuduo

然后我们在testmuduo下定义一个文件:muduo_server.cpp

#include 
#include //事件循环 
#include 
#include //绑定器 
#include 
using namespace std;
using namespace muduo;
using namespace muduo::net;
using namespace placeholders;
//muduo的名字空间作用域
 

class ChatServer//TCPServer 
{
public:
    ChatServer(EventLoop *loop,               //事件循环,reeactor相当于反应堆
               const InetAddress &listenAddr, //muduo封装好的,绑定IP+Port
               const string &nameArg)//给TCPserver一个名字 
        : _server(loop, listenAddr, nameArg), _loop(loop)//没有默认构造哦 
    {
        //给服务器注册用户连接的创建和断开的回调,回调就是对端的相应事件发生了告诉网络库 ,然后网络库告诉我 ,我在回调函数开发业务 
        _server.setConnectionCallback(std::bind(&ChatServer::onConnection, this, _1));//绑定this对象到这个方法中,_1是参数占位符 

        //给服务器注册用户读写事件的回调
        _server.setMessageCallback(std::bind(&ChatServer::onMessage, this, _1, _2, _3));//绑定this对象到这个方法中 

        //设置服务器端的线程数量 1个I/O线程(监听新用户的连接事件), 3个worker线程
        //不设置的话,就1个线程而已,要处理连接又要处理业务 
        _server.setThreadNum(4);//设置4个线程,1个I/O线程,3个worker线程 
    }

    void start()    //开启事件循环 
    {
        _server.start();
    }

private:
    //专门处理:用户的连接创建和断开 epoll listenfd accept
    //如果有新用户的连接或者断开,muduo库就会调用这个函数 
    void onConnection(const TcpConnectionPtr &conn)
    {
        if (conn->connected())//连接 , peerAddress()对端的地址 localAddress() 本地的地址 
        {
            cout << conn->peerAddress().toIpPort() << " -> " << conn->localAddress().toIpPort() << " state:online" << endl;
        }
        else//断开 
        {
            cout << conn->peerAddress().toIpPort() << " -> " << conn->localAddress().toIpPort() << " state:offline" << endl;
            conn->shutdown();//相当于这些close(fd)
            //_loop->quit();    //相当于退出epoll
        }
    }

    //专门处理:用户的读写事件,muduo库去调用这个函数 
    void onMessage(const TcpConnectionPtr &conn, //连接,通过这个连接可以读写数据 
                   Buffer *buffer,               //缓冲区,提高数据收发的性能 
                   Timestamp time)               //接收到数据的时间信息
    {
        string buf = buffer->retrieveAllAsString();//收到的数据放到这个字符串中 
        cout << "recv data:" << buf << " time:" << time.toFormattedString() << endl;
        conn->send(buf);//返回 ,收到什么发送什么 
    }

    TcpServer _server;//第一步 
    EventLoop *_loop; //第二步相当于 epoll 事件循环的指针,有事件发生,loop上报 
};

int main()
{
    EventLoop loop;//相当于像是创建了epoll
    InetAddress addr("127.0.0.1", 6000);//IP地址,端口号 
    ChatServer server(&loop, addr, "ChatServer");

    server.start();//listenfd通过 epoll_ctl 添加到 epoll 
    loop.loop();//相当于epoll_wait,以阻塞方式等待新用户连接,已连接用户的读写事件等
}

直接右击 RUN Code,ld表示链接错误!(表示没有连接外部的库)

我们手动添加外部的库(注意链接库的顺序,先写muduo_net,因为muduo_base也依赖它了),进行编译:

直接运行这个服务器:

使用telent进行连接(telent相当于TCP客户端):

发送一个 hello liufeng,会进行回显!
telnet是ctrl和] 然后回车,输入quit才退出:

8、VScode的配置

我们按F1,输入edit:

这个是编译的配置文件:json格式

我们在命令行写命令,一般是这样的:

我们可以在includePath添加文件的搜索路径:

下面这4个路径是默认搜索的:


我们还可以添加C++的标准:

从哪里添加库的搜索路径?
ctrl+shift+B

点击图中的齿轮。
有一个tasks.json
我们就可以添加g++命令的后面的一些选项了。

编译:

  • ctrl+shift+B

这样,以后直接build就可以了
编译完成

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/882573.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号