我有几个类同时运行,它们从服务器获取输入。两者都设置了套接字。
问题是,即使我在类之间传输相同的数据,当数据到达时,它并不相同。
发送方法如下:
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 的内容。
我错过了什么?
最佳答案
问题可能与您使用 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;]]
需要注意的一件事是,第二个序列化现在将被视为与原始序列化不同的对象。根据您传输数据的方式和内部关系,如果对象彼此共享引用并且您希望维护这些关系,则必须小心不要过早重置流。
关于java - 套接字传输,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/5246925/