对通过 ObjectInputStream 接收的数据进行排序

Question

我制作了一个通过 ObjectInputStream 从服务器接收数据的信使。 我希望能够检索/发送可序列化文件，同时还能够从用户那里检索/发送消息。

我找不到一种在两者（对象和消息）之间进行排序而不与消息传递冲突的好方法。

我尝试为同一个套接字（Data*Stream 和 Object*Stream）使用两个流，它似乎建立得很好，但是当我尝试通过 Data*Stream 从服务器向客户端发送消息时，我在我的客户端上获取java.net.SocketException: socket closed。 （仅在我发送消息时发生）

有人能指出我将如何通过流检索 2 种不同类型的信息的正确方向吗？ （没有采取简单的出路。我不想做writeObject("[message]"+input); 或任何类似的廉价技巧。

---

---

（编辑）解决方案：

感谢 janos，他启发了我编写这段代码。 :') 谢谢哥们

输入接收器：

protected Object data;

public synchronized Object receivedData() throws ClassNotFoundException,
                                                 IOException {
    data = in.readObject();

    if(!(data instanceof String)) {
        retrieveObject();
        data = "";
        System.out.println("Object");
    }
    return data;
}

还有消息线程：

ExecutorService pool = Executors.newScheduledThreadPool(1);

private Runnable receiveData;
public void receiveData() {
    receiveData = new Runnable() {

        public void run() {
            String input;
            try {
                while((input = (String) receivedData()) != null) {
                    if(input.length() > 1) 
                        System.out.println(input);

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

    pool.execute(receiveData);
}

如果您有任何改进提示，请告诉我，我会更新此代码。

Answer 1

您可以创建父类Message，以及子类DataMessage 和TextMessage。

当收到Message时，你可以用instanceof检查它的底层类型，并进行相应的处理。

这些*Message 类可以将您想要在客户端和服务器之间传递的任何对象包装在它们的成员变量中。 *Message 类必须是可序列化的，因此所有成员变量也必须是可序列化的。

例如给定这些Message 类型：

class Message {}

class TextMessage extends Message {
    String text;
}

class DataMessage extends Message {
    User user;
}

您可以处理收到的消息，例如：

Message message = (Message) in.readObject();
if (message instanceof TextMessage) {
    // do something with ((TextMessage)message).text
} else if (message instanceof DataMessage) {
    // do something with ((DataMessage)message).user
}

Answer 2

我希望能够检索/发送可序列化文件，同时还能够从用户那里检索/发送消息。

您可以使用ObjectInputStream 和ObjectOutputStream 完成所有这些操作。

我找不到一种在两者（对象和消息）之间进行排序而不与消息传递冲突的好方法。

除非您指定“冲突”，否则该声明毫无意义。

我尝试对同一个套接字使用两个流（Data*Stream 和 Object*Stream）

1. 你不能这样做。在套接字的整个生命周期中使用相同的流。

2. 您不需要这样做。你可以用Data*Stream 做的任何事情都可以用Object*Stream, 做，因为Data*Stream 实现了Data*Put 和Object*Stream 实现了Object*Put，并且Object*Put 扩展了Data*Put。

它似乎建立得很好，但是当我尝试通过 Data*Stream 从服务器向客户端发送消息时，我得到 java.net.SocketException: socket closed on my client。

这意味着你关闭了流并继续使用它。这是由于您使用了两个流造成的。关闭任何包裹在套接字输入或输出流周围的流会关闭另一个流和套接字。你不需要这个。

（仅在我发送消息时发生）

仅当您读取或写入已关闭的流时才会发生这种情况。

有人能指出我将如何通过流检索 2 种不同类型的信息的正确方向吗？

只需使用Object*Stream的API即可。

（没有采取简单的方法。我不想做 writeObject("[message]"+input); 或任何类似的廉价技巧。

我不知道你为什么认为这是一个“便宜的把戏”。您需要停止做出假设并开始设计。