爪哇 - 保持一个套接字客户端活着读完

Question

我有点新在Java套接字，但这里的是我的问题：

我写了一个客户端线程类，将请求连接到服务器，创建由另一个应用程序（因此我没有为服务器类制作的类）。基本上，这个应用程序将传输一定数量的字节并关闭套接字的服务器端。我已经完全能够接收和处理这些字节。

我的问题是可以在客户端插座被告知“等待”从同一地址/端口的另一连接可用，然后继续读取的字节？ （从本质上说，我运行应用程序时，它读取的字节数和完成了，那么我再次运行应用程序，并在客户端将仍然能够读取）

这里是我的客户线程代码：

public class ClientThread extends Thread{ 

    private Socket soc; 
    private InputStream in; 
    private String host; 
    private int port; 

public ClientThread(String host, int port) 
{ 
    this.host = host; 
    this.port = port; 
    soc = null; 
    in = null; 
} 

public boolean connectToServer() 
{ 
    try { 
     soc = new Socket(host, port); 
     in = new BufferedInputStream(soc.getInputStream()); 
     System.err.println("Connection accepted: "+soc); 
     return true; 
    } catch (UnknownHostException e) { 
     System.err.println("Unable to determine IP of host: "+host+"."); 
     return false; 
    } catch (SocketException e) { 
     System.err.println("Error creating or accessing the socket."); 
     return false; 
    } catch (IOException e) { 
     System.err.println("Couldn't get I/O for the connection to: "+host+"."); 
     return false; 
    } 
} 

public boolean disconnectFromServer() 
{ 
    try { 
     if(in != null) 
      in.close(); 
     if(soc != null && soc.isConnected()) { 
      soc.close(); 
      soc = null; 
      System.err.println("Connection successfully closed!"); 
     } 
     return true; 
    } catch (Exception e) { 
     System.err.println("Exception: "+e); 
     return false; 
    } 
} 

@Override 
public void run() { 
    try { 
     int sz = 0; 
     byte[] tmp = new byte[25]; 
     while(true) 
     { 
       if(sz == -1) { 
        sz = 0; 
       } 
       sz += in.read(tmp, sz, 25-sz); 
       System.out.println(sz); 
       if(sz == 25) { 
        tmp = new byte[25]; 
        for(byte b: tmp) 
         System.out.print(b); 
        sz = 0; 
        Thread.sleep(500); 
       } 

     } 
    } catch (SocketException e) { 
     System.err.println("Connection closed abruptly."); 
    } catch (IOException e) { 
     System.err.println("Couldn't get I/O for the connection to: "+host+"."); 
    } catch (InterruptedException e) { 
     e.printStackTrace(); 
    }  
} 
} 

Answer 1

时accept()回报，只要该插座没有得到关闭，则连接保持开放的服务器将收到一个插座。

所以，当你首次运行时的应用程序，然后关闭服务器，然后运行它第二次，我想连接将被打破，你必须重新初始化。

isConnected()方法会给你一个错误的结果，因为如果你在客户端没有明确地关闭套接字，它总是会返回true。

如果你想确保，你可以一次运行客户端 - 服务器连接，然后关闭服务器，请重新启动它，然后尝试读/从/服务器写作。如果连接中断，则读取结果为-1，写入结果为IOException。