【问题标题】:Java try-with-recourses stuckJava try-with-resources 卡住了
【发布时间】:2017-05-09 13:23:01
【问题描述】:

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

在 Runnable 类的 run 方法中,我打开 try-with-resources 块,在 try 中我有一个 while 循环,它从 inputstream 读取并写入 outputstream,直到它收到来自客户端的 FIN 命令。一切正常,客户端成功断开连接。运行到达 finally 块并打印一些用于测试的东西,但它没有退出 try 块,因此它没有退出 run 方法,我被困在 run 的某个地方,可能是输入流的 read 方法。

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

如何强制关闭 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");
}

....


finally 中的System.out.println("finished") 被打印出来, 但是run方法末尾的System.out.println("Done run")没有!!

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

【问题讨论】:

  • 你试过调试你的程序吗?您的“我认为在 readUTF 调用中”有点含糊。
  • 我试过了,没什么特别的,它通过了run方法,上到java的Runnable类并停止,但线程继续运行

标签: java sockets try-with-resources


【解决方案1】:

您在该行之前返回,这就是它没有运行的原因。 finally 块无论如何都会运行,因为它是一个 finally 块。 finally 块总是运行,这条规则只有一个例外:System.exit(),但事实并非如此。

【讨论】:

  • 哪一行? run 方法运行完美,它只是不会停止,也不会停止关联的线程
  • 哦,我明白了,我将每个“return”语句都更改为“break”。它现在打印最终的打印命令,但线程并没有停止,我的意思是它不会继续服务器的运行方法
猜你喜欢
  • 2013-07-21
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2013-06-30
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
相关资源
最近更新 更多