java - 套接字传输

Question

我有几个类同时运行，它们从服务器获取输入。两者都设置了套接字。

问题是，即使我在类之间传输相同的数据，当数据到达时，它并不相同。

发送方法如下:

        private boolean transferBroadcastData() {
            boolean success = false;

            try {           
                Vector<Client> clientsList =
                    onlineList.getClientsList();

                for (Client client : clientsList) {
                        ObjectOutputStream objectOutputStream =
                            client.getObjectOutputStream();
                            objectOutputStream.writeObject(clientsList);
                            objectOutputStream.flush();
                }


                success = true;

            } catch (Exception ioException) {
                ioException.printStackTrace();
            }

            return success;
        }

这是接收方法:

        while (true) {
                try {
                    Object object = objectInputStream.readObject();

                    if (object instanceof Vector<?>) {
                        String x = "I got it:\n";

                        Vector<Client> clients = (Vector<Client>) object;

                        for(Client c : clients) {
                            x += "\n" + c;
                        }

                        JOptionPane.showMessageDialog(ClientManager.this, x);

                        usersPanel.addClientsToList((Vector<Client>) object);
                    }

                    else if (object instanceof Message)
                        messagePanel.appendText((Message) object);


                } catch (ClassNotFoundException classNotFoundException) {
                    statusPanel.updateStatus("Error reading from socket");
                }
            }

当我在所有客户端上收到 vector 时，其中的元素是不同的。这不是我尝试传输的 Vector 的内容。

我错过了什么？

Answer 1

问题可能与您使用 Serialization/ObjectOutputStream 有关。当对象被序列化时，ObjectOutputStream 会保留内部记录以“优化”序列化过程，因此，如果您将同一个对象序列化两次，它只会重复 ID 并假设该对象没有更改。例如，如果您运行代码:

ObjectOutputStream oos = new ObjectOutputStream();
MyObject[] arr = new MyObject[]{myObject};
oos.write(myObject);
oos.write(arr);

输出可能如下所示(注意不是实际格式，只是一个示例):

[[myObject;id=357;foo=bar;baz=36;]]
[[MyObject[];id=358;data={id=357}]]

请注意，数组不会再次序列化对象，而只是已序列化版本的 id。如果您有代码，则更进一步:

ObjectOutputStream oos = new ObjectOutputStream();
oos.write(myObject);
myObject.setBaz(99999);
oos.write(myObject);

你最终会得到:

[[myObject;id=357;foo=bar;baz=36;]]
{id=357}

请注意，即使对象发生更改，也只会序列化内部 ID。诀窍是，当您编写对象时，您需要清除 ObjectOutputStream 的内部状态，这可以通过 reset() 来完成。来自javadoc:

Reset will disregard the state of any objects already written to the stream. The state is reset to be the same as a new ObjectOutputStream.

因此，如果您采用前面的示例并添加重置:

ObjectOutputStream oos = new ObjectOutputStream();
oos.write(myObject);
myObject.setBaz(99999);
oos.reset();
oos.write(myObject);

您应该得到以下预期行为作为输出:

[[myObject;id=357;foo=bar;baz=36;]]
[[myObject;id=358;foo=bar;baz=99999;]]

需要注意的一件事是，第二个序列化现在将被视为与原始序列化不同的对象。根据您传输数据的方式和内部关系，如果对象彼此共享引用并且您希望维护这些关系，则必须小心不要过早重置流。