C++ websocket客户端没有接收回调

Question

我们有一个用 C# 编写的 WebSocket 服务器和客户端。服务器被设计为根据客户端读取和处理消息的快/慢来减慢速度。 C# 客户端一次读取一条消息。

我正在寻找用 C++ 编写一个客户端，到目前为止我查看的所有库都有一个用于从服务器接收消息的消息处理程序或回调机制。

这意味着客户端连续接收消息，将其排队，然后客户端从队列中读取消息。这不是我们正在寻找的行为。我们要求客户端读取一条消息并处理它，处理完成后，读取下一条消息。我们可以使用任何可用的库来实现这一目标吗？

到目前为止我已经检查了 cpprestsdk、websocketpp、libwebsocket

Answer 1

您可以使用 Boost.ASIO 库。

我制作了一个可以使用 Websocket 和多个连接的服务器。每个连接都使用异步方式接收数据，这些数据将在接收下一条消息之前进行处理：

/**
* This method is used to read the incoming message on the WebSocket
* and handled it before reading the other message.
*/
void wscnx::read()
{
    if (!is_ssl && !m_ws->is_open())
        return;
    else if (is_ssl  && !m_wss->is_open())
        return;

    auto f_read = [self{shared_from_this()}](const boost::system::error_code &ec, std::size_t bytes_transferred)
                 {
                    boost::ignore_unused(bytes_transferred);

                    // This indicates that the session was closed
                    if (ec == websocket::error::closed)
                    {
                        self->close(beast::websocket::close_code::normal, ec);
                        return;
                    }

                    if (ec)
                    {
                        self->close(beast::websocket::close_code::abnormal, ec);
                        return;
                    }

                    std::string data = beast::buffers_to_string(self->m_rx_buffer.data());
                    self->m_rx_buffer.consume(bytes_transferred);

                    if (!self->m_server.expired())
                    {
                        std::string_view vdata(data.c_str());

                        /*************************************
                          Here is where the datas are handled
                        **************************************/
                        self->m_server.lock()->on_data_rx(self->m_cnx_info.id, vdata, self->cnx_info());
                    }
                    
                    /*************************************
                    Read the next message in the buffer.
                    **************************************/
                    self->read(); 
                };//lambda

    if (!is_ssl)
        m_ws->async_read(m_rx_buffer, f_read);
    else
        m_wss->async_read(m_rx_buffer, f_read);
}

在此示例中，连接可以是普通连接，也可以是安全连接，使用 SSL，两者都使用 lambda 函数来接收数据。

我在浏览器上使用 JS 应用程序测试了此服务，并且处理每条消息的顺序没有问题。