损坏的inputStream

Question

它在客户端代码的最后一行中出现错误，并带有代码。 java.io.StreamCorruptedException：无效的流标题：36353137.在这之前，我还没有对流做过任何事情，所以我不确定可能导致ObjectInputStream的问题。

服务器类正常工作，并遵循我为它设置的行为，它只是客户端类错误。

我以为这个问题起初可能是因为流没有被刷新，但是刷新并没有解决问题。

除此之外，由于此错误在代码的早期发生，因此我无法确定要添加哪些内容来修复它。

客户端类 -

import java.io.*; 
import java.net.*; 

public class tcpClient { 

    int nonce; 
    Socket requestSocket; 
    ObjectOutputStream out; 
    ObjectInputStream in; 
    String message; 
    tcpClient(){} 
    void run() 
    { 
     try{ 

      requestSocket = new Socket("localhost", 3223); 
      System.out.println("Connected to localhost in port 3223"); 

      out = new ObjectOutputStream(requestSocket.getOutputStream()); 
      out.flush(); 
      in = new ObjectInputStream(requestSocket.getInputStream()); 

服务器类 -

import java.awt.event.ActionEvent; 
import java.awt.event.ActionListener; 
import java.io.BufferedReader; 
import java.io.InputStreamReader; 
import java.io.PrintStream; 
import java.io.PrintWriter; 
import java.net.InetAddress; 
import java.net.ServerSocket; 
import java.net.Socket; 
import java.util.Calendar; 
import java.util.Random; 
import java.util.Scanner; 
import javax.swing.Timer; 

public class TCPMasterServer 
    implements ActionListener 
{ 
    ServerSocket server; 
    Socket client; 
    Random random; 
    Calendar rightNow; 
    Timer timer; 
    String ipaddress; 
    PrintWriter out; 
    BufferedReader ir; 

    public TCPMasterServer() 
    { 
    this.random = new Random(); 
    this.rightNow = Calendar.getInstance(); 
    try 
    { 
     this.server = new ServerSocket(3223); 
    } 
    catch (Exception e) 
    { 
     e.printStackTrace(); 
    } 
    } 

    private void listenForConnection() 
    { 
    try 
    { 
     this.client = this.server.accept(); 
     this.ipaddress = this.client.getInetAddress().getHostAddress(); 
     System.out.println(this.rightNow.getTime() + ": Connected from: " + this.ipaddress); 

     this.out = new PrintWriter(this.client.getOutputStream(), true); 
     this.ir = new BufferedReader(new InputStreamReader(this.client.getInputStream())); 

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

    private void communicateWithClient() 
    { 
    this.timer = new Timer(2000, this); 
    this.timer.setRepeats(false); 
    this.timer.start(); 
    try 
    { 
     int nonce = this.random.nextInt(1000000); 
     this.out.println(nonce); 
     System.out.println(this.rightNow.getTime() + ": Send nonce: " + nonce); 


     String input = this.ir.readLine(); 
     Scanner in = new Scanner(input); 
     int nonceResponse = in.nextInt(); 

     System.out.print(this.rightNow.getTime() + ": Received number: " + nonceResponse); 
     if (nonceResponse == nonce + 1) 
     { 
     System.out.println("... OK"); 


     this.out.println("SEND_NAME"); 
     System.out.println(this.rightNow.getTime() + ": Request name"); 

     input = this.ir.readLine(); 
     System.out.println(this.rightNow.getTime() + ": Received name: " + input); 


     this.out.println(input + " ACK"); 
     System.out.println(this.rightNow.getTime() + ": ACK sent"); 
     } 
     this.client.close(); 
    } 
    catch (Exception ex) 
    { 
     System.out.println(this.rightNow.getTime() + ": Error happened. Giving up"); 
    } 
    this.timer.stop(); 
    System.out.println(); 
    listenForConnection(); 
    } 

    public void actionPerformed(ActionEvent evt) 
    { 
    try 
    { 
     System.out.println("Timer fired."); 
     this.client.close(); 
    } 
    catch (Exception e) 
    { 
     e.printStackTrace(); 
    } 
    } 

    public static void main(String[] args) 
    { 
    TCPMasterServer server = new TCPMasterServer(); 
    server.listenForConnection(); 
    } 
} 

Answer 1

您使用对象流在服务器上，但在客户端的读者和作家。这是行不通的。如果你想读对象，你必须写对象。