C++搭建集群聊天室(六):muduo网络库

举报
看,未来 发表于 2021/08/25 21:44:01 2021/08/25
【摘要】 @[toc] 简介与建议muduo网络库的编程很容易,要实现基于muduo网络库的服务器和客户端程序,只需要简单的组合 TcpServer 和 TcpClient 就可以。所以,我建议,这个系列整完去看一下源码。 网络服务器编程常用模型【方案1】 : accept + read/write 不是并发服务器【方案2】 : accept + fork - process-pre-connecti...

请添加图片描述

@[toc]

简介与建议

muduo网络库的编程很容易,要实现基于muduo网络库的服务器和客户端程序,只需要简单的组合 TcpServer 和 TcpClient 就可以。
所以,我建议,这个系列整完去看一下源码。


网络服务器编程常用模型

【方案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
在这里插入图片描述

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

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


muduo 的 reactor 模型

图在上面。有图的话我就不想多哔哔,一图胜千言。

从图中,我们可以看出:
XXXXXXXXX,妙啊!!!!


废话不多说,上手。


muduo 库网络编程示例

写一个回显数据库,你写啥进去就回显啥出来,运行的时候加上6000端口

#include"json.hpp"
using json = nlohmann::json; 


#include<vector>
#include<map>
#include<string>
#include<string.h>
#include<iostream>
using namespace std;

void func(){
    // 先来个最基本的
    json js;

    map<string,string> mss;
    mss.insert({"name","wlf"});   //呦呵,pair也插不了
    mss.insert({"age","21"});     //不过这样倒是比用pair要方便

    vector<int> vc = {1,2,3,4,5,6,7,8,9};

    js["name"] = "wlf";
    js["age"] = "21";
    js["path"] = mss;
    js["vc"] = vc;

    string s = js.dump();   //和Python里面的一样

    json js2 = json::parse(s);  //先解析,这里和Python不太一样
    //返回一个JSON的对象,可以看做一个容器
    cout<<js2<<endl;

    // 直接取key-value 
    string name = js2["name"]; 
    cout << "name:" << name << endl;

    // 直接反序列化vector容器 
    vector<int> v = js2["vc"]; 
    for(int val : v) { 
        cout << val << " "; 
    }
    cout << endl;

    // 直接反序列化map容器 
    map<string, string> 
    m2 = js2["path"]; 
    for(auto p : m2) { 
        cout << p.first << " " << p.second << endl; 
    }
    cout << endl;
}


int main(){

    func();

    return 0;
}

cmake编译

cmake_minimum_required(VERSION 3.0) # 最低版本
project(main)   # 给这个工程一个名字,这不是可执行文件的名字,是工程的名字

set(EXECUTABLE_OUTPUT_PATH ${PROJECT_SOURCE_DIR}/bin)

# 设置需要编译的源文件列表
set(SRC_LIST muduo_server_test.cpp)  # 可放多个,但是没必要


# 配置可执行文件名
add_executable(muduo_test ${SRC_LIST})


# 需要链接的外库
target_link_libraries(muduo_test muduo_net muduo_base pthread)   # 如果库之间有相互依赖,注意把被依赖的放前面
【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。