1

我正在开展一个学校项目，以下代码是为构建项目提供的示例（应该可以正常工作，但不是......）。没有编译错误，但是当我使用 telnet 对其进行测试时，显示以下消息：

java.io.StreamCorruptedException: invalid stream header: 56543130 
    at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:801)
    at java.io.ObjectInputStream.<init>(ObjectInputStream.java:298)
    at ThreadedDataObjectHandler.run(ThreadedDataObjectServer.java:41)

第 41 行是

ObjectInputStream in =new ObjectInputStream(incoming.getInputStream());

这是我的代码：

import java.io.*;
import java.net.*;
import java.util.*;
public class ThreadedDataObjectServer {  
    public static void main(String[] args ) {  

      try 
  {  ServerSocket s = new ServerSocket(3000);

     for (;;)
     {  Socket incoming = s.accept( );
        new ThreadedDataObjectHandler(incoming).start();

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

class ThreadedDataObjectHandler extends Thread
{
DataObject myObject = null;
private Socket incoming;
private String greeting="Hello!";
public ThreadedDataObjectHandler(Socket incoming) 
   { 
        this.incoming = incoming;
   }

   public void run()
   {  try 
      {     

    ObjectInputStream in =new ObjectInputStream(incoming.getInputStream());

    ObjectOutputStream out =new ObjectOutputStream(incoming.getOutputStream());

    myObject = (DataObject)in.readObject();

    System.out.println("Message read: " + myObject.getMessage());

    myObject.setMessage("Got it!");

    System.out.println("Message written: " + myObject.getMessage());


    out.writeObject(myObject);

    in.close();

    out.close();

    incoming.close();    

  }
  catch (Exception e) 
  {  e.printStackTrace();
  } 
   } 
}
class DataObject implements Serializable{
    protected String message;
    public DataObject(){
        message="";
    }
public void setMessage(String m){
    message=m;
}
    public String getMessage(){
    return message;
    }
}

我尝试的是切换语句的顺序，ObjectInputStream in=...但ObjectOutputStream out=...没有运气。请帮助...谢谢。

4

2 回答 2

2

根据我从评论中了解到的情况，您正在尝试使用 ObjectInputStream 从远程登录连接中读取对象。

你不能这样做。如果要使用 ObjectInputStream，则需要其他连接程序使用 ObjectOutputStream 编写。

你的 telnet 客户端并不真正关心 Java ObjectOutputStream、ObjectInputStream 和序列化。

所以我会尝试像包装在 BufferedReader 中的 InputStreamReader 之类的东西。

如果您只想测试连接性，只需编写一个小型 java 程序，该程序将连接到您的程序，而不是使用 telnet。

于 2013-04-10T05:09:25.150 回答
0

正如我在评论中提到的大卫，您必须编写一个客户端，该客户端使用 ObjectOutputStream 将相同的 DataObject 发送到服务器套接字。

由于您期望 DataObject，因此客户端需要发送 DataObject。当您使用 telnet 时，它会连接，但从那里您无法以 java 对象流理解的方式发送 DataObject。

有关服务器/客户端示例，请参阅http://zeroh.tripod.com/ressources/sockets.html。

此外，由于它的一些学校练习试图理解这个概念，而不仅仅是复制。

于 2013-04-10T05:21:24.330 回答