-1

编辑：我在这里上传了一些源代码：http: //stabbedbit.com/MCapp/

我的流有问题，客户端每隔一段时间就会抛出一个 StreamCorruptedException。

例如：

first time: works fine -> exit client application.
second time: StreamCorruptedException -> exit client application.
third time: works fine -> exit client application.
forth time: StreamCorruptedException -> exit client application.

等等。

这是故事（简而言之）

服务器 while(true) 为客户端循环，接受它们，如果接受的客户端退出服务器的 inputStream 抛出一个套接字异常，我捕获并使用它来运行这个位代码：

if(dataSender   != null) dataSender.stop();
if(dataReceiver != null) dataReceiver.stop();

try { if(output  != null) output    .close(); } catch(IOException e) { streamNotClosed("output"); }
try { if(input   != null) input     .close(); } catch(IOException e) { streamNotClosed("input"); }
try { if(cryptOut!= null) cryptOut  .close(); } catch(IOException e) { streamNotClosed("encrypted output"); }
try { if(cryptIn != null) cryptIn   .close(); } catch(IOException e) { streamNotClosed("encrypted input"); }
try { if(clientSocket != null) clientSocket.close(); }
catch(IOException e){ logger.warning(socketNotClosed); }

这一切似乎都很好

客户端和服务器都使用这段代码来初始化流：

cryptOut = new CipherOutputStream(clientSocket.getOutputStream(), protocol.encoder);
output = new ObjectOutputStream(cryptOut);

cryptIn = new CipherInputStream(clientSocket.getInputStream(), protocol.decoder);
input = new ObjectInputStream(cryptIn);

如果一切顺利，一个字符串被交换为握手，用户得到验证，然后输入和输出被转发以由单独的线程处理。

但是当它没有时，在“input = new ObjectInputStream(cryptIn);”处会抛出以下错误

java.io.StreamCorruptedException: invalid stream header: 81C69F13
    at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:801)
    at java.io.ObjectInputStream.<init>(ObjectInputStream.java:298)
    at com.stabbedbit.minecraftRemoteAdmin.desktop.connection.ConnectionManager.run(ConnectionManager.java:89)
    at java.lang.Thread.run(Thread.java:722)

（它抛出的代码（81C69F13）每次都不一样）

我尝试通过在停止线程和关闭流时调用垃圾收集器来解决这个问题。但它没有结果。而且我不知道为什么会发生这种情况。

编辑：如果我连接第二个客户端，我还发现我的服务器中断......

如果有人知道任何可以帮助我的事情，请提前致谢。

4

2 回答 2

0

完成写入后，在输出流中，flush() 流。另外，检查您的密码是否在您的代码中正确初始化/重置

于 2013-07-03T15:01:22.480 回答
-1

也许您需要关闭 ObjectOutputStream 代码；out.close();

于 2013-07-01T17:54:39.717 回答