Java 通过 FIO 读取文件

Question

我正在制作一个 TFTP 应用程序。根据 RFC 协议，所有数据必须以最大 512 字节的块发送。所以每个数据包可以是

我将每个文件读入一个字节[]输出数据=新字节[512]；数组，我将它发送给客户端，但是当它得到一个总大小小于 512 字节的文件（如 ascii 文件或 .ini、.css、.html 等）时，似乎出现了问题。

奇怪的是，对于 UDP 协议，每次高达 3mb 的传输都过去了，没有大的损失。似乎发生的唯一损失是读取文件的最后一块小于 512 字节时。

private void sendData() throws Exception
{
    DatagramPacket data = new DatagramPacket(outgoingData, outgoingData.length, clientAddress, clientPort);
    InputStream fis = new FileInputStream(responseData);

    int a;
    while((a = fis.read(outgoingData,0,512)) != -1)
    {
        serverSocket.send(data);
        Thread.sleep(5);
    }
}

既然这是关于读取文件的问题，我该如何修复文件末尾的丢失以及它不读取小于 512 的文件的问题

客户：

private void receiveData() throws Exception
{
    DatagramPacket receiveData = new DatagramPacket(incomingData, incomingData.length);
    OutputStream fos = new FileOutputStream(new File("1"+data));
    while(true)
    {
        clientSocket.receive(receiveData);
        if(receiveData.getLength() == 512)
        {
            fos.write(incomingData);xx
        } else {
            fos.write(incomingData);
            fos.close();
            break;
        }
    }
    clientSocket.close();
}

Answer 1

您的数据包 (data) 现在的固定长度为 outgoingData.length (512?)。所以当你调用serverSocket.send(data)时，它会发送outgoingData数组中的所有数据。

问题是fis.read(outgoingData, 0, 512) 有时读取的数据少于 512 字节。这很可能发生在文件输入流的末尾，当时根本没有那么多数据可供读取。但它也可能更早发生（在实践中不太可能，但您仍应检查以确保安全）。

您已经在a 中存储了实际读取的字节数。只需将此号码传递给setLength，以便DatagramSocket 知道只发送这么多数据。

这应该可以解决问题：

private void sendData() throws Exception
{
    DatagramPacket data = new DatagramPacket(outgoingData, outgoingData.length, clientAddress, clientPort);
    InputStream fis = new FileInputStream(responseData);

    int a;
    while((a = fis.read(outgoingData,0,512)) != -1)
    {
        data.setLength(a);
        // or this
        //data = new DatagramPacket(outgoingData, a, clientAddress, clientPort);

        serverSocket.send(data);
        Thread.sleep(5);
    }
}

接收：

private void receiveData() throws Exception {
    DatagramPacket receiveData = new DatagramPacket(new byte[512], 512);
    OutputStream fos = new FileOutputStream(new File("1"+data));
    while (true) {
        clientSocket.receive(receiveData);
        if (receiveData.getLength() == 512) {
            fos.write(receiveData.getData());
        } else {
            fos.write(receiveData.getData(), receiveData.getOffset(), receiveData.getLength());
            break;
        }
    }
    fos.close();
    clientSocket.close();
}

Answer 2

    private void sendData() throws Exception
{
    DatagramPacket data = new DatagramPacket(outgoingData, outgoingData.length, clientAddress, clientPort);
    InputStream fis = new FileInputStream(responseData);

    int a;
    while((a = fis.read(outgoingData,0,512)) != -1)
    {
        data.setLength(a); //'a' is the number of bytes read setLength(int) lets you set the length of bytes you want to sent
        serverSocket.send(data);
        Thread.sleep(5);
    }
}

setLength(int) Method DatagramPacket 现在在接收端，你可以这样做：

byte[]buffer = new byte[512];
DatagramPacket packet = new DatagramPacket(buffer,buffer.length);
while(socket.isBound() && !socket.isClosed()){
    socket.receive(packet);
    system.out.println("Packet Length: "+packet.getLength());
    //code here
}

修复： IN Server.java

private void sendResponse(String res) throws Exception
        {
            if(res.equals("Y"))
            {
                // Send ACK -> Send File
                DatagramPacket x = new DatagramPacket(outgoingData, outgoingData.length, clientAddress, clientPort);
                serverSocket.send(x); //<<SEND ACK
                sendData();
            } else {
                String error = "ERROR: The file you requested does not exist.";
                outgoingData = error.getBytes();
                DatagramPacket err = new DatagramPacket(outgoingData, outgoingData.length, clientAddress, clientPort);

                serverSocket.send(err);
            }
        }

我注意到您没有发送确认并且客户正在期待它，这似乎是您唯一的问题。第一个数据包目前对您没有任何作用。现在您只需将 ack 数据包设置为您想要的。我刚刚发送了它，但它不包含字符串“ERROR”。