通过网络发送对象向量

问题描述：

好吧，所以我正在编写一个测试程序来发送从服务器到客户端的对象向量。通过网络发送对象向量

-Server-

import java.net.*; 
import java.util.Vector; 
import java.io.*; 

public class TestServer{ 
    public static void main(String[] args) throws IOException { 

     Vector<Obj> obj = new Vector<Obj>(); 
     obj.add(new Obj(5)); 
     obj.add(new Obj(4)); 
     obj.add(new Obj(7)); 
     obj.add(new Obj(8)); 
     obj.add(new Obj(2)); 

     ServerSocket serverSocket = new ServerSocket(4444); 
     boolean listening = true; 

     while(listening){ 
      new ClientThread(serverSocket.accept(), obj).start(); 
     } 

     serverSocket.close(); 
     System.exit(0); 
    } 
} 

class ClientThread extends Thread implements Runnable{ 
    Socket acceptedSocket; 
    Vector<Obj> obj; 

    public ClientThread(Socket acceptedSocket, Vector<Obj> obj){ 
     super("ClientThread"); 
     this.acceptedSocket = acceptedSocket; 
     this.obj = obj; 
    } 

    public void run(){ 
     try{ 
      Socket clientSocket = acceptedSocket; 
      clientSocket.setTcpNoDelay(true); 
      System.out.println("Accepted. Now creating I/O.\n"); 
      DataInputStream in = new DataInputStream(clientSocket.getInputStream()); 
      ObjectOutputStream out = new ObjectOutputStream(clientSocket.getOutputStream()); 
      System.out.println("player connected. \n"); 
      out.writeObject(obj); 
      out.flush(); 

      while(true){ 
       out.writeObject(obj); 
       out.flush(); 

       sleep(15); 
      } 

     } 

     catch(Exception e){ 
      e.printStackTrace(); 
      System.exit(1); 
     } 


    } 
} 

class Obj implements Serializable{ 
    int i; 

    public Obj(int i){ 
     this.i = i; 
    } 
}

-Client-

import java.net.*; 
import java.util.Vector; 
import java.io.*; 

import javax.swing.JOptionPane; 


public class TestClient { 

    static Vector<Obj> obj; 
    static ClientThread ct; 

    public static void main(String[] args){ 
     obj = new Vector<Obj>(); 
     connect(); 

     for(int i = 0; i < obj.size(); i++){ 
      System.out.println("Obj: " + obj.get(i).i); 
     } 

     System.exit(0); 
    } 

    public static void connect(){ 
     String ip = JOptionPane.showInputDialog("Input server IP."); 
     ct = new ClientThread(ip, obj); 
     ct.start(); 
     ct.setPriority(Thread.MAX_PRIORITY); 
    } 
} 

class Obj implements Serializable{ 
    int i; 

    public Obj(int i){ 
     this.i = i; 
    } 
} 

class ClientThread extends Thread implements Runnable{ 
    Socket socket; 
    Vector<Obj> obj; 
    DataOutputStream out; 
    ObjectInputStream in; 
    boolean loop = true; 

    @SuppressWarnings("unchecked") 
    public ClientThread(String ip, Vector<Obj> obj){ 
     super("ClientThread"); 

     try{ 
      socket = new Socket(ip, 4444); 
      socket.setTcpNoDelay(true); 
      out = new DataOutputStream(socket.getOutputStream()); 
      in = new ObjectInputStream(socket.getInputStream()); 
      this.obj = obj; 
      this.obj = (Vector<Obj>) in.readObject(); 
     } 

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

    public void run(){ 
     try{ 
      while(loop){ 
       try{ 
        if(!socket.isClosed() && socket.isConnected()){   
         obj = (Vector<Obj>) in.readObject(); 
         this.sleep(15); 
        } 

        else 
         loop = false; 

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



     } 

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

4444端口已经打开。

收到此错误：

Accepted. Now creating I/O. 

player connected. 

java.net.SocketException: Connection reset by peer: socket write error 
    at java.net.SocketOutputStream.socketWrite0(Native Method) 
    at java.net.SocketOutputStream.socketWrite(Unknown Source) 
    at java.net.SocketOutputStream.write(Unknown Source) 
    at java.io.ObjectOutputStream$BlockDataOutputStream.drain(Unknown Source) 
    at java.io.ObjectOutputStream$BlockDataOutputStream.setBlockDataMode(Unknown Source) 
    at java.io.ObjectOutputStream.writeNonProxyDesc(Unknown Source) 
    at java.io.ObjectOutputStream.writeClassDesc(Unknown Source) 
    at java.io.ObjectOutputStream.writeOrdinaryObject(Unknown Source) 
    at java.io.ObjectOutputStream.writeObject0(Unknown Source) 
    at java.io.ObjectOutputStream.writeFatalException(Unknown Source) 
    at java.io.ObjectOutputStream.writeObject(Unknown Source) 
    at ClientThread.run(TestServer.java:49)

答

你，因为客户端 System.exit（0）终止了这个错误; 呼叫21行。

我看到它只是一个测试，但它也是在测试中编写小心代码的好方法。次使用权的知名度变质剂 -close流在finally块次使用ArrayList的，而不是载体，如果你不需要用它操作过程中的线程安全 -etc

此代码包含了许多潜在的错误，这就是为什么真正的（很简单）问题没有在第一个站点注意到。

答

你得到这个错误是因为客户端以第21行中的System.exit（0）终止，它关闭了连接，，并且在另一端关闭后一直写入连接。这不是一个现实的情况，在这种情况下你不应该这样做，或者这是一个现实的情况，在这种情况下，你应该期望在写入时获得连接重置。

通过网络发送对象向量

相关推荐