0

我已经通过 boost.beast 编写了一个异步 websocket。但是当我尝试运行它时，我无法连接它。

服务器代码如下。当我尝试连接我的 websocket 服务器时，我的 chrome 显示连接状态。当我通过 VS2017 进行调试时，它永远不会遇到 run() 中的 lambda 表达式。


iListener::iListener( boost::asio::io_context& ioc,boost::asio::ip::tcp::endpoint endpoint)  : acceptor_(ioc), socket_(ioc) {

    boost::system::error_code ec;

    std::cout<<"iListener"<<std::endl;
    // Open the acceptor
    acceptor_.open(endpoint.protocol(), ec);
    if (ec) {
        // fail(ec, "open");
        return;
    }

    // Allow address reuse
    acceptor_.set_option(boost::asio::socket_base::reuse_address(true), ec);
    if (ec) {
        // fail(ec, "set_option");
        return;
    }

    // Bind to the server address
    acceptor_.bind(endpoint, ec);
    if (ec) {
        // fail(ec, "bind");
        return;
    }

    // Start listening for connections
    acceptor_.listen(
            boost::asio::socket_base::max_listen_connections, ec);
    if (ec) {

        std::cout << ec.message() << "   listen" << std::endl;
        // fail(ec, "listen");
        return;
    }
}

iListener::~iListener() {

}

void iListener::run() {
    if (!acceptor_.is_open()) {
        return;
    }
    std::cout<<"iListener run"<<std::endl;
    while (true) {
        acceptor_.async_accept(socket_, [&](boost::system::error_code ec1) {
            std::cout << "now run listener" << std::endl;
            if (ec1) {
                std::cout<<ec1.message()<<"   accept"<<std::endl;
                // fail(ec, "accept");
            } else {
                // Create the session and run it
                std::make_shared<NormalSession>(std::move(socket_))->run();
            }
        });
    }


}

void iListener::initListener(const std::string &addressStr, unsigned short port, int threads){
    auto const address = boost::asio::ip::make_address(addressStr);
    boost::asio::io_context ioc{threads};
    std::make_shared<iListener>(ioc, boost::asio::ip::tcp::endpoint{address, port})->run();
    std::vector<std::thread> v;
    v.reserve(threads - 1);
    for(auto i = threads - 1; i > 0; --i)
        v.emplace_back(
                [&ioc]
                {
                    ioc.run();
                });
    ioc.run();
}

当我尝试在 Chrome 的控制台上连接它时。连接需要很长时间，然后显示失败。

所以我改回来，作为 boost.It 的例子。


void iListener::run() {
    if (!acceptor_.is_open()) {
        return;
    }
   // std::cout<<"iListener run"<<std::endl;
   // while (true) {
   //     acceptor_.async_accept(socket_, [&](boost::system::error_code ec1) {
            //std::cout << "now run listener" << std::endl;
   //         if (ec1) {
   //             std::cout<<ec1.message()<<"   accept"<<std::endl;
   //             // fail(ec, "accept");
   //         } else {
   //             // Create the session and run it
   //             std::make_shared<NormalSession>(std::move(socket_))->run();
   //         }
   //     });
   // }
    do_accept();

}

void iListener::do_accept() {
    acceptor_.async_accept(
        socket_,
        std::bind(
            &iListener::on_accept,
            shared_from_this(),
            std::placeholders::_1));
}

void    iListener::on_accept(boost::system::error_code ec) {
    if (ec)
    {
        std::cout << ec.message() << "   on_accept" << std::endl;
    }
    else
    {
        // Create the session and run it
        std::make_shared<NormalSession>(std::move(socket_))->run();
    }

    // Accept another connection
    do_accept();
}

我有两个问题：

1.为什么我使用 lambda，它会 SOF ，但示例不会。2.当我使用while()时，它不起作用，为什么？lambda 表达式和 std::bind() 之间有什么不同吗？

那么另一个问题，下面的两个代码块有什么不同？

void iListener::do_accept() {
    acceptor_.async_accept(
        socket_,
        [&](boost::system::error_code ec1) mutable {
        on_accept(ec1);
    }
}


void iListener::do_accept() {
    acceptor_.async_accept(
        socket_,
        std::bind(
            &iListener::on_accept,
            shared_from_this(),
            std::placeholders::_1));
}

当我使用最上面的那个时，它返回 error_code 995。

4

1 回答 1

1

编辑

bind和 和有什么不一样lambda？在前者中，您可以延长iListener实例的生命周期，而在后者中，您不会。

我们需要从这一行开始：

std::make_shared<iListener>(ioc, boost::asio::ip::tcp::endpoint{address, port})->run();
// [a]

如果您不延长 in 的生命周期iListener，则runin [a] 行iListener实例将被销毁。

  • 标准::绑定

作为您传递的绑定参数之一shared_from_this，它shared_ptr从this指针创建，因此返回的函子对象bind保持指向iListener实例的智能指针延长了它的生命周期。

  • 拉姆达

的生命周期iListener没有延长，您调用async_accept传递 lambda 而不增加当前对象的引用计数器，do_accept即被调用的对象。所以async_accept立即返回，do_accept结束，最后run也结束，并且创建的对象std::make_shared<iListener>(ioc, boost::asio::ip::tcp::endpoint{address, port})被删除。

您需要通过将shared_ptr值传递给您的 lambda 来更新 ref 计数器：

void iListener::do_accept() {
    auto sp = shared_from_this();
    acceptor_.async_accept(
        socket_,
        [&,sp](boost::system::error_code ec1) mutable 
      {
        on_accept(ec1);
      }
}

async_accept由from启动的任务的处理程序（在您的情况下为 lambda 的主体）io_context::run，您看不到此执行，因为您的代码挂在此行：

std::make_shared<iListener>(ioc, boost::asio::ip::tcp::endpoint{address, port})->run();

这将创建包含无限循环且永不结束的iListener实例和调用：run

while (true) { // INFINITE LOOP
    acceptor_.async_accept(socket_, [&](boost::system::error_code ec1) {
        std::cout << "now run listener" << std::endl;
        if (ec1) {
            std::cout<<ec1.message()<<"   accept"<<std::endl;
            // fail(ec, "accept");
        } else {
            // Create the session and run it
            std::make_shared<NormalSession>(std::move(socket_))->run();
        }
    });
}

所以你无法到达io_context::run可以调用处理程序的开始行。

修复：在开始之前，io_context::run您可以启动另一个iListener::run执行的线程。

访问 Boost Asio示例以了解如何async_accept使用。常见的方法是async_accept从它的处理程序调用，但如果你想这样做，你iListener应该派生enable_shared_from_this来延长它的生命周期，当传递到处理程序时。

另一个问题是socket_数据成员。我假设您想在每个会话中保留一个套接字，但现在您的代码无法正确处理它。如果建立了新连接，您只有一个实例socket_被移入。NormalSession因此，当async_accept您第二次调用时，您将传递 INVALID 套接字。它不能工作。它会导致未定义的行为。

执行下面的行后

std::make_shared<NormalSession>(std::move(socket_))->run();

你可以忘记socket_。

async_accept重载，您可以将版本获取处理程序与新接受的套接字一起使用。

但是如果你想保留当前版本socket，你需要确保每次async_accept调用它都需要唯一的套接字实例。

于 2019-05-14T16:36:12.783 回答