写/读一个对象(java中的套接字)

Question

我的问题是，我有一个对象类(包)，其中包含另一个对象(msg)。我使两个类都实现了Serializable。但是当我运行我的程序时，我看到这个错误"java.io。StreamCorruptedException: invalid type code: 00"

outStrm=new ObjectOutputStream(mySocket.getOutputStream());
inStrm=new ObjectInputStream(mySocket.getInputStream());
outStrm.writeObject(new packet());
outStrm.flush();

服务器端是这样的

Socket client = listen_socket.accept();
in=new ObjectInputStream(client.getInputStream());
out=new ObjectOutputStream(client.getOutputStream());
p=(packet) in.readObject();

我发送了许多数据包，奇怪的是，当我调试它(一步一步)，我不会看到错误，但当我运行它，我有这个错误!请帮帮我。

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
class ServerThre
    extends Thread
{
    Socket client;
    ObjectInputStream in;
    ObjectOutputStream out;
    public ServerThre(Socket client_socket)
    {
        client = client_socket;
        try
        {
            in = new ObjectInputStream(client.getInputStream());
            out = new ObjectOutputStream(client.getOutputStream());
        }
        catch (IOException e)
        {
            try
            {
                client.close();
            }
            catch (IOException e2)
            {
            }
            System.err.println("Exception while getting input streams: " + e);
            return;
        }
        this.start();
    }
    private packet getPacket() throws IOException
    {
        packet p;
        try
        {
            p = (packet)in.readObject();
            if (p != null)
            {
                return p;
            }
        }
        catch (ClassNotFoundException e)
        {
            e.printStackTrace();
        }
        return null;
    }
    @Override
    public void run()
    {
        while (!client.isClosed())
        {
            packet p = null;
            try
            {
                p = getPacket();
            }
            catch (IOException e1)
            {
                e1.printStackTrace();
            }
            if (p == null)
            {
                System.out.print("Connection closed by server, exiting");
                return;
            }
        }// end of while
    }
}

Answer 1

这段代码中有几个奇怪的地方。

1. getPacket()中p != null的检测完全没有意义。

2. 后面将p == null等同于连接关闭的测试错误。在这种情况下，你会得到一个EOFException，而不是null。

3. socket. isclosed()只告诉你是否已经关闭了套接字。

当您使用单个ObjectInputStream进行读取并使用多个objectoutputstream进行写入时，通常会出现"无效类型代码"，或者其他方式。