通常服務器在處理客戶端連接請求時，為了不阻塞在accept函數上，會將監聽套接字注冊到io復用函數中，當客戶端請求連接時，監聽套接字變為可讀，隨后在回調函數調用accept接收客戶端連接。muduo將這一部分封裝成了Acceptor類，用于執行接收客戶端請求的任務。

---

類的定義如下，主要就是監聽套接字變為可讀的回調函數

class EventLoop; class InetAddress;/// /// Acceptor of incoming TCP connections. /// /* * 對TCP socket, bind, listen, accept的封裝 * 將sockfd以Channel的形式注冊到EventLoop的Poller中，檢測到sockfd可讀時，接收客戶端*/ class Acceptor : noncopyable {public:typedef std::function<void (int sockfd, const InetAddress&)> NewConnectionCallback;Acceptor(EventLoop* loop, const InetAddress& listenAddr, bool reuseport);~Acceptor();/* 由服務器TcpServer設置的回調函數，在接收完客戶端請求后執行，用于創建TcpConnection */void setNewConnectionCallback(const NewConnectionCallback& cb){ newConnectionCallback_ = cb; }bool listenning() const { return listenning_; }/* 調用listen函數，轉為監聽套接字，同時將監聽套接字添加到Poller中 */void listen();private:/* 回調函數，當有客戶端請求連接時執行（監聽套接字變為可讀） */void handleRead();/* 事件驅動主循環 */EventLoop* loop_;/* 封裝socket的一些接口 */Socket acceptSocket_;/* Channel，保存著sockfd，被添加到Poller中，等待被激活 */Channel acceptChannel_;/* * 當有客戶端連接時首先內部接收連接，然后調用的用戶提供的回調函數* 客戶端套接字和地址作為參數傳入*/NewConnectionCallback newConnectionCallback_;bool listenning_;/* * Tcp連接建立的流程* 1.服務器調用socket,bind,listen開啟監聽套接字監聽客戶端請求* 2.客戶端調用socket,connect連接到服務器* 3.第一次握手客戶端發送SYN請求分節（數據序列號）* 4.服務器接收SYN后保存在本地然后發送自己的SYN分節（數據序列號）和ACK確認分節告知客戶端已收到* 同時開啟第二次握手* 5.客戶端接收到服務器的SYN分節和ACK確認分節后保存在本地然后發送ACK確認分節告知服務器已收到* 此時第二次握手完成，客戶端connect返回* 此時，tcp連接已經建立完成，客戶端tcp狀態轉為ESTABLISHED，而在服務器端，新建的連接保存在內核tcp* 連接的隊列中，此時服務器端監聽套接字變為可讀，等待服務器調用accept函數取出這個連接* 6.服務器接收到客戶端發來的ACK確認分節，服務器端調用accept嘗試找到一個空閑的文件描述符，然后* 從內核tcp連接隊列中取出第一個tcp連接，分配這個文件描述符用于這個tcp連接* 此時服務器端tcp轉為ESTABLISHED，三次握手完成，tcp連接建立* * 服務器啟動時占用的一個空閑文件描述符，/dev/null,作用是解決文件描述符耗盡的情況* 原理如下：* 當服務器端文件描述符耗盡，當客戶端再次請求連接，服務器端由于沒有可用文件描述符* 會返回-1，同時errno為EMFILE，意為描述符到達hard limit，無可用描述符，此時服務器端* accept函數在獲取一個空閑文件描述符時就已經失敗，還沒有從內核tcp連接隊列中取出tcp連接* 這會導致監聽套接字一直可讀，因為tcp連接隊列中一直有客戶端的連接請求* * 所以服務器在啟動時打開一個空閑描述符/dev/null(文件描述符)，先站著'坑‘，當出現上面* 情況accept返回-1時，服務器暫時關閉idleFd_讓出'坑'，此時就會多出一個空閑描述符* 然后再次調用accept接收客戶端請求，然后close接收后的客戶端套接字，優雅的告訴* 客戶端關閉連接，然后再將'坑'占上*/int idleFd_;};

一個不好理解的變量是idleFd_;，它是一個文件描述符，這里是打開"/dev/null"文件后返回的描述符，用于解決服務器端描述符耗盡的情況。
如果當服務器文件描述符耗盡后，服務器端accept還沒等從tcp連接隊列中取出連接請求就已經失敗返回了，此時內核tcp隊列中一直有客戶端請求，內核會一直通知監聽套接字，導致監聽套接字一直處于可讀，在下次直接poll函數時會直接返回。
解決的辦法就是在服務器剛啟動時就預先占用一個文件描述符，通?？梢允谴蜷_一個文件，這里是"/dev/null"。此時服務器就有一個空閑的文件描述符了，當出現上述情況無法取得tcp連接隊列中的請求時，先關閉這個文件讓出一個文件描述符，此時調用accept函數再次接收，由于已經有一個空閑的文件描述符了，accept會正常返回，將連接請求從tcp隊列中取出，然后優雅的關閉這個tcp連接（調用close函數），最后再打開"/dev/null"這個文件把”坑“占住。

---

成員函數的實現也有比較重點的地方，首先是構造函數

Acceptor::Acceptor(EventLoop* loop, const InetAddress& listenAddr, bool reuseport): loop_(loop),acceptSocket_(sockets::createNonblockingOrDie(listenAddr.family())),acceptChannel_(loop, acceptSocket_.fd()),listenning_(false),idleFd_(::open("/dev/null", O_RDONLY | O_CLOEXEC)) {assert(idleFd_ >= 0);/* * setsockopt設置套接字選項SO_REUSEADDR，對于端口bind，如果這個地址/端口處于TIME_WAIT，也可bind成功* int flag = 1;* setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &flag, sizeof(flag));*/acceptSocket_.setReuseAddr(true);/** setsockopt設置套接字選項SO_REUSEPORT，作用是對于多核cpu，允許在同一個<ip, port>對上運行多個相同服務器* 內核會采用負載均衡的的方式分配客戶端的連接請求給某一個服務器*/acceptSocket_.setReusePort(reuseport);acceptSocket_.bindAddress(listenAddr);/* Channel設置讀事件的回調函數，此時還沒有開始監聽這個Channel，需要調用Channel::enableReading() */acceptChannel_.setReadCallback(std::bind(&Acceptor::handleRead, this)); }

構造函數中為用于監聽的套接字設置了SO_REUSEPORT和SO_REUSEADDR屬性，一個是端口重用，一個是地址重用。

• SO_REUSEPORT，端口重用，可以使用還處于TIME_WAIT狀態的端口
• SO_REUSEADDR，地址重用，服務器可以同時建立多個用于監聽的socket，每個socket綁定的地址端口都相同，內核會采用負載均衡的方法將每個將每個客戶端請求分配給某一個socket，可以很大程序的提高并發性，充分利用CPU資源

acceptChannel_用于保存這個用于監聽的套接字，綁定回調函數，在合適的時機注冊到Poller上（調用listen時）

void Acceptor::listen() {loop_->assertInLoopThread();listenning_ = true;acceptSocket_.listen();/* * 開始監聽Channel，也就是設置fd關心的事件(EPOLLIN/EPOLLOUT等)，然后添加到Poller中 * Poller中保存著所有注冊到EventLoop中的Channel*/acceptChannel_.enableReading(); }

比較重要的是事件處理函數，當監聽套接字可讀時，調用accept接收客戶端請求，如果描述符耗盡，釋放idleFd_重新accept，然后關閉，再占用idleFd_

/** 當有客戶端嘗試連接服務器時，監聽套接字變為可讀，epoll_wait/poll返回* EventLoop處理激活隊列中的Channel，調用對應的回調函數* 監聽套接字的Channel的回調函數是handleRead()，用于接收客戶端請求*/ void Acceptor::handleRead() {loop_->assertInLoopThread();InetAddress peerAddr;//FIXME loop until no moreint connfd = acceptSocket_.accept(&peerAddr);if (connfd >= 0){// string hostport = peerAddr.toIpPort();// LOG_TRACE << "Accepts of " << hostport;/* * 如果設置了回調函數，那么就調用，參數是客戶端套接字和地址/端口* 否則就關閉連接，因為并沒有要處理客戶端的意思* * 這個回調函數是TcpServer中的newConnection，用于創建一個TcpConnection連接*/if (newConnectionCallback_){newConnectionCallback_(connfd, peerAddr);}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.// /* 解決服務器端描述符耗盡的情況，原因見.h文件 */if (errno == EMFILE){::close(idleFd_);idleFd_ = ::accept(acceptSocket_.fd(), NULL, NULL);::close(idleFd_);idleFd_ = ::open("/dev/null", O_RDONLY | O_CLOEXEC);}} }

對文件描述符耗盡的處理比較重要，以前沒怎么接觸過

---

回調函數中調用的newConnectionCallback_函數是在Acceptor創建之初由TcpServer設置的（TcpServer表示服務器，內有一個監聽類Acceptor），這個函數主要用于初始化一個TcpConnection，一個TcpConnection對象代表著一個tcp連接

TcpConnection的定義主要都是寫set*函數，成員變量比較多，但是重要的就

• 事件驅動循環loop_
• 用于tcp通信的socket_
• 用于監聽sockfd的channel_
• 輸入輸出緩沖區inputBuffer_/outputBuffer_
• 由TcpServer提供的各種回調函數

/* 事件驅動循環 */EventLoop* loop_;/* 每個tcp連接有一個獨一無二的名字，建立連接時由TcpServer傳入 */const string name_;StateE state_; // FIXME: use atomic variablebool reading_;// we don't expose those classes to client./* 用于tcp連接的套接字，以及用于監聽套接字的Channel */std::unique_ptr<Socket> socket_;std::unique_ptr<Channel> channel_;/* 本地<地址，端口>，客戶端<地址，端口>，由TcpServer傳入 */const InetAddress localAddr_;const InetAddress peerAddr_;/* 連接建立后/關閉后的回調函數，通常是由用戶提供給TcpServer，然后TcpServer提供給TcpConnection */ConnectionCallback connectionCallback_;/* 當tcp連接有消息通信時執行的回調函數，也是由用戶提供 */MessageCallback messageCallback_;/* * 寫入tcp緩沖區之后的回調函數* 通常是tcp緩沖區滿然后添加到應用層緩沖區后，由應用層緩沖區寫入內核tcp緩沖區* 后執行，一般用戶不關系這部分*/WriteCompleteCallback writeCompleteCallback_;/* 高水位回調，設定緩沖區接收大小，如果應用層緩沖區堆積的數據大于某個給定值時調用 */HighWaterMarkCallback highWaterMarkCallback_;/* * tcp連接關閉時調用的回調函數，由TcpServer設置，用于TcpServer將這個要關閉的TcpConnection從* 保存著所有TcpConnection的map中刪除* 這個回調函數和TcpConnection自己的handleClose不同，后者是提供給Channel的，函數中會使用到* closeCallback_*/CloseCallback closeCallback_;/* 高水位值 */size_t highWaterMark_;/* 輸入輸出緩沖區 */Buffer inputBuffer_;Buffer outputBuffer_; // FIXME: use list<Buffer> as output buffer.boost::any context_;// FIXME: creationTime_, lastReceiveTime_// bytesReceived_, bytesSent_

---

首先是構造函數的實現，主要是為Channel提供各種回調函數

/* * 構造函數，設置當fd就緒時調用的回調函數* Channel代表一個對fd事件的監聽*/ TcpConnection::TcpConnection(EventLoop* loop,const string& nameArg,int sockfd,const InetAddress& localAddr,const InetAddress& peerAddr): loop_(CHECK_NOTNULL(loop)),name_(nameArg),state_(kConnecting),reading_(true),socket_(new Socket(sockfd)),channel_(new Channel(loop, sockfd)),localAddr_(localAddr),peerAddr_(peerAddr),highWaterMark_(64*1024*1024) {/* 設置各種回調函數 */channel_->setReadCallback(std::bind(&TcpConnection::handleRead, this, _1));channel_->setWriteCallback(std::bind(&TcpConnection::handleWrite, this));channel_->setCloseCallback(std::bind(&TcpConnection::handleClose, this));channel_->setErrorCallback(std::bind(&TcpConnection::handleError, this));LOG_DEBUG << "TcpConnection::ctor[" << name_ << "] at " << this<< " fd=" << sockfd;/** 設置KEEP-ALIVE屬性，如果客戶端很久沒有和服務器通訊，tcp會自動判斷客戶端是否還處于連接（類似心跳包）* * int setsockopt(fd, SOL_SOCKET, SO_KEEPALIVE, &sockopt, static_cast<socklen_t>(sizeof(sockopt)));*/socket_->setKeepAlive(true); }

回調函數的設置對應了Channel的hanleEvent函數中根據不同激活原因調用不同回調函數（handleEvent調用handleEventWithGuard）。
另外，handleEvent中的tie_是對TcpConnection的弱引用（在后面設置），因為回調函數都是TcpConnection的，所以在調用之前需要確保TcpConnection沒有被銷毀，所以將tie_提升為shared_ptr判斷TcpConnection是否還存在，之后再調用TcpConnection的一系列回調函數

/** 根據fd激活事件的不同，調用不同的fd的回調函數*/ void Channel::handleEvent(Timestamp receiveTime) {/* * RAII，對象管理資源* weak_ptr使用lock提升成shared_ptr，此時引用計數加一* 函數返回，?？臻g對象銷毀，提升的shared_ptr guard銷毀，引用計數減一*/std::shared_ptr<void> guard;if (tied_){guard = tie_.lock();if (guard){handleEventWithGuard(receiveTime);}}else{handleEventWithGuard(receiveTime);} }/** 根據被激活事件的不同，調用不同的回調函數*/ void Channel::handleEventWithGuard(Timestamp receiveTime) {eventHandling_ = true;LOG_TRACE << reventsToString();if ((revents_ & POLLHUP) && !(revents_ & POLLIN)){if (logHup_){LOG_WARN << "fd = " << fd_ << " Channel::handle_event() POLLHUP";}if (closeCallback_) closeCallback_();}if (revents_ & POLLNVAL){LOG_WARN << "fd = " << fd_ << " Channel::handle_event() POLLNVAL";}if (revents_ & (POLLERR | POLLNVAL)){if (errorCallback_) errorCallback_();}if (revents_ & (POLLIN | POLLPRI | POLLRDHUP)){if (readCallback_) readCallback_(receiveTime);}if (revents_ & POLLOUT){if (writeCallback_) writeCallback_();}eventHandling_ = false; }

---

當TcpServer創建完TcpConnection后，會設置各種會調用書，然后調用TcpConnection的connectEstablished函數，主要用于將Channel添加到Poller中，同時調用用戶提供的連接建立成功后的回調函數
TcpServer創建并設置TcpConnection的部分，可以看到，TcpServer會將用戶提供的所有回調函數都傳給TcpConnection，然后執行TcpConnection的connectEstablished函數，這個函數的執行要放到它所屬的那個事件驅動循環線程做，不要阻塞TcpServer線程（這個地方不是為了線程安全性考慮，因為TcpConnection本身就是在TcpServer線程創建的，暴露給TcpServer線程很正常，而且TcpServer中也記錄著所有創建的TcpConnection，這里的主要目的是不阻塞TcpServer線程，讓它繼續監聽客戶端請求）

/* ... *//* 從事件驅動線程池中取出一個線程給TcpConnection */EventLoop* ioLoop = threadPool_->getNextLoop();/* ... *//* 創建一個新的TcpConnection代表一個Tcp連接 */TcpConnectionPtr conn(new TcpConnection(ioLoop,connName,sockfd,localAddr,peerAddr));/* 添加到所有tcp連接的map中，鍵是tcp連接獨特的名字（服務器名+客戶端<地址，端口>） */connections_[connName] = conn;/* 為tcp連接設置回調函數（由用戶提供） */conn->setConnectionCallback(connectionCallback_);conn->setMessageCallback(messageCallback_);conn->setWriteCompleteCallback(writeCompleteCallback_);/* * 關閉回調函數，由TcpServer設置，作用是將這個關閉的TcpConnection從map中刪除* 當poll返回后，發現被激活的原因是EPOLLHUP，此時需要關閉tcp連接* 調用Channel的CloseCallback，進而調用TcpConnection的handleClose，進而調用removeConnection*/conn->setCloseCallback(std::bind(&TcpServer::removeConnection, this, _1)); // FIXME: unsafe/* * 連接建立后，調用TcpConnection連接建立成功的回調函數，這個函數會調用用戶提供的回調函數* 1.新建的TcpConnection所在事件循環是在事件循環線程池中的某個線程* 2.所以TcpConnection也就屬于它所在的事件驅動循環所在的那個線程* 3.調用TcpConnection的函數時也就應該在自己所在線程調用* 4.所以需要調用runInLoop在自己的那個事件驅動循環所在線程調用這個函數*/ioLoop->runInLoop(std::bind(&TcpConnection::connectEstablished, conn));

connectEstablished函數如下

/* * 1.創建服務器(TcpServer)時，創建Acceptor，設置接收到客戶端請求后執行的回調函數* 2.Acceptor創建監聽套接字，將監聽套接字綁定到一個Channel中，設置可讀回調函數為Acceptor的handleRead* 3.服務器啟動，調用Acceptor的listen函數創建監聽套接字，同時將Channel添加到Poller中* 4.有客戶端請求連接，監聽套接字可讀，Channel被激活，調用可讀回調函數(handleRead)* 5.回調函數接收客戶端請求，獲得客戶端套接字和地址，調用TcpServer提供的回調函數(newConnection)* 6.TcpServer的回調函數中創建TcpConnection代表這個tcp連接，設置tcp連接各種回調函數(由用戶提供給TcpServer)* 7.TcpServer讓tcp連接所屬線程調用TcpConnection的connectEstablished* 8.connectEstablished開啟對客戶端套接字的Channel的可讀監聽，然后調用用戶提供的回調函數*/ void TcpConnection::connectEstablished() {loop_->assertInLoopThread();assert(state_ == kConnecting);setState(kConnected);/* Channel中對TcpConnection的弱引用在這里設置 */channel_->tie(shared_from_this());/* 設置對可讀事件的監聽，同時將Channel添加到Poller中 */channel_->enableReading();/* 用戶提供的回調函數，在連接建立成功后調用 */connectionCallback_(shared_from_this()); }

至此tcp連接建立完成，在用戶提供的回調函數中，傳入的參數便是這個TcpConnection的shared_ptr，用戶可以使用TcpConnection::send操作向客戶端發送消息（放到后面）

---

有連接的建立就有連接的關閉，當客戶端主動關閉（調用close）時，服務器端對應的Channel被激活，激活原因為EPOLLHUP，表示連接已關閉，此時會調用TcpConnection的回調函數handleClose，在這個函數中，TcpConnection處理執行各種關閉動作，包括

• 將Channel從Poller中移除
• 調用TcpServer提供的關閉回調函數，將自己從TcpServer的tcp連接map中移除
• 調用客戶提供的關閉回調函數（如果有的話）

void TcpConnection::handleClose() {loop_->assertInLoopThread();LOG_TRACE << "fd = " << channel_->fd() << " state = " << stateToString();assert(state_ == kConnected || state_ == kDisconnecting);// we don't close fd, leave it to dtor, so we can find leaks easily.setState(kDisconnected);channel_->disableAll();/* 此時當前的TcpConnection的引用計數為2，一個是guardThis，另一個在TcpServer的connections_中 */TcpConnectionPtr guardThis(shared_from_this());connectionCallback_(guardThis);// must be the last line/* * closeCallback返回后，TcpServer的connections_(tcp連接map）已經將TcpConnection刪除，引用計數變為1* 此時如果函數返回，guardThis也會被銷毀，引用計數變為0，這個TcpConnection就會被銷毀* 所以在TcpServer::removeConnectionInLoop使用bind將TcpConnection生命期延長，引用計數加一，變為2* 就算guardThis銷毀，引用計數仍然有1個* 等到調用完connectDestroyed后，bind綁定的TcpConnection也會被銷毀，引用計數為0，TcpConnection析構*/closeCallback_(guardThis); }

connectionCallback_是由用戶提供的，連接建立/關閉時調用，主要調用closeCallback_函數（由TcpServer）提供
這個函數主要就存在線程不安全的問題，原因就是此時的線程是TcpConnection所在線程
函數執行順序為：
EventLoop::loop->Poller::poll->Channel::handleEvent->TcpConnection::handleClose->TcpServer::removeConnection
此時就將TcpServer暴露給其他線程，導致線程不安全的問題
為了減輕線程不安全帶來的危險，盡量將線程不安全的函數縮短，muduo中使用runInLoop直接將要調用的函數放到自己線程執行，轉換到線程安全，所以這部分只有這一條語句是線程不安全的

void TcpServer::removeConnection(const TcpConnectionPtr& conn) {// FIXME: unsafe/* * 在TcpConnection所在的事件驅動循環所在的線程執行刪除工作* 因為需要操作TcpServer::connections_，就需要傳TcpServer的this指針到TcpConnection所在線程* 會導致將TcpServer暴露給TcpConnection線程，也不具有線程安全性* * TcpConnection所在線程：在創建時從事件驅動循環線程池中選擇的某個事件驅動循環線程* TcpServer所在線程：事件驅動循環線程池所在線程，不在線程池中* * 1.調用這個函數的線程是TcpConnection所在線程，因為它被激活，然后調用回調函數，都是在自己線程執行的* 2.而removeConnection的調用者TcpServer的this指針如今在TcpConnection所在線程* 3.如果這個線程把this指針delele了，或者改了什么東西，那么TcpServer所在線程就會出錯* 4.所以不安全* * 為什么不在TcpServer所在線程執行以滿足線程安全性(TcpConnection就是由TcpServer所在線程創建的)* 1.只有TcpConnection自己知道自己什么時候需要關閉，TcpServer哪里會知道* 2.一旦需要關閉，就必定需要將自己從TcpServer的connections_中移除，還是暴露了TcpServer* 3.這里僅僅讓一條語句變為線程不安全的，然后直接用TcpServer所在線程調用刪除操作轉為線程安全*/loop_->runInLoop(std::bind(&TcpServer::removeConnectionInLoop, this, conn)); }

removeConnectionInLoop函數如下

/* * 這個函數是線程安全的，因為是由TcpServer所在事件驅動循環調用的*/ void TcpServer::removeConnectionInLoop(const TcpConnectionPtr& conn) {loop_->assertInLoopThread();LOG_INFO << "TcpServer::removeConnectionInLoop [" << name_<< "] - connection " << conn->name();size_t n = connections_.erase(conn->name());(void)n;assert(n == 1);EventLoop* ioLoop = conn->getLoop();/* * 為什么不能用runInLoop, why? *//* * std::bind綁定函數指針，注意是值綁定，也就是說conn會復制一份到bind上* 這就會延長TcpConnection生命期，否則* 1.此時對于TcpConnection的引用計數為2，參數一個，connections_中一個* 2.connections_刪除掉TcpConnection后，引用計數為1* 3.removeConnectionInLoop返回，上層函數handleClose返回，引用計數為0，會被析構* 4.bind會值綁定，conn復制一份，TcpConnection引用計數加1，就不會導致TcpConnection被析構*/ioLoop->queueInLoop(std::bind(&TcpConnection::connectDestroyed, conn)); }

比較重要的地方是TcpConnection生命期的問題，注釋中也有提及。因為muduo中對象使用智能指針shared_ptr存儲的，所以只有當shard_ptr的引用計數為0時才會析構它保存的對象。對于TcpConnection而言，它的引用計數在

建立之初保存在TcpServer的connections_中，這個connections_是一個map，鍵是字符串類型，值就是shared_ptr<TcpConnection>類型，所以建立之初，TcpConnection對象的引用計數為1

創建TcpConnection后，TcpConnection為內部用于監聽文件描述符sockfd的Channel傳遞保存著自己指針的shared_ptr，但是Channel中的智能指針是以weak_ptr的形式存在的（tie_），不增加引用計數，所以此時仍然是1

在TcpConnection處于連接創建的過程中未有shared_ptr的創建和銷毀，所以仍然是1

客戶端主動關閉連接后，服務器端的TcpConnection在handleClose函數中又創建了一個shared_ptr引用自身的局部變量，此時引用計數加一，變為2

緊接著調用TcpServer::removeConnectionInLoop函數，因為傳入的參數是引用類型，不存在賦值，所以引用計數仍為2

在removeConnectionInLoop函數中，TcpServer將TcpConnection從自己的connections_（保存所有tcp連接的map）中刪除，此時引用計數減一，變為1

TcpServer通過std::bind綁定函數指針，將TcpConnection::connectDestroyed函數和TcpConnection對象綁定并放到EventLoop中等待調用，因為std::bind只能是賦值操作，所以引用計數加一，變為2

返回到handleClose函數中，函數返回，局部變量銷毀，引用計數減一，變為1

EventLoop從poll中返回，執行TcpConnection::connectDestroyed函數，做最后的清理工作，函數返回，綁定到這個函數上的TcpConnection對象指針也跟著銷毀，引用計數減一，變為0

開始調用TcpConnection析構函數，TcpConnection銷毀

所以如果在第7步不使用std::bind增加TcpConnection生命期的話，TcpConnection可能在handleClose函數返回后就銷毀了，根本不能執行TcpConnection::connectDestroyed函數

總結

以上是生活随笔為你收集整理的muduo网络库学习（五）服务器监听类Acceptor及Tcp连接TcpConnection的建立与关闭的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。