muduo_net代码剖析之Acceptor

Acceptor用于接收client的连接请求，建立连接

1、Acceptor类`简介`

类Acceptor主要功能socket、bind、listen，并调用注册的回调函数来处理新到的连接

2、Acceptor`连接建立` /`处理时序图`

1：当loop()函数监听到通道acceptChannel_有事件到来，即listen套接字可读时
2：acceptChannel_->handleEvent()
3：Acceptor::handleRead()
4：handleRead()函数中又调用了accept()接收客户端的请求
5：连接建立后，会调用注册的回调函数newConnectionCallback_()

`Acceptor .h`头文件

class Acceptor : noncopyable
{public:typedef std::function<void (int sockfd, const InetAddress&)> NewConnectionCallback;Acceptor(EventLoop* loop, const InetAddress& listenAddr, bool reuseport);~Acceptor();void setNewConnectionCallback(const NewConnectionCallback& cb){ newConnectionCallback_ = cb; }bool listenning() const { return listenning_; }void listen();private:void handleRead();EventLoop* loop_;Socket acceptSocket_;  //监听套接字Channel acceptChannel_;//通道NewConnectionCallback newConnectionCallback_;bool listenning_;int idleFd_;
};

3、源码剖析

① `构造函数`

Acceptor创建非阻塞的listen socket和channel，并且将Acceptor::handleRead函数设置为acceptChannel_的Read Callback

Acceptor::Acceptor(EventLoop* loop, const InetAddress& listenAddr, bool reuseport): loop_(loop), //所属的loopacceptSocket_(sockets::createNonblockingOrDie(listenAddr.family())), //创建非阻塞的listen套接字acceptChannel_(loop, acceptSocket_.fd()), //创建监听Channellistenning_(false), //是否正在监听idleFd_(::open("/dev/null", O_RDONLY | O_CLOEXEC)) //预留idlefd
{assert(idleFd_ >= 0);acceptSocket_.setReuseAddr(true); //设置地址、端口复用acceptSocket_.setReusePort(reuseport);acceptSocket_.bindAddress(listenAddr); //bind//设置ReadCallback，下面在Acceptor::listen()中acceptChannel_.enableReading();//==>当acceptChannel_有读事件(接收到新连接)时，将调用回调函数Acceptor::handleRead()acceptChannel_.setReadCallback(  std::bind(&handleRead, this));
}void Acceptor::handleRead()
{loop_->assertInLoopThread();InetAddress peerAddr;int connfd = acceptSocket_.accept(&peerAddr);//accept新连接if (connfd >= 0) //如果accept返回成功{if (newConnectionCallback_) //调用newConnectionCallback_回调函数{newConnectionCallback_(connfd, peerAddr);}else{sockets::close(connfd);}}else{LOG_SYSERR << "in Acceptor::handleRead";if (errno == EMFILE) //解决太多的文件描述符的错误：使用idlefd{::close(idleFd_); idleFd_ = ::accept(acceptSocket_.fd(), NULL, NULL); ::close(idleFd_); idleFd_ = ::open("/dev/null", O_RDONLY | O_CLOEXEC);}}
}

② `Acceptor::listen()`，这个函数顾名思义，就是开始监听对端的连接请求

void Acceptor::listen()
{loop_->assertInLoopThread();listenning_ = true;acceptSocket_.listen();acceptChannel_.enableReading(); //关心读事件
}

③ 设置连接建立成功后的回调函数：`setNewConnectionCallback`

accept返回后，即连接建立成功后，会执行注册的newConnectionCallback_函数

//设置[连接建立成功的回调函数]
void setNewConnectionCallback(const NewConnectionCallback& cb)
{ newConnectionCallback_ = cb; }

4、示例代码

#include "Acceptor.h"
#include "EventLoop.h"
#include "InetAddress.h"
#include "SocketsOps.h"
#include <stdio.h>void newConnection(int sockfd, const muduo::InetAddress& peerAddr)
{printf("newConnection(): accepted a new connection from %s\n",peerAddr.toHostPort().c_str());::write(sockfd, "How are you?\n", 13);muduo::sockets::close(sockfd);
}int main()
{printf("main(): pid = %d\n", getpid());muduo::InetAddress listenAddr(9981);muduo::EventLoop loop;muduo::Acceptor acceptor(&loop, listenAddr);acceptor.setNewConnectionCallback(newConnection);acceptor.listen();loop.loop();
}

muduo_net代码剖析之Acceptor相关推荐

x264代码剖析（一）：图文详解x264在Windows平台上的搭建
x264代码剖析(一):图文详解x264在Windows平台上的搭建 X264源码下载地址:http://ftp.videolan.org/pub/videolan/x264/ 平台:win7 PC. ...
x264代码剖析（十四）：核心算法之宏块编码函数x264_macroblock_encode()
x264代码剖析(十四):核心算法之宏块编码函数x264_macroblock_encode() 宏块编码函数x264_macroblock_encode()是完成变换与量化的主要函数,而x264_m ...
HDFS集中式的缓存管理原理与代码剖析--转载
原文地址:http://yanbohappy.sinaapp.com/?p=468 Hadoop 2.3.0已经发布了,其中最大的亮点就是集中式的缓存管理(HDFS centralized cache ...
x264代码剖析（四）：vs2010编译x264错误集锦
x264代码剖析(四):vs2010编译x264错误集锦支持VC++平台的x264的最新版本是x264-20091006,接下来就以该版本为例分析编译运行x264过程中遇到的问题以及解决办法. 1. ...
微信跳一跳刷分代码剖析
转载地址:http://blog.csdn.net/u013780605/article/details/78945239?ref=myrecommend 感谢学霸提供了这一途径,感谢原作者无私奉献. ...
IDDPM原理和代码剖析
前言 Improved Denoising Diffusion Probabilistic Models(IDDPM) 是上一篇 Denoising Diffusion Probabilistic M ...
windows下tomcat8启动脚本代码剖析--catalina.bat
Windows下,Tomcat可以以服务形式启动.停止,也可以执行脚本启动(startup.bat).停止(shutdown.bat).执行startup.bat时会调用catalina.bat,ca ...
x264代码剖析（二）：如何编译运行x264以及x264代码基本框架
x264代码剖析(二):如何编译运行x264以及x264代码基本框架 x264工程在x265出现之前一直在更新,但是自x264-20091007(含)不再支持VC++平台,也就是说支持VC++平台的x ...
x264代码剖析（九）：x264_encoder_encode()函数之x264_slice's'_write()函数
x264代码剖析(九):x264_encoder_encode()函数之x264_slice's'_write()函数 x264_encoder_encode()函数的核心函数就是x264_slice ...

muduo_net代码剖析之Acceptor

1、Acceptor类`简介`

2、Acceptor`连接建立` /`处理时序图`

`Acceptor .h`头文件

3、源码剖析

① `构造函数`

② `Acceptor::listen()`，这个函数顾名思义，就是开始监听对端的连接请求

③ 设置连接建立成功后的回调函数：`setNewConnectionCallback`

4、示例代码

muduo_net代码剖析之Acceptor相关推荐

最新文章

热门文章

muduo_net代码剖析之Acceptor

1、Acceptor类简介

2、Acceptor连接建立 /处理时序图

Acceptor .h头文件

3、源码剖析

① 构造函数

② Acceptor::listen()，这个函数顾名思义，就是开始监听对端的连接请求

③ 设置连接建立成功后的回调函数：setNewConnectionCallback

4、示例代码

muduo_net代码剖析之Acceptor相关推荐

最新文章

热门文章

1、Acceptor类`简介`

2、Acceptor`连接建立` /`处理时序图`

`Acceptor .h`头文件

① `构造函数`

② `Acceptor::listen()`，这个函数顾名思义，就是开始监听对端的连接请求

③ 设置连接建立成功后的回调函数：`setNewConnectionCallback`