Delphi中的UDP服务器和客户端

Question

我正在制作一个 UDP C/S。我对服务器每秒可以接收的数据数量有疑问。

我已经测试了将 10、100、1000 条数据消息批量发送到服务器，10、100 条接收没有问题。发送 1000 时，只收到 300 ~ 400。所有测试都在本地完成。

我已经尝试使用 ICS 的 twsocket 和 Synapse 的 tudpblocksocket 来实现服务器。两者都出现了上述相同的问题。

能否向我解释为什么会发生这种情况，以及如何提高服务器性能。

使用 TUDPBlockSocket 的代码

...

while not Terminated do
begin
  try
    sz := FUDPServer.WaitingData;
    if sz > 0 then
    begin
      FUDPServer.RecvBuffer(mem.Memory, sz);
      mem.Seek(0, 0);
      AMessage := fFormats.ReadFromStream(mem);
      DoMessageReceived(FUDPServer.RemoteSin.sin_addr, AMessage);
    end; 

  finally

  end;
end;

...

使用 ICS 的代码

...

procedure TShapeServer.WSocketDataAvailable(Sender: TObject; ErrCode: Word);
...
begin
  SrcLen := SizeOf(Src);
  stream := TMemoryStream.Create;
  stream.SetSize(INT_BUFFER_SIZE);
  Inc(fMessageReceived);  
  try
    Len    := FUDPServer.ReceiveFrom(stream.Memory, stream.size, Src, SrcLen);
    if (FSenderAddr.S_addr = INADDR_ANY) or
       (FSenderAddr.S_addr = Src.Sin_addr.S_addr) then
    begin

      while stream.Position < Len do
      begin
        try
          AMessage := fFormats.ReadFromStream(stream);
          DoMessageReceived(Src.Sin_addr, AMessage);
        except
          break;
        end;
      end;

    end;

  finally
    stream.Free;
  end;
end;
...

Answer 1

UDP 不保证消息传递 - 如果缓冲区中没有位置，数据包会毫不犹豫地丢弃。 如果您需要保证交付，请使用 TCP 并在 TCP 之上构建基于消息的通信方案。或者使用我们已经拥有的MsgConnect 产品。十字军注意事项：MsgConnect 有一个开源版本。

Answer 2

如果你想使用 UDP 协议并且不丢失任何数据包，你必须在你的程序中添加一个确认机制，因为 UDP 数据包在传输过程中可能会丢失。这种ACK机制已经在TCP协议中实现，是性能和一致性的最佳选择。

如果您不能使用 TCP（可能您的客户端没有足够的 CPU 功率或 RAM 来处理 TCP），请考虑使用一些易于编码的基于 UDP 的协议，例如 TFTP。我们通过SynCrtUnit 实现了一个 TFTP 客户端和服务器，但是您在 Synapse 中有这样一个组件。但是 TFTP 很慢，因为它等待每个传输的数据包的 ACK 信号。所以你不会丢失任何数据包，但与 TCP 相比，速度会很差。

去年，我在基于 DOS 的自动化引擎中在 Delphi 中实现了这样的 TFTP 服务器，然后在 TP 7 中实现了 TFTP 客户端。这工作得很好，两端共享一些对象结构。 TFTP/UDP/IP 堆栈是在纯 TP 7 中编码的，只有静态分配的内存，并且运行良好。

但如果您没有这种“低 CPU”要求，请考虑使用 TCP/IP 而不是 UDP/IP。例如，如果您需要一些广播，则使用 UDP，但使用某种 ACK 机制。