升壓ASIO狀態服務器設計

Question

我寫上boost::asio

1. 在這裏，我實例化一個Server擁有一個io_service
   
2. 服務器由server.start()方法，它調用Server::accept()啓動服務器應用程序，並創建一個新的Session甚至在它得到一個新的連接
3. 呼叫_acceptor.async_accept這就是設置調用Session::handler()方法能源部回調握手。

現在可以在獲得新客戶端之前創建套接字嗎？ ，並且在這段代碼中，在編寫了一個"Hello "消息後，會話被自動破壞，這在HTTP的情況下是好的，但是我想進行有狀態通信。所以套接字必須async_wait才能讀取，只需寫出這個"Hallo "即可。我也想知道這個設計是否可以？或者它有任何設計缺陷。

這裏去我的編譯代碼

〜

class Session: public boost::enable_shared_from_this<Session>, private boost::noncopyable{ 
    private: 
    size_t _id; 
    boost::asio::ip::tcp::socket _socket; 
    public: 
    typedef boost::shared_ptr<Session> pointer; 
    static pointer create(boost::asio::io_service& ios){ 
     return pointer(new Session(ios)); 
    } 
    private: 
    explicit Session(boost::asio::io_service& ios): _socket(ios){ 
    static size_t counter = 0; 
    _id = counter++; 
    std::cout << ">> Session " << id() << " constructing" << std::endl; 
    } 
    public: 
    void handler(const boost::system::error_code &ec){ 
     const std::string message = (boost::format("HTTP/1.1 200 OK\r\nContent-Length: %2%\r\n\r\nHello, %1%!") % id() % (7+boost::lexical_cast<std::string>(id()).length())).str(); 
     if(!ec){ 
     boost::asio::async_write(_socket, boost::asio::buffer(message), boost::bind(&Session::write_handler, this)); 
     }else{ 
     std::cout << ec.message() << std::endl; 
     } 
    } 
    void write_handler(){ 

    } 
    size_t id() const{ 
     return _id; 
    } 
    boost::asio::ip::tcp::socket& socket(){ 
     return _socket; 
    } 
    virtual ~Session(){ 
     std::cout << ">> Session " << id() << " destructing" << std::endl; 
    } 
    }; 

class Server: public boost::enable_shared_from_this<Server>, private boost::noncopyable{ 
    private: 
    boost::asio::io_service  _ios; 
    boost::asio::ip::tcp::acceptor _acceptor; 
    public: 
    explicit Server(boost::asio::ip::tcp::endpoint& endpoint):_acceptor(_ios, endpoint){ 

    } 
    void start(){ 
     accept(); 
     _ios.run(); 
    } 
    void accept(){ 
     std::cout << "accepting " << std::endl;; 
     Session::pointer session = Session::create(_ios); 
     _acceptor.async_accept(session->socket(), boost::bind(&Server::handler, this, session, boost::asio::placeholders::error)); 
    } 
    void handler(Session::pointer session, const boost::system::error_code &ec){ 
     if(!ec){ 
     session->handler(ec); 
     }else{ 
     //possible destroy session ? but how to destroy a shared pointer ? 
     } 
     accept(); 
    } 
}; 


int main(){ 
    const unsigned int port = 5050; 
    boost::asio::ip::tcp::endpoint endpoint(boost::asio::ip::tcp::v4(), port); 

    Server server(endpoint); 
    server.start(); 

    return 0; 
} 

Answer 1

整體設計看起來不錯，但也有少數實現錯誤：

• Session::handler()：message，基礎緩衝區提供async_write()，可能會在調用async_write()之前超出範圍。這違反了API所要求的保證。考慮使message成員變量爲Session，或在成員函數中使其成爲static。這是從文檔的相關摘錄：

  雖然可以根據需要複製緩衝區對象，底層的內存塊的所有權由調用者，後者必須保證它們有效，直到處理程序被調用保留。下面是從文檔的相關摘錄：

• 對於來自boost::enable_shared_from_this繼承對象，傳遞實例句柄boost::bind時使用shared_from_this()代替this指針。否則，可能會在處理程序運行之前刪除this指向的對象實例。

此外，爲了解決代碼註釋的問題Server::handler()內，如果發生錯誤，一旦處理程序返回，因爲它是通過boost::shared_ptr管理的Session將被刪除。