2013-07-30 61 views
1

這是我當前的服務器代碼。我使用telnet連接到服務器。async_read不讀取從telnet發送的數據

#include <cstdlib> 
#include <iostream> 
#include <boost/bind.hpp> 
#include <boost/asio.hpp> 

using boost::asio::ip::tcp; 

class Connection 
{ 
public: 
    Connection(boost::asio::io_service& io_service) : socket_(io_service) 
    { 

    } 

    void start() 
    { 
     AsyncRead(); 
    } 

    tcp::socket& socket() 
    { 
     return socket_; 
    } 
private: 
    void AsyncRead() 
    { 
     boost::asio::async_read(socket_, boost::asio::buffer(data_, max_length), 
           [this](boost::system::error_code ec, std::size_t length) 
           { 
            if (!ec) 
            { 
             std::cout << data_ << std::endl; 
            } 
           }); 
    } 

    tcp::socket socket_; 
    enum { max_length = 1024 }; 
    char data_[max_length]; 
}; 


class server 
{ 
public: 
    server(boost::asio::io_service& io_service, short port) 
    : io_service_(io_service), 
     acceptor_(io_service, tcp::endpoint(tcp::v4(), port)) 
    { 
     start_accept(); 
    } 

private: 
    void start_accept() 
    { 
     Connection* connection = new Connection(io_service_); 
     acceptor_.async_accept(connection->socket(), [this, connection](boost::system::error_code ec) 
           { 
            //std::cout << ec.message() << std::endl; 
            if(!ec) 
            { 
             std::cout << "Connected." << std::endl; 
             connection->start(); 
            } 
            else 
            { 
             delete connection; 
            } 

            start_accept(); 
           }); 
    } 

    boost::asio::io_service& io_service_; 
    tcp::acceptor acceptor_; 
}; 

int main(int argc, char* argv[]) 
{ 
    try 
    { 
     boost::asio::io_service io_service; 

     server s(io_service, 7899); 

     io_service.run(); 
    } 
    catch (std::exception& e) 
    { 
     std::cerr << "Exception: " << e.what() << "\n"; 
    } 

    return 0; 
} 

而不是async_read我用async_read_some我可以從遠程登錄發送的第一條消息和多數民衆贊成它。

關於我在做什麼的任何建議是錯誤的?
謝謝。

回答

3

async_read將讀取長度參數中指定的字節數。您沒有看到第一條消息,因爲async_read仍在等待讀取max_length字節。這question討論類似的行爲

+0

如何在這裏繼續,如果async_read等待max_length字節,我只是想發送可以說3字節和5,然後10,我怎樣才能打印所有消息從telnet發送,一一個而不是等待max_length? – Kobe

+1

@vBx:最直接的方法是使用[tcp :: socket :: async_read_some()](http://www.boost.org/doc/libs/1_54_0/doc/html/booster_asio/reference/async_read_until/ overload1.html)方法,它在數據到達時調用處理函數。作爲替代,您可以使用[async_read_until()](http://www.boost.org/doc/libs/1_54_0/doc/html/boost_asio/reference/basic_stream_socket/async_read_some.html),它會在調用處理程序時分隔符或大小已達到。 –

+0

@DaveS:我嘗試使用async_read_some方法,並且這只是打印我發送的第一條消息。所以,如果我從telnet輸入「hello」,我會在我的服務器中收到消息,如果再次輸入「world」,則不會打印,而我寫入的所有其他消息都不會打印。所以只是第一個。 – Kobe