c ++ boost从套接字读取错误的数据

Question

我尝试使用 boost ssl 套接字服务器。我从https://www.boost.org/doc/libs/1_69_0/doc/html/boost_asio/example/cpp11/ssl/server.cpp 获取示例并尝试 cout 接收数据：

#include <cstdlib>
#include <functional>
#include <iostream>
#include <boost/asio.hpp>
#include <boost/asio/ssl.hpp>

using boost::asio::ip::tcp;

class session : public std::enable_shared_from_this<session>
{
public:
    session(tcp::socket socket, boost::asio::ssl::context& context)
        : socket_(std::move(socket), context)
    {
    }

    void start()
    {
        do_handshake();
    }

private:
    void do_handshake()
    {
        auto self(shared_from_this());
        socket_.async_handshake(boost::asio::ssl::stream_base::server,
            [this, self](const boost::system::error_code& error)
            {
                if (!error)
                {
                    do_read();
                }
            });
    }

    void do_read()
    {
        auto self(shared_from_this());
        socket_.async_read_some(boost::asio::buffer(data_),
            [this, self](const boost::system::error_code& ec, std::size_t length)
            {
                if (!ec)
                {
                    std::cout << std::string(data_) << std::endl;

                    do_write(length);
                }
            });
    }

    void do_write(std::size_t length)
    {
        auto self(shared_from_this());
        boost::asio::async_write(socket_, boost::asio::buffer(data_, length),
            [this, self](const boost::system::error_code& ec,
                std::size_t /*length*/)
            {
                if (!ec)
                {
                    do_read();
                }
            });
    }

    boost::asio::ssl::stream<tcp::socket> socket_;
    char data_[1024];
};

class server
{
public:
    server(boost::asio::io_context& io_context, unsigned short port)
        : acceptor_(io_context, tcp::endpoint(tcp::v4(), port)),
        context_(boost::asio::ssl::context::sslv23)
    {
        context_.set_options(
            boost::asio::ssl::context::default_workarounds
            | boost::asio::ssl::context::no_sslv2
            | boost::asio::ssl::context::single_dh_use);
        context_.set_password_callback(std::bind(&server::get_password, this));
        context_.use_certificate_chain_file("/home/chiffa/SOAP/CRT/Server.crt");
        context_.use_private_key_file("/home/chiffa/SOAP/CRT/Server.key", boost::asio::ssl::context::pem);
        context_.use_tmp_dh_file("/home/chiffa/SOAP/CRT/dh2048.pem");

        do_accept();
    }

private:
    std::string get_password() const
    {
        return "test";
    }

    void do_accept()
    {
        acceptor_.async_accept(
            [this](const boost::system::error_code& error, tcp::socket socket)
            {
                if (!error)
                {
                    std::make_shared<session>(std::move(socket), context_)->start();
                }

                do_accept();
            });
    }

    tcp::acceptor acceptor_;
    boost::asio::ssl::context context_;
};

int main(int argc, char* argv[])
{
    try
    {


        boost::asio::io_context io_context;

        using namespace std; // For atoi.
        server s(io_context, atoi("4443"));

        io_context.run();
    }
    catch (std::exception& e)
    {
        std::cerr << "Exception: " << e.what() << "\n";
    }

    return 0;
}

然后我从 POSTMAN 发送一些 JSON 数据，例如：

{
    "cmd": "alerts",
    "endpoint": "ref/alerts",
    "lng_id": 1
}

但是在 cout 我得到了这个：

POST /ref/alerts HTTP/1.1 内容类型：应用程序/json 缓存控制：无缓存 邮递员令牌：545be9f7-8d3f-4f7e-ba44-e3a38d648031 用户代理：PostmanRuntime/7.6.0 接受： */* 主机：192.168.1.229:4443 接受编码：gzip，放气 内容长度：70 连接：保持活动 { “cmd”：“警报”， “端点”：“参考/警报”， “lng_id”：1 } 平底锅，br 内容长度：51 FHaIuRqCKdojreapq3ziIChnhxJ5Lllt1kgJbhSVxQbnpB5967wNASYNyM glcGRtZfQW7Ymb03WyroD7GoKNKQEo5JYBmOf8I1AQKBgQDTbvwifdNySWVybKIn wXPdHYJpcQ/E3pP1SCtmHxTMpU6fdPaM3K53o4YCIOdgA2Lu6yMyVsrqJfiBID5Z tu8Q2cd1YwAUeM2iiDNriYyP3ZEt7bzZQ5GRV95aOeiLlGTuqEhi0/u9OiDNCWnQ 03IDqZeloMd1OiT0heN5NNKVOwKBgQDKxvd9ntlfzACxlltR86T/E0b6tL84X0IS kvCHuZNLs5Ls+lZALKu4cuMfxOgxqI65qxgsUqFqFzjWHhi8NVVW1bLP0Yq0+r8a Yz17mz0L6iUBnW5kUs7yIGxT6ww+ski7JJY0h8EtBi7gNyET/lZyafLFoRYI9Lsb tqMB+9/3QQKBgHoMnAExDwju81+c8/HtCvv919UUDd0/+rrhYSP/FxuW5Q7JDrV7 gj7Pp0C9S7Kx4b82/sdFMLb/Gjc3rKZPIitg+3F4p4gpv9Jtuvj9mqVFalPP426r QXFb/p+ow+Mm0yis/bQG2E+AKYUSRQHlvO/+SuqyJ9E0sjZwv0GtS！

谁能解释为什么它会添加flate, br Content-Length: 51 FHaIuRqCKdojreapq3z...... 以及如何修复它？

Answer 1

在您的session 类中，data_ 成员是一个简单的char[] 数组，因此当do_read() 调用std::string(data_) 时，std::string 构造函数将data_ 视为以空值结尾的C 字符串，读取直到在内存中找到 '\0' 字符。

但是，data_ 不是以 null 结尾的 C 字符串。如果在async_read_some() 写入data_ 的字节中找不到'\0' 字符（在此示例中永远不会找到），那么std::string 将简单地读入data_ 内存的其余部分，并且您最终会输出 data_ 中已经存在的任何 async_read_some() 没有覆盖的内容。但更糟糕的是，如果在到达data_ 的末尾之前没有找到'\0'，std::string 将继续读取周围的内存，现在你有一个缓冲区溢出。

async_read_some() 谓词的length 参数是保存到data_ 中的实际字节数。使用接受长度作为输入参数的std::string 构造函数：

std:::cout << std::string(data_, length);

或者，您可以使用 ostream::write() 方法完全摆脱 std::string：

std::cout.write(data_, length);