重写muduo网络库：终章TcpServer

2023-10-31 08:30
文章标签 重写 muduo 网络 tcpserver 终章

本文主要是介绍重写muduo网络库：终章TcpServer，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

终章TcpServer

回顾muduo网络库的简单使用：

#include <mymuduo/TcpServer.h>
#include <mymuduo/Logger.h>
#include <functional>
#include <string>class EchoServer
{
public:EchoServer(EventLoop* loop, const InetAddress &addr,const std::string &name):loop_(loop),server_(loop,addr,name){//注册回调函数server_.setMessageCallback(std::bind(&EchoServer::onMessage, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3));server_.setConnectionCallback(std::bind(&EchoServer::onConnection, this, std::placeholders::_1));//设置线程数量server_.setThreadNum(3);}void start(){server_.start();}
private:void onConnection(const TcpConnectionPtr& conn){if(conn->connected()){LOG_INFO("Connect UP : %s", conn->peerAddress().toIpPort().c_str());}else{LOG_INFO("Connect DOWN : %s", conn->peerAddress().toIpPort().c_str());}}void onMessage(const TcpConnectionPtr& conn,Buffer* buf,Timestamp time){std::string msg = buf->retrieveAllAsString();conn->send(msg);conn->shutdown();}EventLoop* loop_;TcpServer server_;
};int main()
{EventLoop loop;InetAddress addr(8000);EchoServer server(&loop, addr, "EchoServer-01");server.start();loop.loop();return 0;
}

用户先定义一个EventLoop事件循环和Socket地址，用他们构造一个TcpServer对象，然后就是设置回调函数和线程数量，接着就是启动线程池，开启循环监听。

而在构造TcpServer对象的时候做了什么呢？
在这里插入图片描述
首先就是接收了一个mainLoop，用接收的mainLoop和Socket地址创建了一个Acceptor，然后就是给Acceptor绑定了一个回调，这个回调就是在accept的处理流程，得到一个connfd时，就会触发这个回调。
在这里插入图片描述
这个回调会从线程池中获取一个ioLoop，对这个新连接的connfd打包成TcpConnection；设置用户设置的回调，回调的传递流程时从用户=》TcpServer=》TcpConnection=》Channel=》Poller；然后就runInLoop唤醒ioLoop所在的线程起来处理。

重写TcpServer.h：

#pragma once#include "noncopyable.h"
#include "EventLoop.h"
#include "Acceptor.h"
#include "InetAddress.h"
#include "Callbacks.h"
#include "EventLoopThreadPool.h"
#include "Buffer.h"
#include "TcpConnection.h"#include <string>
#include <functional>
#include <atomic>
#include <unordered_map>class TcpServer : noncopyable
{
public:using ThreadInitCallback = std::function<void(EventLoop*)>;enum Option{kNoReusePort,kReusePort,};TcpServer(EventLoop* loop, const InetAddress& listenAddr, const std::string& nameArg, Option option = kNoReusePort);~TcpServer();void setThreadInitCallback(const ThreadInitCallback &cb) { threadInitCallback_ = cb; }void setConnectionCallback(const ConnectionCallback &cb) { connectionCallback_ = cb; }void setMessageCallback(const MessageCallback &cb) { messageCallback_ = cb; }void setWriteCompleteCallback(const WriteCompleteCallback &cb) { writeCompleteCallback_ = cb; }//设置subloop线程数量void setThreadNum(int numThreads);//开启服务监听void start();private:void newConnection(int sockfd, const InetAddress &peerAddr);void removeConnection(const TcpConnectionPtr& conn);void removeConnectionInLoop(const TcpConnectionPtr& conn);using ConnectionMap = std::unordered_map<std::string, TcpConnectionPtr>;EventLoop *loop_; //用户定义的loopconst std::string ipPort_;const std::string name_;std::unique_ptr<Acceptor> acceptor_;    //运行在mainloop，任务就是监听新连接事件std::shared_ptr<EventLoopThreadPool> threadPool_;  //one loop per threadConnectionCallback connectionCallback_; //新连接回调MessageCallback messageCallback_;   //有读写消息时的回调WriteCompleteCallback writeCompleteCallback_;   //消息发送完成以后的回调ThreadInitCallback threadInitCallback_; //loop线程初始化的回调std::atomic_int started_;int nextConnId_;ConnectionMap connections_;  //保存所有的连接
};

重写TcpServer.cc：

#include "TcpServer.h"
#include "Logger.h"
#include "TcpConnection.h"#include <strings.h>EventLoop* CheckLoopNotNull(EventLoop *loop)
{if(loop == nullptr){LOG_FATAL("%s:%s:%d mainloop is null \n", __FILE__, __FUNCTION__, __LINE__);}return loop;
}TcpServer::TcpServer(EventLoop* loop, const InetAddress& listenAddr, const std::string& nameArg, Option option):loop_(CheckLoopNotNull(loop)),ipPort_(listenAddr.toIpPort()),name_(nameArg),acceptor_(new Acceptor(loop, listenAddr, option = kReusePort)),threadPool_(new EventLoopThreadPool(loop, name_)),connectionCallback_(),messageCallback_(),nextConnId_(1),started_(0)
{//当有新用户连接时，会执行TcpServer::newConnection回调acceptor_->setNewConnectionCallback(std::bind(&TcpServer::newConnection, this,std::placeholders::_1, std::placeholders::_2));
}//设置subloop线程数量
void TcpServer::setThreadNum(int numThreads)
{threadPool_->setThreadNum(numThreads);
}//开启服务监听
void TcpServer::start()
{if(started_++ == 0) //防止一个TcpServer对象被start多次{threadPool_->start(threadInitCallback_);loop_->runInLoop(std::bind(&Acceptor::listen, acceptor_.get()));}
}//有一个新的客户端的连接，acceptor会执行这个回调操作
void TcpServer::newConnection(int sockfd, const InetAddress& peerAddr)
{//轮询算法，选择一个subLoop，来管理channelEventLoop* ioLoop = threadPool_->getNextLoop();char buf[64] = {0};snprintf(buf, sizeof buf, "-%s#%d", ipPort_.c_str(), nextConnId_);++nextConnId_;std::string connName = name_ + buf;LOG_INFO("TcpServer::newConnection [%s] - new connection [%s] from %s \n",name_.c_str(), connName.c_str(), peerAddr.toIpPort().c_str());//通过sockfd获取其绑定的本机的IP地址和端口信息sockaddr_in local;::bzero(&local, sizeof local);socklen_t addrLen = sizeof local;if(::getsockname(sockfd, (sockaddr*)&local, &addrLen) < 0){LOG_ERROR("sockets::getLocalAddr");}InetAddress localAddr(local);//根据连接成功的sockfd，创建TcpConnection连接对象TcpConnectionPtr conn(new TcpConnection(ioLoop, connName, sockfd, localAddr, peerAddr));connections_[connName] = conn;//下面回调都是用户设置给Tcpserver =》TcpConnection = 》 channel =》 poller =》notify channel调用回调conn->setConnectionCallback(connectionCallback_);conn->setMessageCallback(messageCallback_);conn->setWriteCompleteCallback(writeCompleteCallback_);//设置了如何关闭连接的回调conn->setCloseCallback(std::bind(&TcpServer::removeConnection, this, std::placeholders::_1));ioLoop->runInLoop(std::bind(&TcpConnection::connectEstablished, conn));
}void TcpServer::removeConnection(const TcpConnectionPtr& conn)
{loop_->runInLoop(std::bind(&TcpServer::removeConnectionInLoop, this, conn));
}void TcpServer::removeConnectionInLoop(const TcpConnectionPtr& conn)
{LOG_INFO("TcpServer::removeConnectionInLoop [%s] - connection %s\n",name_.c_str(), conn->name().c_str());connections_.erase(conn->name());EventLoop* ioLoop = conn->getLoop();    ioLoop->queueInLoop(std::bind(&TcpConnection::connectDestroyed, conn));
}TcpServer::~TcpServer()
{for(auto &item : connections_){TcpConnectionPtr conn(item.second); //这个局部的shared_ptr智能指针对象，出右括号，可以自动释放newitem.second.reset();//销毁连接conn->getLoop()->runInLoop(std::bind(&TcpConnection::connectDestroyed, conn));}
}

这篇关于重写muduo网络库：终章TcpServer的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/314083。

相关文章

Linux系统配置NAT网络模式的详细步骤(附图文)

Linux系统配置NAT网络模式的详细步骤(附图文)

《Linux系统配置NAT网络模式的详细步骤(附图文)》本文详细指导如何在VMware环境下配置NAT网络模式,包括设置主机和虚拟机的IP地址、网关,以及针对Linux和Windows系统的具体步骤,... 目录一、配置NAT网络模式二、设置虚拟机交换机网关2.1 打开虚拟机2.2 管理员授权2.3 设置子
阅读更多...
揭秘Python Socket网络编程的7种硬核用法

揭秘Python Socket网络编程的7种硬核用法

《揭秘PythonSocket网络编程的7种硬核用法》Socket不仅能做聊天室,还能干一大堆硬核操作,这篇文章就带大家看看Python网络编程的7种超实用玩法,感兴趣的小伙伴可以跟随小编一起... 目录1.端口扫描器：探测开放端口2.简易 HTTP 服务器：10 秒搭个网页3.局域网游戏：多人联机对战4.
阅读更多...
SpringBoot使用OkHttp完成高效网络请求详解

SpringBoot使用OkHttp完成高效网络请求详解

《SpringBoot使用OkHttp完成高效网络请求详解》OkHttp是一个高效的HTTP客户端,支持同步和异步请求,且具备自动处理cookie、缓存和连接池等高级功能,下面我们来看看SpringB... 目录一、OkHttp 简介二、在 Spring Boot 中集成 OkHttp三、封装 OkHttp
阅读更多...
Linux系统之主机网络配置方式

Linux系统之主机网络配置方式

《Linux系统之主机网络配置方式》：本文主要介绍Linux系统之主机网络配置方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、查看主机的网络参数1、查看主机名2、查看IP地址3、查看网关4、查看DNS二、配置网卡1、修改网卡配置文件2、nmcli工具【通用
阅读更多...
使用Python高效获取网络数据的操作指南

使用Python高效获取网络数据的操作指南

《使用Python高效获取网络数据的操作指南》网络爬虫是一种自动化程序,用于访问和提取网站上的数据,Python是进行网络爬虫开发的理想语言,拥有丰富的库和工具,使得编写和维护爬虫变得简单高效,本文将... 目录网络爬虫的基本概念常用库介绍安装库Requests和BeautifulSoup爬虫开发发送请求解
阅读更多...
如何通过海康威视设备网络SDK进行Java二次开发摄像头车牌识别详解

如何通过海康威视设备网络SDK进行Java二次开发摄像头车牌识别详解

《如何通过海康威视设备网络SDK进行Java二次开发摄像头车牌识别详解》：本文主要介绍如何通过海康威视设备网络SDK进行Java二次开发摄像头车牌识别的相关资料,描述了如何使用海康威视设备网络SD... 目录前言开发流程问题和解决方案dll库加载不到的问题老旧版本sdk不兼容的问题关键实现流程总结前言作为
阅读更多...
SSID究竟是什么? WiFi网络名称及工作方式解析

SSID究竟是什么? WiFi网络名称及工作方式解析

《SSID究竟是什么?WiFi网络名称及工作方式解析》SID可以看作是无线网络的名称，类似于有线网络中的网络名称或者路由器的名称,在无线网络中，设备通过SSID来识别和连接到特定的无线网络... 当提到 Wi-Fi 网络时，就避不开「SSID」这个术语。简单来说，SSID 就是 Wi-Fi 网络的名称。比如
阅读更多...
Java实现任务管理器性能网络监控数据的方法详解

Java实现任务管理器性能网络监控数据的方法详解

《Java实现任务管理器性能网络监控数据的方法详解》在现代操作系统中,任务管理器是一个非常重要的工具,用于监控和管理计算机的运行状态,包括CPU使用率、内存占用等,对于开发者和系统管理员来说,了解这些... 目录引言一、背景知识二、准备工作1. Maven依赖2. Gradle依赖三、代码实现四、代码详解五
阅读更多...
Linux 网络编程 --- 应用层

Linux 网络编程 --- 应用层

一、自定义协议和序列化反序列化 代码： 序列化反序列化实现网络版本计算器 二、HTTP协议 1、谈两个简单的预备知识 https://www.baidu.com/ --- 域名 --- 域名解析 --- IP地址 http的端口号为80端口，https的端口号为443 url为统一资源定位符。CSDNhttps://mp.csdn.net/mp_blog/creation/editor
阅读更多...
ASIO网络调试助手之一：简介

ASIO网络调试助手之一：简介

多年前，写过几篇《Boost.Asio C++网络编程》的学习文章，一直没机会实践。最近项目中用到了Asio，于是抽空写了个网络调试助手。 开发环境： Win10 Qt5.12.6 + Asio(standalone) + spdlog 支持协议： UDP + TCP Client + TCP Server 独立的Asio（http://www.think-async.com）只包含了头文件，不依
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2