主页 / 问题 / 1158547
Accepted
Николай Николаевич
Asked:2020-07-29 04:54:10 +0000 UTC2020-07-29 04:54:10 +0000 UTC

如何通过网络正确传送数据

  • 772

假设我在服务器上拨打了 3 次电话send

send(sock,"I",sizeof("I"),0);
send(sock,"Y",sizeof("Y"),0);
send(sock,"X",sizeof("X"),0);

在客户端，我打了 3 次电话recv

recv(sock,buf,sizeof(buf),0);
recv(sock,buf,sizeof(buf),0);
recv(sock,buf,sizeof(buf),0);

有时会发生三个 send 调用的执行速度比数据到达客户端的速度要快，所以第一个 recv 调用读取了三个 send 调用发送的所有数据，而第二个 recv 在预期中冻结，你必须做“安全网”：

客户端收到第一次send调用的数据，然后向服务器发送一个肯定响应，服务器上的下一个send调用只有在收到客户端的肯定响应后才执行，这非常集体农场，所以如果你知道一个正常的方式 - 写一个答案

c

1 个回答

  1. Best Answer

    从编程的角度来看，TCP 表示双向数据流，并且该数据可以一次以任意块的形式传送，可以更小也可以更大。您需要使用您的协议将此流划分为消息，该协议在 TCP 之上运行。

    主要有几种方式：

    1. 发送和阅读固定长度的消息。

      #define MSG_SZ 64
// ...
char buf[MSG_SZ];
strncpy("X", buf, MSG_SZ-1); buf[MSG_SZ-1]=0; send(sock, buf, MSG_SZ, 0);
strncpy("Y", buf, MSG_SZ-1); buf[MSG_SZ-1]=0; send(sock, buf, MSG_SZ, 0);

      接待：

      char buf[MSG_SZ];
recv(sock, buf, MSG_SZ, MSG_WAITALL);
recv(sock, buf, MSG_SZ, MSG_WAITALL);

    2. 使用分隔符/字符串。

      #define MSG_SEP "\n<NEXT>\n"
#define MSG_SEP_LEN (sizeof(MSG_SEP) - 1)
// ...
send(sock, "X", sizeof("X")-1, 0); send(sock, MSG_SEP, MSG_SEP_LEN, 0);
send(sock, "Y", sizeof("Y")-1, 0); send(sock, MSG_SEP, MSG_SEP_LEN, 0);

      接待：

      char *recvMsg(int sock) {
  static char buf[BUF_SZ]; // буфер статический, так что будет сохраняться между вызовами
  static size_t recv_n = 0; //< колличество данных в буфере
  char *sep_pos;    //< позиция разделителя

  while(1) {
    ssize_t recv_rv = 0; 
    sep_pos = memmem(buf, recv_n, MSG_SEP, MSG_SEP_LEN) // сначала ищем разделитель т.к. предыдущий вызов мог прочитать несколько сообщений. 
    // memmem — нестандартная функция для поиска подстроки в памяти аналогичная strstr
    if (sep_pos) {
      break;
    }

    // Получение дополнительных данных
    ssize_t recv_rv = recv(sock, buf + recv_n, BUF_SZ - recv_n, 0);

    if (recv_rv<0) {
      if (errno == EINTR) {
        continue; // Системный вызов был прерван сигналом.
                  // Эту ситуацию желательно обрабатывать на unix-подобных ОС
      } else {
        error_or_die(); // обработка других ошибок, например разрыва соединения
        return 0;
      }
    } else if (recv_rv == 0) {
      // соединение закрыто и данных в сокете больше нет, но стоп-строка не найдена.
      error_or_die();
      return 0;
    } else { // прочитано несколько символов. Добавим их длину.
      recv_n+=recv_rv;
      if (recv_n==BUF_SZ) { // Буфер переполнен.
        error_or_die();
        return 0;
      }
    }
  }

  assert (sep_pos);

  // Обрезка одного сообщения
  size_t rv_len = sep_pos-buf;
  char *rv = malloc(rv_len+1);
  assert(rv);
  memncpy(buf, rv, rv_len);
  rv[rv_len] = 0;

  // Сдвиг оставшихся в буфере данных в начало
  recv_n -=( rv_len + MSG_SEP_LEN);
  memncpy(sep_pos + MSG_SEP_LEN, buf, recv_n);

  return rv;
}

// ...

char *buf1 = recvMsg(sock); /* ... */  free (buf1);
char *buf2 = recvMsg(sock); /* ... */  free (buf2);

    3. 在它之前/在其标题中发送消息大小。

      const char *msg="X";
uint32_t sz = strlen(msg);
uint32_t nsz = htonl(nsz); // перевод размера сообщения в сетевой порядок байт.
// Вообще говоря, это не обязательно, но необходимо удостоверится, 
// что обе машины ожидают данные с одинаковым порядком байт совпадает.
send(sock, &nsz, 4, 0); send(sock, msg, sz, 0);
msg="Y"; sz = strlen(msg);
nsz = htonl(nsz)
send(sock, &nsz, 4, 0); send(sock, msg, sz, 0);

      接待：

      uint32_t sz;

recv(sock, &sz, 4, MSG_WAITALL);
sz = ntohl(sz);
recv(sock, buf, sz, MSG_WAITALL);

recv(sock, &sz, 4, MSG_WAITALL);
sz = ntohl(sz);
recv(sock, buf, sz, MSG_WAITALL);

    4. 每个连接只发送一条消息。

      sock = socket(AF_INET, SOCK_STREAM, 0)
connect(sock, (struct sockaddr *) &addr, sizeof(addr);
send(sock, "X", sizeof("X"), 0);
shutdown(sock, SHUT_WR);
/* получение ответа */
close(sock)

sock = socket(AF_INET, SOCK_STREAM, 0);
connect(sock, (struct sockaddr *) &addr, sizeof(addr);
send(sock, "Y", sizeof("Y"), 0);
shutdown(sock, SHUT_WR);
/* получение ответа */
close(sock);

      接待：

      sock = accept(srv_sock, 0, 0);
size_t recv_n = 0;
ssize_t recv_rv;

while (1) {
  recv_rv = recv (sock, buf+recv_n, BUF_SZ - recv_n, 0);
  if (recv_rv<0) {
    error_or_die(); /* обработка ошибок */
  } else if (recv_rv == 0) {
    break;
  } else { // recv_rv > 0
    recv_n += recv_rv
  }
}

/* формирование ответа */

close(sock);

/* приём следующего соединения аналогичен */

    所有方法都可以以各种组合使用，每种方法都有优点和缺点。例如，（1）只适用于非常简单的协议，实际上在示例（3）中也用于“header”；HTTP 对标头使用方法 (2)，对内容使用方法 (3)，或者在旧版本中使用方法 (4)。

    您还应该记住，一次可以不仅更多，而且更少数据，因此上面的示例使用 MSG_WAITALL 或带缓冲的完整读取周期，如 (2) 和 (4) 所示。就本地系统的开销而言，类似的用户空间读取循环通常也适用于其他选项。对于服务于许多客户端的服务器的情况，通常需要它。

    免责声明：所有代码都是推测性地编写以说明原理，不会调试，并且可能包含错误。

    • 13

相关问题