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
我可以從遠程登錄發送的第一條消息和多數民衆贊成它。
關於我在做什麼的任何建議是錯誤的?
謝謝。
如何在這裏繼續,如果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