0

我的服务器在线程中运行此代码,因此我可以在等待客户端连接时与 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 上找到任何东西,因为当人们打开多个或单个 Socket时,获得 a 的一般问题StreamCorruptedException似乎是,但我没有这样做。任何帮助将不胜感激。InputStreamsOutputStreams

4

3 回答 3

1

我想你可能不止一次打开你的输入/输出流。尝试检查 connect-Function 是否只被调用一次。

于 2013-05-23T13:18:04.407 回答
1

您正在构建ObjectOutputStreams然后将它们扔掉。它们应该MessageListener像 the 一样传递给构造函数,ObjectInputStreams,所以它有一些有效的每个客户端可以写。您不可能像现在的代码那样正确地向对等方写入。可能您在ObjectOutputStream某处为错误的同伴重复使用。

您正在创建的那些ObjectInputStreamObjectOutputStream变量应该是方法的本地变量,而不是周围类的成员。事实上,这两个流都应该在run()您将要启动的线程的方法中构造,而不是在accept()循环中内联。否则你可能会在错误的地方阻塞。并且ObjectOutputStream应该总是在 , 之前构造ObjectInputStream,以使死锁不可能。

于 2013-05-23T00:12:31.933 回答
-1

嗯,您必须为客户端/服务器端使用相同的类(带有 id)。我已将消息机制放入用于客户端/服务器项目的库中。此外,如果我编译服务器/客户端,我会编译所有三个项目......也许这会有所帮助。

于 2013-05-22T20:43:46.097 回答