使用一个TCP套接字的多个请求

如何解决使用一个TCP套接字的多个请求

我正在学习套接字编程（和c ++）。我写了一个下面的函数，要求一个数组的和（使用boost库）：

std::future<void> Asyncclient::ReqSum(const std::vector<double>& numbers)
{
    return std::async(
        std::launch::async,[&,numbers]()
        {
            // Setup connection.
            boost::asio::io_service _ioservice;
            tcp::socket _socket(_ioservice);
            _socket.connect(m_endpoint);

            std::string requestJson = Serializer::ArraySumRequest(numbers);
            boost::system::error_code err;
            while (true)
            {
                boost::asio::write(_socket,boost::asio::buffer(requestJson),err);
                if (err)
                {
                    std::stringstream ss;
                    ss << "Couldn't write to socket! error code: " << err;
                    throw ss.str();
                }

                // getting response from server
                boost::asio::streambuf receiveBuffer;
                boost::asio::read(_socket,receiveBuffer,boost::asio::transfer_all(),err);

                if (err && err != boost::asio::error::eof)
                {
                    std::stringstream ss;
                    ss << "Receiving from the server Failed! error code: " << err.message();
                    throw ss.str();
                }

                const char* data = boost::asio::buffer_cast<const char*>(receiveBuffer.data());

                rapidjson::Document doc;
                doc.Parse<rapidjson::kParseDefaultFlags>(data);

                if (!doc.HasMember("result"))
                    throw "No result found!";

                double result = doc["result"].GetDouble();

                std::cout << "Sum of the array: " << result << std::endl;
            }
            _socket.shutdown(boost::asio::socket_base::shutdown_both);
            _socket.close();
        });
}

第一次写入和读取都可以正常工作，但是第二次我进入循环写入套接字可以正常工作，但是读取时出现错误：

错误代码：10053；消息：建立的连接被计算机主机中的软件中止了。

此错误与我的机器有关吗？我该怎么做？

解决方法

您似乎正在尝试从服务器接收所有数据：

boost::asio::streambuf receiveBuffer;
boost::asio::read(_socket,receiveBuffer,boost::asio::transfer_all(),err);

read()命令完成的唯一方法是服务器指示流的结尾。由于您是第一次收到有效的响应，因此这意味着服务器会在向您发送响应后立即关闭连接。