boost教程：http://zh.highscore.de/cpp/boost/

改写7.4网络编程案例，服务器支持连接多个客户端

服务端：

#include <iostream>

#include <string>

#include <boost/asio.hpp>

/// <summary>

/// 简单服务器，客户端连接就发送 HTTP/1.1 200 OK\r\nContent-Length: 13\r\n\r\nHello, world!

/// </summary>

boost::asio::io_context io;

boost::asio::ip::tcp::socket sock(io);

boost::asio::ip::tcp::endpoint endpoint(boost::asio::ip::tcp::v4(), 9076);

boost::asio::ip::tcp::acceptor acceptor(io, endpoint);

std::string data = "HTTP/1.1 200 OK\r\nContent-Length: 13\r\n\r\nHello, world!";

void accept_handler(const boost::system::error_code& ec)

{

    if (!ec)

　　{
        //如果有新客户端连接，需要将sock转移给新的客户端sock，原来的sock用于继续接收新客户端

        boost::asio::ip::tcp::socket client_sock(std::move(sock));

        client_sock.async_write_some(boost::asio::buffer(data), [](const boost::system::error_code& ec, std::size_t size) {});

   }

   acceptor.async_accept(sock, accept_handler);

}

int main()

{

    acceptor.listen();

    acceptor.async_accept(sock,accept_handler);

    io.run();

}                                

客户端：

#include <boost/asio.hpp>

#include <boost/array.hpp>

#include <iostream>

#include <string>

boost::asio::io_context io;

boost::asio::ip::tcp::socket sock(io);

boost::asio::ip::tcp::resolver resolver(io);

boost::array<char, 1024> buff;

void read_handler(const boost::system::error_code& ec, std::size_t size)

{

    //请留意，read_handler() 在将数据写出至 std::cout 之后，会再次调用 async_read_some() 方法。

    //这是必需的，因为无法保证仅在一次异步操作中就可以接收到整个网页。 async_read_some() 和 read_handler()

    //的交替调用只有当连接被破坏时才中止，如当 web 服务器已经传送完整个网页时。 这种情况下，在 read_handler() 内部将报告一个错误，

    // 以防止进一步将数据输出至标准输出流，以及进一步对该 socket 调用 async_read() 方法。 这时该例程将停止，因为没有更多的异步操作了。

    if (!ec)

    {

        std::cout << std::string(buff.data(), size) << std::endl;

        //客户端接收一次消息接收完就结束进程

        sock.async_read_some(boost::asio::buffer(buff), read_handler);

    }

    //客户端可以继续接收消息，不结束进程

    //sock.async_read_some(boost::asio::buffer(buff), read_handler);

}

void connect_handler(const boost::system::error_code& ec)

{

    if (!ec)

    {

        sock.async_read_some(boost::asio::buffer(buff), read_handler);

    }

}

void resolver_handler(const boost::system::error_code& ec, boost::asio::ip::tcp::resolver::iterator it)

{

    if (!ec)

    {

        sock.async_connect(*it, connect_handler);

    }

}

int main()

{

    boost::asio::ip::tcp::resolver::query query("127.0.0.1", "9076");

    resolver.async_resolve(query, resolver_handler);

    io.run();

}