Java Udp套接字，本地主机中丢失的数据包

Question

我正在实现一个简单的java udp套接字程序。详细信息如下:

• 服务器端:假设我在服务器端创建2500个数据包，然后通知客户端我要发送2500个数据包，每个数据包都是packetSize字节。然后在一个循环中，创建每个数据包然后发送。
• 客户端:收到数据包数量后，在一段时间内等待接收到 2500 个数据包。

问题是这样的:客户端的 for 循环永远不会结束!这意味着 2500 个数据包从未收到!虽然我检查了服务器端，它已经将它们全部发送了。

我尝试使用以下方法将套接字的接收缓冲区大小设置为 10 * packetSize:

socket.setReceiveBufferSize(10 * packetSize)

但是它不起作用。

你认为我该如何解决这个问题？我知道 UDP 不可靠，但客户端和服务器都在同一台计算机的不同端口上运行!

这是服务器端的代码:

for (int i = 0; i < packets; i++) {
            byte[] currentPacket = new byte[size];
            byte[] seqnum = intToByteArray(i);
            currentPacket[0] = seqnum[0];
            currentPacket[1] = seqnum[1];
            currentPacket[2] = seqnum[2];
            currentPacket[3] = seqnum[3];

            for (int j = 0; j < size-4; j++) {
                currentPacket[j+4] = finFile[i][j];
            }

            sendPacket = new DatagramPacket(currentPacket, currentPacket.length, receiverIP, receiverPort);
            socket.send(sendPacket);
            try {
                Thread.sleep(2);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

和客户端:

int k = 0;
    while (true) {
        receivedBytes = new byte[size];
        receivePacket = new DatagramPacket(receivedBytes, size);
        socket.receive(receivePacket);
        allBytes.add(receivePacket.getData());
        k++;
        if (k == packets)
            break;
    }

allBytes 只是一个包含接收到的字节的链接列表。我用它来重新组装最终文件。

附注此代码非常适合 100Mb 以下的文件。谢谢

Answer 1

更新: tl;dr 摘要: packets 未正确初始化或使用 TCP，或者在 UDP 数据包中添加序列号，以便您的客户端知道它是否丢弃了数据包，您可以编写代码来处理该问题(请求重播)。无论如何，这本质上使它成为一个基本的 TCP。

我怀疑您从未初始化数据包，因此您从未遇到中断。将 while 重写为 for 循环可以轻松检查这是否正确。假设您发送的第一个数据包包含它将接收多少个数据包，并且您正确初始化了数据包，那么如果您的数据包丢失，那么您的客户端程序将不会结束，因为 receive() 是一种阻塞方法。

如果您强烈怀疑数据包丢失，请调试客户端并查看 LinkedList 中收到的数据包数量，并将其与服务器端发送的数据包数量进行比较。

for(int i = 0; i < packets; i++) {
    receivedBytes = new byte[size];
    receivePacket = new DatagramPacket(receivedBytes, size);
    socket.receive(receivePacket);
    allBytes.add(receivePacket.getData());
}
System.out.println("All " + packet + " received.");

切换到上面的代码会让您知道，如果您从未到达 print 语句，那么您就知道您正在丢失数据包，因为 receive() 是一种阻塞方法，这意味着您的客户端陷入困境for 循环。这是因为 for 循环无法满足，因为如果服务器发送了 2500 个数据包，但客户端只收到 2300 个数据包，它仍然会在 receive() 行的 for 循环中等待2301、2302、...数据包等等。

由于您有一个超过 100MB 或更多的文件需要组装，我假设您不能容忍丢失，因此要么使用 TCP 来满足该要求，要么通过在代码中创建自己的 header 来处理这种可能性每个数据包。该 header 可以像客户端将接收和读取的递增序列号一样简单，如果它跳过前一个数据包中的数字，那么它将知道数据包丢失了。此时，您可以让客户端请求服务器重新广播该特定数据包。但此时您刚刚实现了自己的原始 TCP。