工作代码片段-boost::asio

同步服务端：

    boost::timer tm;
    io_service is;
    ip::tcp::acceptor acceptor(is, ip::tcp::endpoint(ip::tcp::v4(), 8000));
    for(;;) {
        ip::tcp::socket so(is);
        acceptor.accept(so);
        char buf[501];
        error_code ec;
        so.read_some(buffer(buf), ec);
        buf[500] = '\0';
        cout << buf << endl;
        cout << "all time:"<<tm.elapsed() << endl;
    }

同步客户端：

    io_service is;
    ip::tcp::socket socket(is);
    ip::tcp::endpoint  ep(ip::address_v4::from_string("192.168.3.33"), 8000);

    socket.connect(ep);
    error_code ec;
    char buff[500];
    memset(buff, '9', 500);
    socket.write_some(buffer(buff, 500), ec);
    return NULL;

异步服务端：

    io_service is;
    ip::tcp::acceptor ac(is, ip::tcp::endpoint(ip::tcp::v4(), 8000));

    boost::shared_ptr<ip::tcp::socket> psocket(new ip::tcp::socket(is));
    ac.async_accept(*psocket, boost::bind(accept_f, psocket, _1));
    is.run();

void accept_f(boost::shared_ptr<ip::tcp::socket> pso, error_code ec)
{
 std::cout << pso->remote_endpoint().address() << std::endl;
 boost::shared_ptr<string> pstr(new string("999999999999999999999999"));
 psocket->async_write_some(buffer(*pstr), boost::bind(write_f, pstr, _1, _2));
}
void write_f(boost::shared_ptr<std::string> pstr, error_code ec,
 size_t bytes_transferred)
{
}