async_read不读取从telnet发送的数据

这是我当前的服务器代码。我使用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我可以从远程登录发送的第一条消息和多数民众赞成它。

关于我在做什么的任何建议是错误的？
谢谢。

来源

2013-07-30 Kobe

async_read将读取长度参数中指定的字节数。您没有看到第一条消息，因为async_read仍在等待读取max_length字节。这question讨论类似的行为

来源

2013-07-30 13:40:27

如何在这里继续，如果async_read等待max_length字节，我只是想发送可以说3字节和5，然后10，我怎样才能打印所有消息从telnet发送，一一个而不是等待max_length？ – Kobe

@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），它会在调用处理程序时分隔符或大小已达到。 –

@DaveS：我尝试使用async_read_some方法，并且这只是打印我发送的第一条消息。所以，如果我从telnet输入“hello”，我会在我的服务器中收到消息，如果再次输入“world”，则不会打印，而我写入的所有其他消息都不会打印。所以只是第一个。 – Kobe

async_read不读取从telnet发送的数据

回答

相关问题