使用 boost.beast 创建 websocket 服务器

Question

我想创建简单的 boost.beast websocket 服务器，它接受连接保存指向它的指针，并且当有人连接时向每个连接的套接字发送消息。

我从 boost.beast async_server 示例中获取代码：https://github.com/vinniefalco/Beast/blob/master/example/websocket-server-async/websocket_server_async.cpp

并补充：

static std::vector<std::shared_ptr<connection>> server::players_connections;

和

void server::connection::send_message(std::string msg){
            boost::beast::ostream(buffer_) << msg;
            ws_.binary(ws_.got_binary());
            ws_.async_write(buffer_.data(),
                            strand_.wrap(std::bind(
                                    &connection::on_write,
                                    shared_from_this(),
                                    std::placeholders::_1)));
        }

在 void server::connection::on_read(error_code ec) 方法的末尾我添加了

 for(auto  player : server::players_connections){
                player->send_message("already accepted");
            }

并且在 server::connection::on_accept 结束时：

players_connections.push_back(std::make_shared<connection>(*this, ep_, std::move(sock_)));
        players_connections.back()->run();

当第二个套接字连接时出现此错误：

websocket-server-async: /usr/local/boost_1_64_0/boost/beast/websocket/detail/pausation.hpp:210: void boost::beast::websocket::detail::pausation::emplace(F&&) [with F = boost::beast::websocket::stream<boost::asio::basic_stream_socket<boost::asio::ip::tcp> >::write_some_op<boost::beast::buffer_prefix_view<boost::beast::consuming_buffers<boost::beast::basic_multi_buffer<std::allocator<char> >::const_buffers_type> >, boost::beast::websocket::stream<boost::asio::basic_stream_socket<boost::asio::ip::tcp> >::write_op<boost::beast::basic_multi_buffer<std::allocator<char> >::const_buffers_type, boost::asio::detail::wrapped_handler<boost::asio::io_service::strand, std::_Bind<std::_Mem_fn<void (server::connection::*)(boost::system::error_code)>(std::shared_ptr<server::connection>, std::_Placeholder<1>)>, boost::asio::detail::is_continuation_if_running> > >]: Assertion `! base_' failed.
Aborted

服务器完整修改代码：http://morse.swirski.name/pastes/vrv552rf2yc7fyyflxhejukjdpr4vxe

我错过了什么？

Answer 1

看起来这个错误是因为我在调用

ws_.async_write(buffer_.data(),
                            strand_.wrap(std::bind(
                                    &connection::on_write,
                                    shared_from_this(),
                                    std::placeholders::_1)));

连续两次这是导致问题的原因。我不确定为什么。我怀疑一个又一个调用的方法 do_read 导致了这个问题。我会提出任何建议。

Answer 2

有一个基于 Boost::Beast 的非阻塞 WebSocket 库可简化 WebSockets 集成。

它叫WebSockets-Callback.CPP available on GitHub。