1

这是我现在所拥有的。

接收者：

public static void read(Socket socket, ObjectInputStream in) {
    try {
        String separator = in.readUTF();
        while (in.readByte() == -3) {
            String path = in.readUTF().replaceAll(separator, System.getProperty("file.separator"));
            File file = new File(new File(path).getParent());
            if (!file.exists()) {
                file.mkdirs();
            }
            FileOutputStream fos = new FileOutputStream(path);
            int b = 0;
            while ((b = in.readByte()) != -4) {
                fos.write(b);
            }
            fos.close();
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
}

发件人：

public static void send(String[] path) {
    Socket socket;
    try {
        socket = new Socket(ip, port);
        socket.setKeepAlive(true);
    } catch (UnknownHostException e) {
        return;
    } catch (IOException e) {
        return;
    }
    try {
        ObjectOutputStream out = new ObjectOutputStream(socket.getOutputStream());
        out.writeUTF(Devbox.getSeparator());
        for (String s : path) {
            send(s, out);
            out.writeByte(-2);
        }
        out.close();
        socket.close();
    } catch (Exception e) {
        e.printStackTrace();
    }
}

private static void send(String path, ObjectOutputStream out) {
    File file = new File(path);
    if (file.isDirectory()) {
        File[] files = file.listFiles();
        for (File f : files) {
            send(path + f.getName(), out);
        }
    } else {
        try {
            out.writeByte(-3);
            out.writeUTF(path);
            FileInputStream fis = new FileInputStream(file);
            int b = 0;
            while ((b = fis.read()) != -1) {
                out.writeByte(b);
            }
            fis.close();
            out.writeByte(-4);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

这是我在发件人中遇到的错误。

java.net.SocketException: Software caused connection abort: socket write error
    at java.net.SocketOutputStream.socketWrite0(Native Method)
    at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:109)
    at java.net.SocketOutputStream.write(SocketOutputStream.java:153)
    at java.io.ObjectOutputStream$BlockDataOutputStream.writeBlockHeader(ObjectOutputStream.java:1874)
    at java.io.ObjectOutputStream$BlockDataOutputStream.drain(ObjectOutputStream.java:1855)
    at java.io.ObjectOutputStream$BlockDataOutputStream.writeByte(ObjectOutputStream.java:1895)
    at java.io.ObjectOutputStream.writeByte(ObjectOutputStream.java:760)

它指向

                out.writeByte(b);

它成功发送了大约 25 个文件，然后抛出此错误。每次它扔到的文件都不一样，但在5个文件左右的相同范围内。接收者在一个特定文件之后停止，该文件通常在发送者停止的文件之前一对。它停止是因为 in.readByte() == -3 是假的。当它发生时，我得到了 -85 和 16 之类的数字。我在另一台计算机上尝试了它，因为它说的是软件，它是完全相同的。有谁知道为什么会这样？我花了一天的时间试图弄清楚，但一无所获。任何帮助是极大的赞赏。

4

2 回答 2

0

使用 BufferedInputStream 在 send 方法中读取 FileInputStream。

BufferedInputStream bis = new BufferedInputStream(new FileInputStream(file));
while ((b = bis.read()) != -1) {
    out.writeByte(b);
}

还可以尝试互补的 BufferedOutputStream

BufferedInputStream bos = new FileOutputStream(path);
int b = 0;
while ((b = in.readByte()) != -4) {
    bos.write(b);
}

此外，您需要在文件完成传输时清除您的连接。

out.flush;
于 2012-04-24T15:51:07.493 回答
0

请阅读此答案，我认为除此之外不能说其他任何内容，而且我在您的代码中也看不到任何会关闭连接的内容。

来自 OTN 讨论

WinSock 描述：当本地网络系统中止连接时，可能会发生错误。如果 WinSock 在数据重新传输失败后中止已建立的连接（接收方永远不会确认在数据流套接字上发送的数据），则会发生这种情况。

TCP/IP 场景：如果本地系统没有收到发送数据的 (ACK) 确认，则连接将超时。如果 (FIN)ish TCP 数据包没有被确认，它也会超时（即使 FIN 被确认，如果没有返回 FIN，它最终也会超时）。

它似乎在 WindowsXP 中发生得更多，而且似乎也可能与 Windows 防火墙设置有关。在任何情况下，重点是中止源自本地机器内部。

于 2012-04-24T15:55:26.053 回答