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

【问题标题】：Java Udp sockets, packets lost in localhostJava Udp 套接字，本地主机中丢失的数据包
【发布时间】：2019-05-25 17:05:46
【问题描述】：

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

服务器端：假设我在服务器端创建了 2500 个数据包，然后通知客户端我要发送 2500 个数据包，每个数据包是 packetSize 字节。然后在一个循环中，创建每个数据包然后发送。
客户端：在被告知数据包数量后，在 for（或 while）中，我等待接收 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 以下的文件。谢谢

【问题讨论】：

DatagramChannel 的文档说明了以下内容：“无法放入缓冲区的数据将被静默丢弃。”尝试确保您的缓冲区大小大于或等于您期望接收的数据。
@JacobG。谢谢。缓冲区是什么意思？给DatagramPacket作为构造函数的字节数组？

标签： java sockets udp packet

【解决方案1】：

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

我怀疑您从未初始化过packets，因此您从未点击过您的break。将您的while 重写为for 循环可以轻松检查这是否属实。假设您发送的第一个数据包包含它将接收多少个数据包，并且您正确初始化packets，那么如果您的数据包丢失，那么您的客户端程序将不会结束，因为 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 个数据包，它仍然会在接收（）行的 for 循环中等待 2301、2302、...。 .. 数据包等等。

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

【讨论】：