java.io.StreamCorruptedException：无效类型代码：00
Posted
技术标签:
【中文标题】java.io.StreamCorruptedException：无效类型代码：00【英文标题】：java.io.StreamCorruptedException: invalid type code: 00 【发布时间】：2012-06-02 07:02:04 【问题描述】：所以基本上我正在编写一个客户端-服务器多人游戏。 我有一个 SeverCommunicationThread，如果他收到 RequestForGame 创建一个游戏线程，它会创建一个游戏线程。 当我发送 RequestForGame 时抛出异常 java.io.StreamCorruptedException: invalid type code: 00 我认为这是因为两个线程都试图读取相同的 ObjectInputStream，我对它的工作原理不太了解，我只知道如何使用它。您能帮我了解问题所在以及如何解决吗？ 谢谢:)
public class ServerCommunicationThread extends Thread
private Socket connectionSocket;
private ObjectInputStream inFromClient;
private ObjectOutputStream outToClient;
private String nickname;
private ServerModelManager model;
public ServerCommunicationThread(Socket connectionSocket,
ServerModelManager model) throws IOException
this.connectionSocket = connectionSocket;
inFromClient = new ObjectInputStream(connectionSocket.getInputStream());
outToClient = new ObjectOutputStream(connectionSocket.getOutputStream());
this.model = model;
start();
public void run()
try
String nickname = (String) inFromClient.readObject();
if (model.exists(nickname))
System.out.println(nickname + " already exists");
outToClient.writeObject(new MessageForClient("Please choose another nickname"));
else
System.out.println(nickname + " connected, adding to list");
model.addClient(nickname, connectionSocket,outToClient,inFromClient);
this.nickname=nickname;
while(true)
Object o= inFromClient.readObject();//StreamCorruptedexception
if(o instanceof RequestForGame)
RequestForGame r=(RequestForGame)o;
String userToPlayWith=r.getUserToPlayWith();
if(userToPlayWith.equals(nickname))
String message="Playing with yourself makes your palms hairy, choose another opponent";
outToClient.writeObject(message);
else
System.out.println("received request to play with "+userToPlayWith+". starting game");
ClientRepresentative client1=model.getClient(nickname);
ClientRepresentative client2=model.getClient(userToPlayWith);
ServerGameThread s=new ServerGameThread(client2,client1,client2.getInStream(),client1.getInStream(),client1.getOutStream(),client2.getOutStream());
else if(o instanceof String)
String s=(String) o;
if(s.equals("i want to quit"))
model.deleteClient(nickname);
inFromClient.close();
String q="quit";
outToClient.writeObject(q);
connectionSocket.close();
System.out.println(nickname+"has quit without exc");
catch (EOFException e)
System.out.println(nickname+" has quit");
catch (SocketException e)
System.out.println(nickname+" has quit");
catch (Exception e)
e.printStackTrace();
public class ServerGameThread extends Thread
private ClientRepresentative client1,client2;
private ObjectInputStream inFromClient1,inFromClient2;
private ObjectOutputStream outToClient1,outToClient2;
private Field gameField;
public ServerGameThread(ClientRepresentative client1, ClientRepresentative client2,ObjectInputStream inFromClient1,ObjectInputStream inFromClient2,ObjectOutputStream outToClient1,ObjectOutputStream outToClient2)
System.out.println("startin game thred");
this.client1=client1;//client 1 goes first
this.client2=client2;//client 2 started game
this.inFromClient1=inFromClient1;
this.inFromClient2=inFromClient2;
this.outToClient1=outToClient1;
this.outToClient2=outToClient2;
gameField=new Field();
System.out.println("check");
start();
public void run()
System.out.println("Starting game. players: "+client1.getNickname()+";"+client2.getNickname());
try
outToClient1.writeObject(gameField);
outToClient2.writeObject(gameField);
while(true)
try
System.out.println("listening to "+client1.getNickname());
Object o1=inFromClient1.readObject();//read move from client 1.**//StreamCorruptedexception**
while(!(o1 instanceof PlayerMove))
o1=inFromClient1.readObject();//read move from client 1.
PlayerMove move1=(PlayerMove)o1;
System.out.println("received move "+move1+" sending to "+client2.getNickname());
outToClient2.writeObject(move1);
System.out.println("listening to "+client2.getNickname());
Object o2=inFromClient2.readObject();//read move from client 1.
while(!(o2 instanceof PlayerMove))
o2=inFromClient2.readObject();//read move from client 1.
PlayerMove move2=(PlayerMove)o2;
System.out.println("received move "+move2+" sending to "+client1.getNickname());
outToClient1.writeObject(move2);
catch (ClassNotFoundException e)
// TODO Auto-generated catch block
e.printStackTrace();
catch (IOException e)
// TODO Auto-generated catch block
e.printStackTrace();
model.addClient 方法虽然我不认为问题出在这里
public void addClient(String nickname, Socket clientSocket,ObjectOutputStream stream,ObjectInputStream inStream)
clients.addClient(nickname, clientSocket,stream,inStream);//add to arraylist
//send client list to all clients
String[] users=this.getAvailableClients();
ObjectOutputStream[] streams=clients.getOutStreams();
for(int i=0;i<streams.length;i++)
try
streams[i].writeObject(users);
catch (IOException e)
// TODO Auto-generated catch block
e.printStackTrace();
将对象发送到服务器的客户端代理，方法由GUI中的用户操作触发
public class Proxy
final int PORT = 1337;
String host;
String nickname;
private Socket clientSocket;
private ObjectOutputStream outToServer;
private ObjectInputStream inFromServer;
private ClientModelManager manager;
public Proxy(String nickname,String host,ClientModelManager manager)
this.nickname=nickname;
this.host=host;
this.manager=manager;
this.connect(nickname);
public void connect(String nick)
Socket clientSocket;
try
clientSocket = new Socket(host, PORT);
System.out.println("client socket created");
outToServer = new ObjectOutputStream(clientSocket.getOutputStream());
inFromServer=new ObjectInputStream(clientSocket.getInputStream());
outToServer.flush();
outToServer.writeObject(nick);
ClientReceiverThread t=new ClientReceiverThread(inFromServer,manager);
t.start();
catch (Exception e)
e.printStackTrace();
public void makeRequest(String user)
try
outToServer.writeObject(new RequestForGame(user));
catch(IOException e)
e.printStackTrace();
public void quit()
try
outToServer.writeObject(new String("i want to quit"));
//clientSocket.close();
catch (IOException e)
e.printStackTrace();
public void sendMove(PlayerMove move)
try
outToServer.writeObject(move);
catch (IOException e)
// TODO Auto-generated catch block
e.printStackTrace();
【问题讨论】：
调用model.addClient(nickname, connectionSocket,outToClient,inFromClient);时ServerModelManager在做什么？其中可能存在破坏流的代码。
addClient（将用户添加到一个ClientRepresantative 类型的ArrayList 中，该ArrayList 包含套接字、对象输出和输入流。）它不读取任何内容
好的。此外，您应该在构造 ObjectOutputStreams 后刷新它们以确保发送标头。这可能是您收到该错误的原因；流标头尚未通过。创建后在客户端和服务器上刷新 ObjectOutputStream。
我添加了冲洗，没有任何改变
您介意在您编写对象的地方添加您的客户端代码吗？
【参考方案1】：
如果您这样做，可能会发生此问题
在同一个套接字上构造一个新的ObjectInputStream 或ObjectOutputStream，而不是在套接字的生命周期内使用相同的；
在同一个套接字上使用另一种流；或者，
使用对象流来读取或写入非对象的内容会导致不同步。
【讨论】：
我首先在两侧（代理、服务器通信线程）创建 ObjectOutputStream。我只构造它一次，然后将它的引用发送给另一个线程。我不使用任何其他类型的流。唯一想到的是我正在尝试同时从 2 个线程中的同一个 ObjectInputStream 读取一个对象。（ServerCommunicationThread，ServerGameThread）这可能是问题吗？ （从异常的位置我会这么认为..） @user1420273 当然可以，除非你有适当的同步。【参考方案2】：如果读取序列化对象的 JVM 没有该对象的正确类/jar 文件，也会发生这种情况。这通常会导致ClassNotFoundException，但如果您有不同的 jar/class 版本并且serialVersionUID 在版本之间没有更改，则会生成StreamCorruptedException。 （如果存在类名冲突，也可能出现此异常。例如：包含具有相同完整类名的不同类的 jar，尽管它们可能也需要相同的 serilVersionUID）。
检查客户端是否有正确版本的 jar 和类文件。
【讨论】：
不，它不能。这种情况会导致 ClassNotFoundException。 我做出了这个答案，因为我通过安装正确的 jar 文件成功地修复了问题中的错误。我相信在我的情况下我有错误的版本（并且版本 UID 没有得到正确维护），虽然它是不久前的......它也可能与类名冲突？ @ejp 我将修改我的答案以指示 jar 文件版本 - 可以随意删除您的反对票，它不会激励一个人为他人提供体验的好处！ 不幸的是，这个世界并不完美，并不是每个人都能正确维护serialVersionUID。没有 serialVersionUID 不匹配 - 它没有在版本之间正确维护。正如我所说，我遇到了问题中所述的错误，并通过安装正确的版本解决了它。这不是误诊！这可能是导致此错误的原因。
以防万一不清楚，通过“未正确维护”，我的意思是说类的 serialVersionUID 在版本之间没有更改。因此版本 UID 匹配，并且引发的异常是 StreamCorruptedException，因为 ObjectInputStream 没有找到与它所期望的元素相对应的元素。相信我，花了一些时间才弄清楚这一点，这个 SO 问题是我寻找答案的地方之一 - 因此我在这里为遇到类似情况的其他人提供它。
到@drevicko 的观点，类似地描述here。【参考方案3】：
如果您通过添加此方法为类实现自定义反序列化例程，我遇到了另一种可能性：
private void readObject( ObjectInputStream objectInputStream ) throws IOException
然后 objectInputStream.defaultReadObject() 必须在任何进一步读取输入流之前调用并调用以正确初始化对象。
我错过了这一点，尽管对象返回时没有抛出异常，但下一次读取对象流时会令人困惑地引发无效类型代码异常。
此链接提供有关该过程的更多信息：http://osdir.com/ml/java.sun.jini/2003-10/msg00204.html。
【讨论】：
这不是对问题的正确陈述。问题是您必须调用defaultReadObject(). 完成此操作后，读取自己内容的确切字节数并不重要。【参考方案4】：
如果ObjectInputStream 只被构造一次，然后只是将它的引用传递给另一个线程，那么只需将这个对象的访问权限包含在synchronized 块中，以确保一次只有一个线程可以访问这个对象.
当您从 ObjectInputStream 读取时，如果它在多个线程之间共享，只需在 synchronized 块内访问它。
示例代码：（对所有出现的readObject()执行此操作）
...
String nickname = null;
synchronized (inFromClient)
nickname = (String) inFromClient.readObject();
【讨论】：
【参考方案5】：我也有这个例外。发生这种情况是因为我为 Server 类和 Client 类使用了两个线程。我使用一个线程来发送和接收对象。然后就没事了。如果您不熟悉synchronized，这是解决问题的简单方法。
【讨论】：
【参考方案6】：java.io.StreamCorruptedException：无效类型代码：00
我最近遇到了这个问题，但没有像 OP 那样做。做了一个快速的谷歌搜索，并没有找到任何有用的东西，因为我认为我解决了它，所以我对我的解决方案发表评论。
TLDR：不要让多个线程同时写入同一个输出流（而是轮流）。当客户端尝试读取数据时会导致问题。解决方案是锁定写入输出。
我正在做一些与 OP 非常相似的事情，制作多人（客户端-服务器模型）游戏。我有一个像 OP 这样的线程正在监听流量。发生的事情是，在我的服务器端，服务器有多个线程同时写入客户端的流（不认为这是可能的，游戏是半回合制的）。正在读取传入流量的客户端线程抛出此异常。为了解决这个问题，我基本上在写入客户端流（在服务器端）的部分上加了一个锁，这样服务器端的每个线程都必须在写入流之前获得锁。
【讨论】：
以上是关于java.io.StreamCorruptedException：无效类型代码：00的主要内容，如果未能解决你的问题，请参考以下文章