如何解决无法通过 boost websocket 将文本帧解码为 UTF 8

Question

我通过 boost 编写了一个 websocket，并通过 chrome 客户端收到了消息。 当我使用 ws 时，它运行良好，我可以收到正确的消息。 但是当我使用 wss 时，它的效果很差，并且说无法将文本帧解码为 UTF 8。

图片是什么问题是ssl模式。

c++ 发送消息代码

  Json::Value jsonMsg;
        jsonMsg["msgType"] = Json::Value("MspServiceStartUp");
        jsonMsg["version"] = Json::Value(std::string(MSP_VERSION));
        ws_->async_write(boost::asio::buffer((void *) jsonMsg.toStyledString().data(), jsonMsg.toStyledString().size()),
                         boost::asio::bind_executor(*strand_, [&, sp](boost::system::error_code ec1,
                                                                      std::size_t bytes_transferred1) {
                             boost::ignore_unused(bytes_transferred1);
                             if (ec1) {
                                 LOG_ERR << "async write failed, ec = " << ec1 << ", msg = "
                                         << ec1.message();
                                 return;
                             }
                             // Clear the buffer
                             buffer_->consume(buffer_->size());
                             task();
                         }));
    }

js代码

var ws=new WebSocket("wss://localhost.com:17801/");
ws.onopen=()=>{console.log('ws open')};
ws.onclose=()=>{console.log('ws close')};
ws.onmessage=(msg)=>{console.log('ws onMessage');console.log(msg)};

这个奇怪的角色是从哪里来的？ 问题是什么？如何解决这个问题？

Answer 1

问题在于发送数据。 async_write() 立即结束，它不会复制数据缓冲区，您必须确保传递到 boost::asio::buffer 的数据在发送完整消息之前一直存在。

即使我们在async_write 和结束大括号{ 之间添加了一些延迟代码：

async_write(boost::asio::buffer((void *) jsonMsg.toStyledString().data(), ..));
... some code waiting until write is completed
}

此代码也不起作用，因为toStyledString 返回string 按值。 所以临时的string 被创建，string::data() 被调用，async_write() 结束，你在由async_write() 发起的任务中有悬空指针。

快速解决方案，例如通过使用智能指针来延长字符串的生命周期：

std::shared_ptr<std::string> buf(std::make_shared<std::string>(jsonMsg.toStyledString()));
ws_->async_write(boost::asio::buffer(*buf),
                 boost::asio::bind_executor(*strand_, 
                 [&, sp, buf](boost::system::error_code ec1,
                             std::size_t bytes_transferred1) 
                 {
                         boost::ignore_unused(bytes_transferred1);
                         if (ec1) {
                             LOG_ERR << "async write failed, ec = " << ec1 << ", msg = "
                                     << ec1.message();
                             return;
                         }
                         // Clear the buffer
                         buffer_->consume(buffer_->size());
                         task();
                 }));

通过boost::asio::buffer(*buf) 传递buf，并通过lambda 中的值捕获它：[&,sp,buf]。