我想发送通过 TCP 连接序列化的数据。我创建了一个客户端/服务器连接,并在序列化后发送一个对象。但是,我不知道我应该如何读取数据。
这是代码片段:
发送功能:
sendTo(String receiverAddr, int receiverPort,....., Object data) {
.
.
.
if (data != null) {
byte[] byteObj = programming5.io.Serializer.serializeBytes(data);
output.writeInt(byteObj.length);
output.write(byteObj, 0, byteObj.length);
output.flush();
}
output.close();
sock.close();
}
函数调用:
String hostname = somevalue;
int portNo = somevalue;
Hashtable <Integer, Integer> object = somevalue;
sendTo(hostname,portNo,...,object);
接收功能:
DataInputStream input = new DataInputStream(clientSocket.getInputStream());
int length = input.readInt();
byte[] bytes = new byte[length];
input.readFully(bytes);
Hashtable<Integer, Integer> recvObj = (Hashtable<Integer,Integer)programming5.io.Serializer.deserialize(bytes);
这是行不通的。我收到以下异常:
无效的流标头:07F8ACED java.io.StreamCorruptedException:无效的流标头:07F8ACED
请告诉我该怎么做。