Блог

Все примеры, которые я видел, используют boost::asio в основной функции следующим образом:

 int main()
{
    boost::asio::io_service io_service;
    server server1(io_service, 1980);   
    boost::thread t(boost::bind(amp;io_service::run, amp;io_service));
    
    return 0;
}
  

Как я могу использовать их в качестве переменных класса?

 class TcpConnect
{
private:
    boost::asio::io_service io_service;
    server server1;
    boost::thread t;

    void initBoost() // I want to create a boost thread in this function
}
  

Это определение файла сервера:

 class session
{
public:
    session(boost::asio::io_serviceamp; io_service)
        : socket_(io_service)
    {
    }
    
    tcp::socketamp; socket()
    {
        return socket_;
    }
    
    void start()
    {
        socket_.async_read_some(boost::asio::buffer(data_, max_length),
            boost::bind(amp;session::handle_read, this,
                boost::asio::placeholders::error,
            boost::asio::placeholders::bytes_transferred));
    }
    
    void handle_read(const boost::system::error_codeamp; error,
        size_t bytes_transferred)
    {
        if (!error)
        {
            boost::asio::async_write(socket_,
                boost::asio::buffer(data_, bytes_transferred),
                boost::bind(amp;session::handle_write, this,
                boost::asio::placeholders::error));
        }
        else
        {
            delete this;
        }
    }
    
    void handle_write(const boost::system::error_codeamp; error)
    {
        if (!error)
        {
            socket_.async_read_some(boost::asio::buffer(data_, max_length),
                boost::bind(amp;session::handle_read, this,
                    boost::asio::placeholders::error,
                    boost::asio::placeholders::bytes_transferred));
        }
        else
        {
            delete this;
        }
    }
    
private:
    tcp::socket socket_;
    enum { max_length = 1024 };
    char data_[max_length];
};
    
class server
{
public:
    server(boost::asio::io_serviceamp; io_service, short port)
        : io_service_(io_service),
        acceptor_(io_service, tcp::endpoint(tcp::v4(), port))
    {
        session* new_session = new session(io_service_);
        acceptor_.async_accept(new_session->socket(),
            boost::bind(amp;server::handle_accept, this, new_session,
                boost::asio::placeholders::error));
    }
    
    void handle_accept(session* new_session,
        const boost::system::error_codeamp; error)
    {
        if (!error)
        {
            new_session->start();
            new_session = new session(io_service_);
            acceptor_.async_accept(new_session->socket(),
                boost::bind(amp;server::handle_accept, this, new_session,
                    boost::asio::placeholders::error));
        }
        else
        {
            delete new_session;
        }
    }
    
private:
    boost::asio::io_serviceamp; io_service_;
    tcp::acceptor acceptor_;
};