0

我正在开发一个客户端/服务器聊天应用程序，它允许用户通过套接字连接发送文件（图像/视频......）。

为了管理所有类型的通信，我使用一个对象“数据包”来存储我想要发送的所有信息。（发件人，收件人，文件......）。

这是我在流中编写的代码示例：

private void write(Packet packet) throws IOException {
    ByteArrayOutputStream bos = new ByteArrayOutputStream();
    ObjectOutputStream os = new ObjectOutputStream(bos);
    os.writeObject(packet);
    this.outStream.write(bos.toByteArray());
}

而outStream 是一个OutputStream。

这是我的连接运行：

public void run() {
    while (isRunning()) {
        try {
            byte[] buffer = new byte[65536];
            // Read from the InputStream
            inStream.read(buffer);
            ObjectInputStream in = new ObjectInputStream(new ByteArrayInputStream(buffer));
            Packet p = (Packet) in.readObject();

        } catch (IOException e) {
            e.printStackTrace();
            this.disconnect();
        }
    }
}

除了文件传输之外，它适用于所有目的！我将文件放在一个 byte[]（带有文件流）中，并将数组存储在我的数据包对象中。当服务器接收到通信时，它会在“in.readObject()”上中断，并给我一个漂亮的“java io streamcorruptedexception wrong format: 0”异常。

我尝试使用自定义 byte[]（由 string.getBytes() 填充）进行传输，效果非常好。

那么，我做错了什么？

4

1 回答 1

3

您正在从 InputStream 读取字节数组（任意大小可能太小）。然后你构造一个 ObjectInputStream 来读取这个字节数组。为什么不直接从 InputStream 中读取对象？

ObjectInputStream in = new ObjectInputStream(inStream);
Packet p = (Packet) in.readObject();

不需要缓冲区。

此外，InputStream.read() 不会从 InputStream 中读取所有内容。它读取可用的内容，并返回读取的字节数。如果您在返回 -1 之前不循环，那么您只会读取另一端发送的部分内容。

顺便说一句，您在发送方犯了同样的错误。不是将对象直接写入输出流，而是将其写入字节数组，然后发送此字节数组。将您的对象直接写入流：

ObjectOutputStream os = new ObjectOutputStream(this.outputStream);
os.writeObject(packet);

不需要缓冲区。

于 2012-05-26T21:08:21.470 回答