用 C++ boost::asio 写一个简易服务器

好的，以下是一个简单的使用 boost::asio 库编写的服务器示例：

#include <iostream>
#include <boost/asio.hpp>

using namespace boost::asio;
using namespace boost::asio::ip;

class Session : public std::enable_shared_from_this<Session> {
public:
    Session(tcp::socket socket) : socket_(std::move(socket)) {}

    void start() {
        do_read();
    }

private:
    void do_read() {
        auto self(shared_from_this());
        socket_.async_read_some(buffer(data_, max_length),
            [this, self](boost::system::error_code ec, std::size_t length) {
                if (!ec) {
                    do_write(length);
                }
            });
    }

    void do_write(std::size_t length) {
        auto self(shared_from_this());
        async_write(socket_, buffer(data_, length),
            [this, self](boost::system::error_code ec, std::size_t /*length*/) {
                if (!ec) {
                    do_read();
                }
            });
    }

    tcp::socket socket_;
    enum { max_length = 1024 };
    char data_[max_length];
};

class Server {
public:
    Server(io_service& ios, short port)
        : acceptor_(ios, tcp::endpoint(tcp::v4(), port)),
          socket_(ios) {
        do_accept();
    }

private:
    void do_accept() {
        acceptor_.async_accept(socket_,
            [this](boost::system::error_code ec) {
                if (!ec) {
                    std::make_shared<Session>(std::move(socket_))->start();
                }
                do_accept();
            });
    }

    tcp::acceptor acceptor_;
    tcp::socket socket_;
};

int main(int argc, char* argv[]) {
    try {
        if (argc != 2) {
            std::cerr << "Usage: server <port>" << std::endl;
            return 1;
        }

        io_service ios;
        Server s(ios, std::atoi(argv[1]));
        ios.run();
    } catch (std::exception& e) {
        std::cerr << "Exception: " << e.what() << std::endl;
    }

    return 0;
}

这个服务器使用了 boost::asio 库提供的异步 I/O 操作实现，它只会在有客户端连接时才会创建一个新的 Session 对象处理该客户端的请求，这样可以避免阻塞主线程。在 Session 对象中，我们使用了 async_read_some 和 async_write 这两个异步操作来处理客户端的读写请求，这样可以保证多个客户端之间互不干扰。最后，在 main 函数中，我们启动了一个 Server 对象，并调用了 io_service 的 run 方法来启动事件循环。