使用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))); 
     } 

在空隙服務器::連接:: on_read（ERROR_CODE EC）方法我已經添加

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

和在服務器::連接的端部的端部： ：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方法導致了這個問題。我會appriciate任何建議。