如何确定当前客户端套接字已关闭并连接到另一台服务器？

Question

我希望在代码中实现一个处理程序，如果连接到客户端的服务器在10秒后没有响应，则允许客户端自动连接到同一网络上的服务器的第二个实例。我做错了什么？？

private static void connectToServer(String serverHostname, int port) throws UnknownHostException, IOException
    {
        try {
            echoSocket = new Socket(serverHostname, 10118);
            out = new PrintWriter(echoSocket.getOutputStream(), true);
            in = new BufferedReader(new InputStreamReader(echoSocket
                    .getInputStream()));
        } catch (UnknownHostException e) {
            System.err.println("Unknown host: " + serverHostname);
            System.exit(1);
        } catch (IOException e) {
            System.err.println("Not connected to server: "
                    + serverHostname);
            System.exit(1);
        }
    }





 public static void main(String[] args) throws IOException {
            listServer.add("10.196.113.31");
            listServer.add("10.196.113.27");
            BufferedReader stdIn = new BufferedReader(new InputStreamReader(
                    System.in));
            try {


            if (args.length > 0)
                serverHostname = args[0];
            System.out.println("Trying to connect to host " + serverHostname
                    + " at port 10118.");


            connectToServer(getServer(), 10118);
            echoSocket.setSoTimeout(10000);

            String userInput;
            System.out.print("Input: ");

                while ((userInput = stdIn.readLine()) != null) {
                    out.println(userInput);

                    if (!echoSocket.isConnected()) connectToServer(serverHostname, 10118);

                    System.out.println("echo: " + in.readLine());
                    System.out.print("Input: ");
                }
            } catch (SocketTimeoutException e) {
                NextServer();
                connectToServer(getServer(), 10118);
                System.out.println("Timeout");
                // TODO: handle exception
            }


            out.close();
            in.close();
            stdIn.close();
            echoSocket.close();
        }

        private static void NextServer(){
            idServer ++;        
        }

        private static String getServer(){
            return listServer.get(idServer);
        }

当我运行服务器，然后是客户端时，一切都很好。然后我在同一网络上的另一台机器上启动第二个服务器，并尝试从同一客户端发送文本，客户端应该自动检测到第一个服务器断开连接，连接到服务器的第二个实例并发送文本消息。下面是我得到的例外：

线程“main”java.net.socketException中的异常：在sun.nio.cs.streamdecoder.readbytes（未知源）sun.nio.cs.streamdecoder.impread（未知源）sun.nio.cs.streamdecoder.read（未知源）sun.nio.cs.streamdecoder.read（未知源）java.io.inputstreamreader.read（未知源）java.io.bufferedreader.fill（未知源）java.io.bufferedreader.read（未知源）

Answer 1

如果您希望客户端在服务器断开连接时执行某些操作，那么您需要做的不仅仅是捕获SocketTimeoutException。如stacktrace所示，删除的连接将导致抛出一般的SocketException。你也应该抓住这个。

换句话说，看起来您只处理从客户机到服务器的初始连接失败的情况；您不处理现有条件被删除的情况。