在 Java 中重置 ObjectOutputStream

Question

我知道以前有人问过这个问题，但是我无法实现如何使用 ObjectOutputStream 多次发送对象，我尝试了这个论坛上人们所说的。 问题是我正在使用多线程和套接字在 Java 中开发一个 Snake 游戏，我已经画了两条蛇，但是我只能将蛇从一条蛇发送到另一条蛇，所以，当我尝试发送另一条蛇时，我得到和 StreamCorruptedException。这是我的代码：

这个方法在我的 Snake 类中，我读过 ObjectOutputStrean 不能多次初始化，但是¿我怎样才能多次发送蛇对象？，这让我很困惑：

 public void sendSnake()
 {
    try
    {
        outputStream=socket.getOutputStream();
        oos=new ObjectOutputStream(outputStream);
        oos.writeObject(snakeBody);
    }catch(IOException ioe)
    {
        ioe.printStackTrace();
    }    
}

问题在于我的代码部分。谢谢。

这是我在 do while 循环中所做的：

 try
 {
      this.sendSnake();
      this.receiveListSnakes();

            for(int i=0; i<listaSnakes.size(); i++)
            {
                for(int j=0; j<listSnake.get(i).tam(); j++)
                {
                    mostrar(listSnake.get(i).take(j).part); //this is for display de snake
                }
            }
 }catch(IOException ioex)
 {
     ioex.printStackTrace();
 }

 if( op.equals("up") ) 
 {
     posy--;
     ...


 public Snake(JFrame screen)
 {
      //above I have created the Socket
      socket=new Socket(ipClient, port);


      outputStream=socket.getOutputStream();
      oos=new ObjectOutputStream(outputStream);

 }

Answer 1

您可以构造一次ObjectOutputStream 并将引用保存为字段。另外，您应该flush()。假设你有一个 Snake 类，我会通过传入 socket.getOutputStream() 来构建类似

private ObjectOutputStream oos;
public Snake(OutputStream os) {
  oos = new ObjectOutputStream(os);
}

public void sendSnake()
{
  try {
    oos.writeObject(snakeBody);
  } catch(IOException ioe) {
    ioe.printStackTrace();
  } finally {
    oos.flush();
  } 
}

然后您可以使用您的Snake 实例多次调用sendSnake，

Snake s = new Snake(socket.getOutputStream());
s.sendSnake();
s.sendSnake();

Answer 2

您必须在套接字的整个生命周期内使用相同的ObjectOutputStream。更准确地说，您必须成对使用ObjectOutputStream 和ObjectInputStream：当您构造一个时，您必须在对等方构造另一个。然而，这基本上是不可能协调的，所以单一的ObjectInput/OutputStream 规则适用。

Snake 不应发送自身，也不应使用 Socket [或任何类型的 OutputStream，与此处的其他答案相反] 构造或构造自身。发送Snake（或其他任何东西）的实体应该拥有套接字和输出流，并且应该进行写入。