我的服务器在线程中运行此代码,以便在等待客户端连接时可以与GUI交互(目前我仅使用1个客户端和1个服务器。)

@Override
public void run() {

    Socket client = null;
    MessageListener listener = null;

    try {
        client = server.accept();
        oos = new ObjectOutputStream(client.getOutputStream());
        ois = new ObjectInputStream(client.getInputStream());
        listener = new MessageListener(ois);
        (new Thread(listener)).start();

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


我的客户端只需运行一次此代码即可连接到服务器并修复输入/输出流:

try {
        ois = new ObjectInputStream(server.getInputStream());
        MessageListener listener = new MessageListener(ois);
        oos = new ObjectOutputStream(server.getOutputStream());
        (new Thread(listener)).start();
    } catch (IOException e) {
        e.printStackTrace();
    }


MessageListener运行一个线程来检查传入的消息。

@Override
public void run() {
    while (true) {
        Message message = null;
        try {
            message = (Message) in.readObject();
            if (message != null) {
                System.out.println(message.getName());
            }
        } catch (ClassNotFoundException | IOException e) {
            e.printStackTrace();
        }

    }
}


但是,当我启动程序时,起初我只能从服务器发送到客户端,而不能以其他方式发送(我无法与客户端GUI交互)。
从服务器向客户端发送第一条消息后,我收到以下错误消息:

java.io.StreamCorruptedException: invalid type code: 6F
at java.io.ObjectInputStream.readObject0(Unknown Source)
at java.io.ObjectInputStream.readObject(Unknown Source)
at com.jale.chat.iohandling.MessageListener.run(MessageListener.java:25)
at java.lang.Thread.run(Unknown Source)


编辑:得到第一条错误消息后,我只能从客户端发送到服务器(发送实际上可行),但是错误消息不断向我的控制台发送垃圾邮件。

MessageListener的第25行:

message = (Message) in.readObject();


尚未在google / Stack Overflow上找到任何内容,因为获取StreamCorruptedException的一般问题似乎是人们为单个Socket打开多个InputStreamsOutputStreams,但是我没有这样做。任何帮助将不胜感激。

最佳答案

我认为您可能已经多次打开了Input / Output-Streams。尝试检查connect-Function仅被调用一次。

10-05 18:25