D receiveFrom 没有收到完整的数据包

Question

我目前正在使用 D 为游戏编写一个小型 UDP 服务器。问题是收到的一些数据包与实际数据包的长度不匹配（通过wireshark查看）。

例如，客户端通过网络发送一个 110 字节的数据包，该数据包显示在 Wireshark 下。但是 D 码只接收 7 个字节！没有其他 7 字节数据包从客户端通过网络发送。

D 中的 7 个字节与 110 字节数据包中的前 7 个字节匹配。我认为这是套接字库的问题，因为我想不出其他任何可能导致此问题的东西。

问题总是发生在同一点和完全相同的数据包。如果忽略此问题，某些数据包仍会出现问题。

请注意，该项目中有多个文件，因此我在下面包含了代码片段：

this(in Logger logger, string bindInterface = "0.0.0.0", ushort bindPort = 19132) {
    this.logger = logger;
    socket = new UdpSocket(AddressFamily.INET);
    bindAddress = new InternetAddress(bindInterface, bindPort);
}

void bind(uint sendBufferSize = 1024 * 1024, uint recvBufferSize = 1024 * 1024) {
    socket.bind(bindAddress);

    socket.setOption(SocketOptionLevel.SOCKET, SocketOption.BROADCAST, true);
    socket.setOption(SocketOptionLevel.SOCKET, SocketOption.SNDBUF, sendBufferSize);
    socket.setOption(SocketOptionLevel.SOCKET, SocketOption.RCVBUF, recvBufferSize);
    socket.blocking = false;
}

bool recv(ref Address address, ref byte[] buffer) {
    auto length = socket.receiveFrom(buffer, SocketFlags.NONE, address);
    if(length > 0) {
        buffer.length = length;
        debug logger.logDebug(to!string(length) ~ " Packet IN: " ~ to!string(cast(ubyte[]) buffer));
        return true;
    }
    buffer = null;
    return false;
}

...

Address a;
    byte[] data = new byte[1024 * 1024];
    while(max-- > 0 && socket.recv(a, data)) {
        handlePacket(a, data);
    }

完整源码可以在here.找到

任何帮助将不胜感激。

客户是

Answer 1

问题出在这一行：

bool recv(ref Address address, ref byte[] buffer)

使用ref，您不会进行切片，但您确实修改了原始缓冲区，因此如果前一个数据包长 7 个字节，您将无法再接收超过 7 个字节

因此您可以更改代码以删除 ref 并返回长度而不是纯 bool

size_t recv(ref Address address, byte[] buffer);

然后：

Address a;
byte[] data = new byte[1024 * 1024];
size_t len;
while(max-- > 0 && (len = socket.recv(a, data))) {
    handlePacket(a, data[0 .. len]);
}

但这可能不适用于您的 handlePacket 函数，因为另一个 ref 所以另一个变体是不要更改您的 recv 但只有部分代码围绕 handlePacket

Address a;
byte[] data = new byte[1024 * 1024];
size_t arr = data[];
while(max-- > 0 && socket.recv(a, arr)) {
    handlePacket(a, arr);
    arr = data[];
}