发送和接收的数据大小不同答案

【问题标题】：Sent and received data isn't the same size发送和接收的数据大小不同
【发布时间】：2011-07-17 12:13:44
【问题描述】：

我用 C++ 编写了带有 boost.asio 和 php 客户端的服务器。当我发送少量数据时，我得到了所有数据，但是当我发送长字符串时，我丢失了大部分数据。

这是我从服务器发送数据的部分，它说我已经发送了 65536 个字节

void handle_write(const boost::system::error_code& /*error*/,
            size_t size/*bytes_transferred*/) {
        cout <<size<<endl;
    }
    void handler_read(const boost::system::error_code&, std::size_t size) {
        istream is(&buffer);
        string myString;
        getline(is, myString);

        Manager myManager(myString);
        string response = myManager.getResponse();
        boost::asio::async_write(socket_,
                boost::asio::buffer(response),
                boost::bind(&tcp_connection::handle_write, shared_from_this(),
                        boost::asio::placeholders::error,
                        boost::asio::placeholders::bytes_transferred));

    }

我在这里制作我将要发送的字符串

string getMap(string name, string pass) {
            if (name == "admin" && pass == "123") {
                string response = "";
                ConvertTypes types;
                response = types.intToString(MAP_HEIGHT) + " ";
                response += types.intToString(MAP_WIDTH) + "\r\n";
                for (int i=0; i<MAP_HEIGHT;i++) {
                    for (int j=0;j<MAP_WIDTH;j++) {
                        response += types.intToString(
                                worldMap[i][j].getHeight()) + " ";
                        response += types.intToString(
                                worldMap[i][j].getIsTown()) + " ";
                        response += string (1, worldMap[i][j].getTetrain())
                                +"\r\n";
                    }
                }
                return response;
            } else {
                return "";
            }
        }

在 php 端我读取了发送的数据，stream_get_meta_data 说我只收到了 8183 字节的数据。

print_r($this->socket->getStatus());

        for ($i=0; $i<$MAP_HEIGHT;$i++) {
            for ($j=0; $j<$MAP_WIDTH;$j++) {

                $this->response = $this->socket->readLine();
                $this->response = explode(' ', $this->response);
                echo "<p>";
                echo "$i $j <br>";
                print_r($this->response);
                echo '<br>';
                print_r($keyArray);
                $map[$i][$j] = array_combine($keyArray, $this->response);
                $this->response = $this->socket->readLine();
            } }

        }

【问题讨论】：

我不懂PHP，但是不保证网络包会在一个块内全部送达，如果你稍等片刻再试读，有没有更多的资料？

标签： php c++ sockets network-programming boost-asio

【解决方案1】：

你可以通过socket发送一个大块，但是接收端可能会收到几个小块，例如：

send    -> 10000 bytes

receive <- 3000 bytes
receive <- 2000 bytes
receive <- 4500 bytes
receive <-  500 bytes

这只是一个例子，TCP 不保证发送和接收块的大小相同。

【讨论】：

+1 在服务器端调用一次send 不等于在客户端调用一次recv。这是一个需要理解的重要概念。

【解决方案2】：

我找到了答案。我以不安全的方式从服务器发送数据。当async_write 将控制权交给其他东西时，其余数据都丢失了。

你必须将字符串传递给这个类：

class shared_const_buffer {
public:
  // Construct from a std::string.
  explicit shared_const_buffer(const std::string& data)
    : data_(new std::vector<char>(data.begin(), data.end())),
      buffer_(boost::asio::buffer(*data_))
  {
  }

  // Implement the ConstBufferSequence requirements.
  typedef boost::asio::const_buffer value_type;
  typedef const boost::asio::const_buffer* const_iterator;
  const boost::asio::const_buffer* begin() const { return &buffer_; }
  const boost::asio::const_buffer* end() const { return &buffer_ + 1; }

private:
  boost::shared_ptr<std::vector<char> > data_;
  boost::asio::const_buffer buffer_;
};

并发送此缓冲区而不是原始字符串。这样您就不会丢失数据。

【讨论】：