話說回來呢，前段時間又重新看了一遍Muduo庫，嗯哼，把原來的框架又大概走了一遍，嗯對，僅僅是框架，還有說到最精華的部分，我想說以前我是發過一篇對Muduo庫的執行緒池的剖析（雖然說剖析的一般吧 = =！！！，但是畢竟是自己的心血啊），Muduo庫的記憶體池也是Muduo庫精華的一部分，當然，還有一個精華的部分我認為是Muduo庫的Buffer緩衝區，它運用了環形緩衝區以及vector制動拓長陣列的這一個性質，這裡覺得它運用的很巧妙有木有，WHY？我想說它這裡的環形緩衝區既保持瞭解決黏包問題緩衝區不夠的問題，同時vector又解決了緩衝區自動增長的問題，我想說陳碩在這方面考慮問題簡直就是天才！！！

當然還有什麼bind,function,shareptr,scoreptr,weakptr這些boost庫的東西在Muduo庫中也是巧妙的運用了，誒，陳碩簡直天才，媽蛋啊，把C++簡直運用得爐火純青，淋漓盡致，呃，感覺說了好多屁話吧，接下來開始進入重點！！！

OK，話不多說先上圖（這個沒圖不好表達啊！！）

好了好了，我們可以很明顯的從圖上看到我分了幾個部分對吧

TcpServer //代表的是一個總的伺服器的類，我們可以這麼理解它，我們並不知道伺服器內部大概要做什麼，我們只需要呼叫這個TcpServer就可以了，我們可以理解成它是一個伺服器入口吧。
TcpConnection //這裡是一個連線處理器把，能這麼理解吧，當accept接受了一條連線的話就會在這裡面進行處理，嗯哼，就是這樣
Acceptor

//這裡面是對Socket和一個Channel的一個一個封裝，我想理解它為一箇中間的處理器吧，大概能這麼理解吧，當然我們必須把Socket算進來，因為畢竟Acceptor封裝的是Socket
Socket //Socket本身是對socket、listen、bing、accept等伺服器函式進行的一個封裝
Channel //一個時間處理器，會把相關的對可讀可寫的事件處理函式回撥放入這個類中形成一個物件，就是相當於對事件處理方法封裝一下，假如epoll需要處理事件，會從Channel事件處理器中找到相應的方法對事件進行處理
Eventloop //可以理解成為事件分流處理器，把相關的事件處理器Channel註冊金epoll中，而假如epoll有反應則會呼叫Channle中相應的回撥函式，Eventloop底層呼叫的是poll或者epoll
Poll //只是一個抽象類，作為對呼叫的Epoll或者Poll的基類
EPollPoller //Poll的子類，是呼叫的epoll的一個封裝

我們得把Muduo庫分成四大塊，分別是以Acceptor為主的伺服器塊，TcpConnection的連線塊，Channel的事件塊以及以Eventloop為主的epoll監聽塊。

我們先從Tcpserver來分析一下吧
看下TcpServer中的成員

  EventLoop* loop_;  // the acceptor loop
  const string hostport_;  //埠
  const string name_;  //伺服器名字吧
  boost::scoped_ptr<Acceptor> acceptor_; // avoid revealing Acceptor  一個Acceptor物件
  boost::shared_ptr<EventLoopThreadPool> threadPool_; //執行緒池
  ConnectionCallback connectionCallback_;  //連接回調函式
  MessageCallback messageCallback_;  //連線到資訊的回撥函式
  WriteCompleteCallback writeCompleteCallback_;
  ThreadInitCallback threadInitCallback_;
  AtomicInt32 started_;

當然重要的成員物件我都寫在上面了，有了註釋。
我們再來看看TcpServer的建構函式

TcpServer::TcpServer(EventLoop* loop,
                     const InetAddress& listenAddr,
                     const string& nameArg,
                     Option option)
  : loop_(CHECK_NOTNULL(loop)),
    hostport_(listenAddr.toIpPort()),
    name_(nameArg),
    acceptor_(new Acceptor(loop, listenAddr, option == kReusePort)),
    threadPool_(new EventLoopThreadPool(loop)),
    connectionCallback_(defaultConnectionCallback),
    messageCallback_(defaultMessageCallback),
    nextConnId_(1)
{
  acceptor_->setNewConnectionCallback(
      boost::bind(&TcpServer::newConnection, this, _1, _2));
}

我們可以看到傳進來幾個引數，分別是EventLoop、InetAddress、string、Option
重點還是EventLoop和InetAddress，一個是事件分流器，而這個InetAddress呢則是對套接字地址sockaddr_in的一個封裝，我們把埠號和要繫結的IP地址傳進去即可。

EventLoopThreadPool這傢伙是個執行緒池，至於內部的結構希望看我對EventLoopThreadPool分析的那篇文章比較好吧。

TcpServer內部封裝了一個Accepror物件acceptor_，當然我們知道它是用scoped_ptr對它進行封裝的了。

ConnectionCallback connectionCallback_的作用是當accept接受到一個新的連線產生一個新的檔案描述符而創造了一個通訊套接字的時候，呼叫一下這個connectionCallback_回撥函式，當然這個函式內容可以你自己設計，可以讓你提取回調的TcpConnection 物件。

MessageCallback messageCallback_的作用是當通訊套接字接受到一個新的資訊的時候進行回撥，當然，這個回撥函式的內容也可以你自己去設計。

ConnectionCallback和MessageCallback 的回撥函式的引數都有固定格式，在這裡不是重點物件就不說了。

我們可以看到在建構函式中setNewConnectionCallback這個回撥函式呼叫了TcpServer::newConnection，嗯哼，這是一個什麼樣的函式呢？我們來看一下

void TcpServer::newConnection(int sockfd, const InetAddress& peerAddr)
{
  loop_->assertInLoopThread();
  //從io執行緒池中提取一條工作執行緒出來對accept的通訊socket進行處理
  EventLoop* ioLoop = threadPool_->getNextLoop();
  char buf[32];
  snprintf(buf, sizeof buf, ":%s#%d", hostport_.c_str(), nextConnId_);
  ++nextConnId_;
  string connName = name_ + buf;

  LOG_INFO << "TcpServer::newConnection [" << name_
           << "] - new connection [" << connName
           << "] from " << peerAddr.toIpPort();
  InetAddress localAddr(sockets::getLocalAddr(sockfd));
  // FIXME poll with zero timeout to double confirm the new connection
  // FIXME use make_shared if necessary
  //我們能從這裡看到它實際上是建立了一個TcpConnection，當accept接受到一個新的檔案描述符的時候，建立一個TcpConnection對它進行封裝
   TcpConnectionPtr conn(new TcpConnection(ioLoop,
                                          connName,
                                          sockfd,
                                          localAddr,
                                          peerAddr));
  //我們可以從這裡看出來是對新建立的TcpConnection的一些初始化
  connections_[connName] = conn;
  conn->setConnectionCallback(connectionCallback_);
  conn->setMessageCallback(messageCallback_);
  conn->setWriteCompleteCallback(writeCompleteCallback_);
  conn->setCloseCallback(
      boost::bind(&TcpServer::removeConnection, this, _1)); // FIXME: unsafe
  ioLoop->runInLoop(boost::bind(&TcpConnection::connectEstablished, conn));
}

當然，你可以從這裡看到了啊，這個函式實際上是對accpet新接受到一個通訊套接字以後把它放入到一個新創立的TcpConnection對這個通訊套接字做一個封裝，並將函式指標什麼的初始化，誒對咯，它在最後還呼叫了一個TcpConnection::connectEstablished這個函式，後面介紹到TcpConnection的時候我們會來介紹一下這個函式的作用，在這裡先大概介紹一下這個函式的作用就是將接受到的socket的檔案描述符註冊到epoll事件列表當中，HOHO，就是這樣。

當然TcpServer中還有第二個比較重要的函式，這個函式代表了伺服器的啟動，這個函式當然就是void TcpServer::start()了，我們來簡單的看一下這個函式的程式碼

void TcpServer::start()
{
  if (started_.getAndSet(1) == 0)
  {
  //對執行緒池的一個啟動處理
    threadPool_->start(threadInitCallback_);

    assert(!acceptor_->listenning());
    loop_->runInLoop(
    //當然這是呼叫了底層的listen監聽咯
    boost::bind(&Acceptor::listen, get_pointer(acceptor_)));
  }
}

這個函式啟動了，底層的listen()函式就相當於啟動了，所以我們可以暫時稱這是一個伺服器的開關吧！！！

/********************************************/
呃，總結一就先總結到這裡吧！