8
我試圖通過套接字將jpeg幀寫入客戶端,使用async_write()
。我以增強asynchronous TCP daytime server爲例作爲起點。boost :: asio :: async_write,寫入大於65536字節的數據
#include <ctime>
#include <iostream>
#include <string>
#include <boost/bind.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/enable_shared_from_this.hpp>
#include <boost/asio.hpp>
using boost::asio::ip::tcp;
std::string make_daytime_string()
{
using namespace std; // For time_t, time and ctime;
time_t now = time(0);
return ctime(&now);
}
class tcp_connection
: public boost::enable_shared_from_this<tcp_connection>
{
public:
typedef boost::shared_ptr<tcp_connection> pointer;
static pointer create(boost::asio::io_service& io_service)
{
return pointer(new tcp_connection(io_service));
}
tcp::socket& socket()
{
return socket_;
}
void start()
{
message_ = make_daytime_string();
boost::asio::async_write(socket_, boost::asio::buffer(message_),
boost::bind(&tcp_connection::handle_write, shared_from_this(),
boost::asio::placeholders::error,
boost::asio::placeholders::bytes_transferred));
}
private:
tcp_connection(boost::asio::io_service& io_service)
: socket_(io_service)
{
}
void handle_write(const boost::system::error_code& /*error*/,
size_t /*bytes_transferred*/)
{
}
tcp::socket socket_;
std::string message_;
};
class tcp_server
{
public:
tcp_server(boost::asio::io_service& io_service)
: acceptor_(io_service, tcp::endpoint(tcp::v4(), 13))
{
start_accept();
}
private:
void start_accept()
{
tcp_connection::pointer new_connection =
tcp_connection::create(acceptor_.io_service());
acceptor_.async_accept(new_connection->socket(),
boost::bind(&tcp_server::handle_accept, this, new_connection,
boost::asio::placeholders::error));
}
void handle_accept(tcp_connection::pointer new_connection,
const boost::system::error_code& error)
{
if (!error)
{
new_connection->start();
start_accept();
}
}
tcp::acceptor acceptor_;
};
int main()
{
try
{
boost::asio::io_service io_service;
tcp_server server(io_service);
io_service.run();
}
catch (std::exception& e)
{
std::cerr << e.what() << std::endl;
}
return 0;
}
我修改了執行如下async_write()
的方法:
void start()
{
// fileToVector method reads contents of file to vector;
std::vector<unsigned char> message_ = fileToVector("/tmp/test");
boost::asio::async_write(socket_, boost::asio::buffer(message_),
boost::bind(&tcp_connection::handle_write, shared_from_this(),
boost::asio::placeholders::error,
boost::asio::placeholders::bytes_transferred));
}
當讀取從使用客戶端與服務器的大文件時,服務器將只寫最多65536個字節。如果我用同步呼叫boost::asio::write()
替換boost::asio::async_write()
呼叫,則將正確的字節數傳送到客戶端。
所以我想我的問題是,如何使用boost::asio::async_write()
發送超過65536字節?任何幫助將不勝感激。
此外,還請注意傳輸文件ASIO的示例[link](http://www.boost.org/doc/libs/1_48_0/doc/html/boost_asio/example/windows/transmit_file.cpp)。在Linux中使用'TransmitFile' Windows函數或'sendfile'可以避免緩衝區分配的開銷。 – megabyte1024 2012-02-24 15:32:59
問題與您所描述的完全相同,緩衝區在async_write完成之前被銷燬。非常感謝答覆和答覆。 – 2012-02-28 12:10:07