程序卡在ObjectInputStream构造函数中

Question

嘿，我在试着调试最近2-3天的程序。问题是，我正在构建一个客户端服务器体系结构，所有客户端ping服务器(带着他们的信息)在服务器端使用Socket connection.So一定时间间隔后，当我试图构造一个ObjectOutputStream时，程序会卡住。这是客户的代码。

 public void pingUpdate(){
    Thread pingThread = new Thread() {
    public void run() {
        while(true) {
             try { 
                ping_socket = new Socket( "localhost", 11111 );
                ObjectOutputStream ping_objectOutputStream = new ObjectOutputStream( ping_socket.getOutputStream( ) );
                ping_objectOutputStream.flush();

                ping_objectOutputStream.writeObject( user );

                ping_objectOutputStream.close();

                ping_socket.close( );

             }catch (Exception exception) {
               exception.printStackTrace();
            }
           }
   };
    pingThread.start();
}

这是服务器的代码

  public void run() {
while ( true ) {
      try {

            System.out.println("Server Listening" );

            Socket client = null;

            client = serverSock.accept();
            System.out.println("Accepted" );

             InputStream inputStream = client.getInputStream();

             System.out.println("Input stream established" );

             ObjectInputStream ois = new ObjectInputStream( inputStream );

              System.out.println("Object streams established" );

              User user = ( User ) ois.readObject( );

              System.out.println("Object read" );

               ois.close( );
               client.close( );
             }
              catch (Exception e){
                     e.printStackTrace();
                 }
         }
    }

服务器程序打印直到“输入流建立”并卡住。我不知道为什么会发生这种情况，尽管我在client side.Thanks中刷新了输出流。

Answer 1

我不能复制挂着的客户。我认为应该如何将对象写入流，而不必在流之后刷新，因为只有在流满或关闭之前流才会被刷新。请使用最后块关闭套接字和流。

我重写了您的源代码，并发送了一个字符串"Hallo，Server“，而不是用户对象(在您提供的代码中缺少)。我在发送后增加了一点延迟，因为没有将连接淹没在服务器上。

我已经用JDK 1.8更新102在Win 8.1上测试了代码，现在它可以工作了。

客户端：

import java.io.IOException;
import java.io.ObjectOutputStream;
import java.net.Socket;

public class Client{

   public static void main(String[] args){

      new Client().pingUpdate();
   }

   public void pingUpdate(){

      Thread pingThread = new Thread(){

         @Override
         public void run(){

            while(true){
               Socket ping_socket = null;
               ObjectOutputStream ping_objectOutputStream = null;
               try{
                  ping_socket = new Socket("localhost",
                                           11111);
                  ping_objectOutputStream = new ObjectOutputStream(ping_socket.getOutputStream());

                  ping_objectOutputStream.writeObject("Hallo, Server");
                  ping_objectOutputStream.flush();
               }
               catch(Exception exception){
                  exception.printStackTrace();
               }
               finally{
                  try{
                     if (ping_objectOutputStream != null){
                        ping_objectOutputStream.close();
                     }
                  }
                  catch(IOException e){
                     e.printStackTrace();
                  }
                  try{
                     if (ping_socket != null){
                        ping_socket.close();
                     }
                  }
                  catch(IOException e){
                     e.printStackTrace();
                  }
               }

               // wait some time for the next ping
               try{
                  Thread.sleep(1000);
               }
               catch(InterruptedException e){
                  e.printStackTrace();
               }
            }
         }
      };
      pingThread.start();
   }
}

服务器：

import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server{

   public void servePingUpdate(){

      Thread pingThread = new Thread(){

         @Override
         public void run(){

            ServerSocket serverSock = null;
            try{
               serverSock = new ServerSocket(11111);

               while(true){
                  Socket client = null;
                  ObjectInputStream ois = null;

                  try{
                     System.out.println("Server Listening");

                     client = serverSock.accept();
                     System.out.println("Accepted");

                     InputStream inputStream = client.getInputStream();

                     System.out.println("Input stream established");

                     ois = new ObjectInputStream(inputStream);

                     System.out.println("Object streams established");

                     String message = (String) ois.readObject();

                     System.out.println("Object read: " + message);
                  }
                  catch(Exception e){
                     e.printStackTrace();
                  }
                  finally{
                     try{
                        if (ois != null){
                           ois.close();
                        }
                     }
                     catch(IOException e){
                        e.printStackTrace();
                     }
                     try{
                        if (client != null){
                           client.close();
                        }
                     }
                     catch(IOException e){
                        e.printStackTrace();
                     }
                  }
               }
            }
            catch(IOException e1){
               e1.printStackTrace();
            }
            finally{
               try{
                  if (serverSock != null){
                     serverSock.close();
                  }
               }
               catch(IOException e){
                  e.printStackTrace();
               }
            }
         }
      };
      pingThread.start();
   }

   public static void main(String[] args){

      new Server().servePingUpdate();
   }
}

编辑: TCP协议需要一些时间来进行TCP握手，而服务器需要一些时间通过System.out输出行并关闭套接字。

在没有等待的情况下，客户端会抛出一个已经在使用的java.net.BindException: Address : connect在1-2秒之后，因为服务器没有可用的端口了。对于较低延迟的UDP协议，请参阅UDP定位器的示例代码或保持套接字打开，并在每次ping时重用它。