先說說Epoll的ET模式

epoll預設的模式是LT，要說ET不得不提到LT，LT與ET的區別可以用一句話概括：
LT模式下只要socket處於可讀狀態(新增EPOLLIN事件時)或可寫狀態(新增EPOLLOUT事件時)，就會一直返回其socket。
ET模式下在第一次返回socket後，只有當socket由不可寫到可寫(新增EPOLLIN事件時)或由不可讀到可讀(新增EPOLLOUT事件時)，才會返回其socket。

進一步捋一下

由上可得，我們對ET操作必須要做到以下條件：
如果讀：必須要將緩衝區的內容全部讀出，即讀到緩衝區空為止
如果寫：一直寫，知道需寫的資料寫完或是緩衝區滿為止。
要做到以上要求，我們必須使用非阻塞套接字，否則socket會常常處在阻塞情況下，從而導致其他套接字餓死的情況發生。

(何謂餓死，程式阻塞在當前套接字的操作上，而其他套接字根本沒有機會進行操作)

為什麼我們需要Buffer

TCP 是一個無邊界的位元組流協議，接收方必須要處理“收到的資料尚不構成一條完整的訊息”和“一次收到兩條訊息的資料”等等情況。
如果是阻塞模式下，上面的情況根本不需要考慮，因為只要你recv，資料最終一定會過來，但代價就是你會一直阻塞在那裡，我們編寫伺服器當然要儘可能的避免這種情況的出現，所以我們使用非阻塞套接字。
然而，非阻塞模式下，我們就必須要解決上面的情況。
那麼，想想，如果給你一個記憶體空間，你讀取資料時，無論取多少，都先放進這個空間，而要處理時從這個空間取資料即可。

有了這個空間，無論是訊息不完整還是多個訊息，我們都得以解決。
寫也是一樣的，當你向socket傳送資料時，如果傳送了一部分，緩衝區滿了，此時我們該怎麼辦呢，只好一直阻塞，直至socket變回可寫，再將剩餘的資料全部寫入。顯然，代價還是阻塞，如果我們不想阻塞，仍然需要一個類似上面的空間。
這個空間，就是我們說的buffer，也可以叫做使用者緩衝區。

Buffer的實現思路

首先，我們希望保證任何時候向buffer裡面新增資料，都可以新增成功，也就是說，我們的buffer的空間需要足夠大，但我們又不能確定一個固定的數值，因為如果數字設定的小了，還是會出現新增失敗的情況，但如果設定的大了，又會導致大量空間的浪費。
所以我們將空間設定為可變的，用vector來儲存，因為vector空間增長是以2的冪的形式擴充套件，很高效。
用兩個指標或是變數來作為讀標誌和寫標誌，如下圖所示。

圖片摘自Muduo 設計與實現之一：Buffer 類的設計)

這張圖畫的相當的清晰明瞭，一目瞭然，就不再具體描述了。
另外有兩點優化，第一點是當Buffer內沒有資料的時候(也就是readindex=writeindex時)，要將兩個標誌全部歸零，以免空間一直無限制增長下去，前面的空間反而浪費了。
第二點是，要新增資料時，如果剩餘的空間不夠(writeable)，而加上前面空閒的空間(prependable+writeable)能夠放下的話，將資料移動到buffer起始位置，以避免一次空間的增長。

程式碼

//
//  Buffer.h
//  QuoridorServer
//
//  Created by shiyi on 2016/12/2.
//  Copyright © 2016年 shiyi. All rights reserved.
//

#ifndef Buffer_H
#define Buffer_H

#include <stdio.h>
#include <iostream>
#include <vector>

using namespace std;

class Buffer
{
public:
    Buffer() : m_widx(0), m_ridx(0)
    {}

    ~Buffer(){}

    void init()
    {
        m_widx = m_ridx = 0;
        m_buf.clear();
    }

    //增加內容
    void PutData(char *data, int len)
    {
        //如果調整空間後足夠存放，則進行調整
        int capa = m_buf.capacity();
        if(capa < m_widx + len && capa > len + m_widx - m_ridx)
            adjust();

        for(int i = 0; i < len; i++)
            m_buf.push_back(data[i]);

        m_widx += len;
    }

    //返回獲取的包的大小，資料不完整返回-1
    int GetData(char* data, int len)
    {
        len = min(m_widx-m_ridx, len);

        for(int i = 0; i < len; i++)
        {
            if(m_ridx >= m_widx)
                break;
            data[i] = m_buf[m_ridx++];
        }

        if(m_ridx >= m_widx)
        {
            m_ridx = m_widx = 0;
            m_buf.clear();
        }
        return len;
    }

private:

    //將資料移至容器頭部，充分利用空間
    void adjust()
    {
        vector<char> t(m_buf.begin()+m_ridx, m_buf.begin()+m_widx);
        m_widx -= m_ridx;
        m_ridx = 0;

        m_buf.clear();

        for(int i=0; i<m_widx; i++)
            m_buf.push_back(t[i]);
    }

private:

    int m_ridx;
    int m_widx;
    std::vector<char> m_buf;
};

#endif /* Buffer_H */