Acceptor连接

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; }void listen();bool listening() const { return listening_; }// Deprecated, use the correct spelling one above.// Leave the wrong spelling here in case one needs to grep it for error messages.// bool listenning() const { return listening(); }private:void handleRead();EventLoop* loop_;            //主线程LoopSocket acceptSocket_;      //监听连接的socketChannel acceptChannel_;    //上述socket对应的ChannelNewConnectionCallback newConnectionCallback_;   //accept()成功后执行的回调bool listening_;          //是否开启监听连接int idleFd_;              //用于处理busy-loop
};

构造函数

Acceptor::Acceptor(EventLoop* loop, const InetAddress& listenAddr, bool reuseport): loop_(loop),acceptSocket_(sockets::createNonblockingOrDie(listenAddr.family())),//创建一个非阻塞socket套接字acceptChannel_(loop, acceptSocket_.fd()),      //创建监听连接channellistening_(false),idleFd_(::open("/dev/null", O_RDONLY | O_CLOEXEC))   // 处理busy-loop
{assert(idleFd_ >= 0);acceptSocket_.setReuseAddr(true);     //地址复用acceptSocket_.setReusePort(reuseport);//根据参数设置端口复用 与上面一条结合在一起取消Time_wait状态acceptSocket_.bindAddress(listenAddr); //绑定地址acceptChannel_.setReadCallback(  //设置可读回调,服务器收到连接后执行的函数std::bind(&Acceptor::handleRead, this));
}

先创建了一个socket,然后用这个socket初始化acceptChannel_,并且打开了"/dev/null"被idleFd保存,但是在构造函数中并没有开始监听用户连接,这个操作被封装成为一个函数,在TcpServer::star()中调用

void Acceptor::listen()
{loop_->assertInLoopThread();listening_ = true;acceptSocket_.listen();          //启动listen() 监听连接acceptChannel_.enableReading();    //向loop中加入读事件回调 可读时调用handleRead
}

接下来看读回调

void Acceptor::handleRead()
{loop_->assertInLoopThread();    //是否在IO线程中InetAddress peerAddr; //struct sockaddr_in addr//FIXME loop until no moreint connfd = acceptSocket_.accept(&peerAddr);   //peerAddr用于获取对端的协议地址if (connfd >= 0){// string hostport = peerAddr.toIpPort();// LOG_TRACE << "Accepts of " << hostport;if (newConnectionCallback_) //连接回调,在TcpServer的构造函数中设置为 TcpServer::newConnection{newConnectionCallback_(connfd, peerAddr);   //把刚刚accept的cfd和addr传入}else{sockets::close(connfd);}}else       //连接失败处理{LOG_SYSERR << "in Acceptor::handleRead";// Read the section named "The special problem of// accept()ing when you can't" in libev's doc.// By Marc Lehmann, author of libev.if (errno == EMFILE){::close(idleFd_);idleFd_ = ::accept(acceptSocket_.fd(), NULL, NULL);::close(idleFd_);idleFd_ = ::open("/dev/null", O_RDONLY | O_CLOEXEC);}}
}

成功获取到客端连接后生成了fd再调用回调newConnectionCallback_(),该回调在TcpServer的构造函数中被设置.

这里说下不成功的操作,也就是busy-loop,这种情况是指该进程中的文件描述被耗尽了,故而返回错误号 errno == EMFILE

那么没们在构造函数中打开的一个文件描述符就可以派上用场了,我们关闭该描述然后再次accpet(),此时就可以成功接收到

客端的连接,然后再把客端的连接关闭,再次打开"/dev/null",就可以通知客端刚刚你发起的连接失败了

Muduo Acceptor连接类相关推荐

ADO.NET—数据提供程序(连接类)
.NET Framework 数据提供程序是专门为数据处理以及快速地只进.只读访问数据而设计的组件. 一.Connection 1.介绍开启程序和数据库之间的连结 ADO.NET底层可自己产生对象 ...
php连接电脑,PHP_深入理解php的MySQL连接类，无意间在电脑里发现还有这么 - phpStudy...
深入理解php的MySQL连接类无意间在电脑里发现还有这么个Mysql的连接类,也不记得哪里收藏的了,贴上来吧. 后面几个show_databases和show_tables....等方法都用了一堆 ...
boost::signals2模块实现连接类测试
boost::signals2模块实现连接类测试实现功能 C++实现代码实现功能 boost::signals2模块实现连接类测试 C++实现代码 #include <boost/signa ...
Ado.Net 实体类、数据连接类、数据访问类
建文件夹:定义数据连接类.数据访问类.实体类 using System; using System.Collections.Generic; using System.Linq; using Syst ...
pdo mysql连接类_PHP PDO-MYSQL：如何在不同类之间使用数据库连接
小编典典解决方案1 替换class account_info {为class account_info extends connection { 更换 $con = new connection() ...
php mysql 连接类_深入理解php的MySQL连接类
无意间在电脑里发现还有这么个Mysql的连接类,也不记得哪里收藏的了,贴上来吧. 后面几个show_databases和show_tables....等方法都用了一堆echo,好像一直不喜欢在类的方法 ...
mysql连接查询优点_1105 ROM优缺点,MySQL连接类,查插更方法
ROM 对象关系映射,映射到数据库中的数据表优点: 使用者不要关心SQL命令具体怎么编写直接调用方法,来执行对应的SQL命令缺点: 高级封装导致效率变低会忘记SQL语句 MySQL连接类 cl ...
公共数据库访问连接类
公共数据库访问连接类顾名思义,公共数据库访问连接类有三个特点: 1.公共的,所以在该类中的所有方法都是静态的,因此直接调用类名即可,无须再实例化. 2.数据库访问,要访问数据库 3.连接类,所以有一 ...
Python开发mysql和mongo 连接类
因为业务需求,需要连接数据库查询数据数据库类型:mysql,mongodb 需求:有中连机制,读取配置文件,可实例化,有日志记录配置文件 dbconfig.conf [Mongodbtest] h ...

Muduo Acceptor连接类

Acceptor连接

构造函数

Muduo Acceptor连接类相关推荐

最新文章

热门文章