Java 资源尝试卡住

Question

我有一个经典的服务器多客户端程序。服务器监听 ServerSocket，并为每个传入的套接字构建一个新的 Runnable 类并在 ExecuteService 中执行它。

在 Runnable 类的 run 方法中，我打开 try-with-resources block ，并且在 try 中我有一个 while 循环，它从输入流读取并写入输出流，直到收到来自客户端的 FIN 命令。一切正常，客户端成功断开连接。运行到达finally block 并打印一些内容进行测试，但它不会退出try block ，因此它不会退出run方法，并且我被困在运行中的某个地方，可能是输入流的读取方法。

如果有人感兴趣，我可以发布代码。

如何强制关闭finally中的所有内容并退出run方法？

代码:
服务器.java:

public static void main(String[] args) {
    playersReady = new ArrayList<Integer>();
    ServerSocket server = null;
    try {
        server = new ServerSocket(Consts.PORT);
        ExecutorService service = Executors.newFixedThreadPool(characters.size());
        while(playersReady.size()<characters.size()){
            RequestHandler handler = new RequestHandler(server.accept());
            service.execute(handler);
        }
        service.shutdownNow();
        service.shutdown();
        while(!service.isTerminated()){}

        System.out.println("finished");

<小时/>

RequestHandler.java

public final class RequestHandler implements Runnable {

    .....

public void run() {
    //DataOutputStream output = null;
    //DataInputStream input = null;

    try (DataOutputStream output = new DataOutputStream(socket.getOutputStream());
            DataInputStream input = new DataInputStream(socket.getInputStream())){
        // socket.setSoTimeout(500);
        handleReady(input.readUTF().split(" "), output);
        while (/*!shutdown && !socket.isClosed() && */socket.isConnected()) {

            System.out.println("check before read " + character.getId());
            String request = input.readUTF();
            System.out.println("check after read " + character.getId());

            System.out.println("-----------------------------------" + request);
            if (shutdown) {
                socket.shutdownInput();
                socket.getOutputStream().flush();
                socket.shutdownOutput();
                break;
            }
            String[] requestParser = request.split(" ");
            if (requestParser[1].equals("DMG")) {
                // handle damage request
                handleDamage(requestParser, output);
            } else if (requestParser[1].equals("BND")) {
                // handle bandage request
                handleBandage(requestParser, output);
            } else if (requestParser[1].equals("FIN")) {
                // handle finish request
                handleFin();
                if (!socket.isClosed())
                    socket.shutdownInput();
                if (!socket.isClosed()) {
                    socket.getOutputStream().flush();
                    socket.shutdownOutput();
                }
                shutdown = true;
                break;
            } else {
                break;
            }
        }
    } catch (SocketTimeoutException e) {
        System.out.println(e.getMessage());
    } catch (IOException e) {
        e.printStackTrace();
        shutdown = true;
        break;
    } catch (Throwable e) {
        e.printStackTrace();
    } finally {
        try {
            System.out.println("finished");

            if (!socket.isClosed())
                socket.shutdownInput();
            if (!socket.isClosed()) {
                socket.getOutputStream().flush();
                socket.shutdownOutput();
                socket.close();
            }
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    System.out.println("Done run");
}

...

<小时/>

最后打印出System.out.println("finished")，但是 run 方法末尾的 System.out.println("Done run") 却没有!!

为什么？
它卡在了 run 方法中，我想是在 readUTF 调用中，但我关闭了所有资源!

Answer 1

您在该行之前返回，这就是它不运行的原因。无论如何，finally block 都会运行，因为它是一个finally block 。 finally block 总是会运行，这一规则只有一个异常(exception):System.exit()，但事实并非如此。