0

为什么客户端代码不终止?(我们需要先启动服务端程序再运行客户端)

服务器代码:

public class ServerSocketTest {

    static final int PORT = 9999;

    public static void main(String[] args) throws IOException {
        final ServerSocket serverSocket = new ServerSocket(PORT);

        Runtime.getRuntime().addShutdownHook(new Thread() {
            @Override
            public void run() {
                try {
                    serverSocket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        });

        while (true) {
            final Socket socket = serverSocket.accept();
            Runnable runnable = new Runnable() {

                @Override
                public void run() {
                    System.out.println(socket);
                }
            };
            Thread thread = new Thread(runnable);
            thread.start();
        }

    }

}

客户端代码:

public class SocketClient {

    public static void main(String[] args) throws UnknownHostException,
            IOException {
        final Socket socket = new Socket("localhost", ServerSocketTest.PORT);

        Runtime.getRuntime().addShutdownHook(new Thread() {
            @Override
            public void run() {
                System.out.println("waiting to close socket " );
                printThread(Thread.currentThread());
                try {                   
                    socket.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });

        Runtime.getRuntime().addShutdownHook(new Thread() {
            @Override
            public void run() {
                System.out.println("waiting to exit");
                printThread(Thread.currentThread());                
                System.exit(0);
            }
        });
    }

    static void printThread(Thread currentThread) {
        System.out.println(currentThread + ": Alive=" + currentThread.isAlive()
                + ",Daemon=" + currentThread.isDaemon());
    }
}

我使用 Ubuntu。使用 jconsole,我可以跟踪以下线程以及其他一些 RMI 和 JMX 线程:


名称:参考处理程序状态:在 java.lang.ref.Reference$Lock@14f38ff 上等待总阻塞:1 总等待:2

堆栈跟踪:

java.lang.Object.wait(Native Method)
java.lang.Object.wait(Object.java:503)
java.lang.ref.Reference$ReferenceHandler.run(Reference.java:133)

名称:终结器状态:在 java.lang.ref.ReferenceQueue$Lock@3037a0 上等待总阻塞:1 总等待:2

堆栈跟踪:

java.lang.Object.wait(Native Method)
java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:135)
java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:151)
java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:177)

名称:信号调度器状态:RUNNABLE 总阻塞:0 总等待:0

堆栈跟踪:


名称:DestroyJavaVM 状态:WAITING on net.SocketClient$2@39b27b 阻塞总数:0 等待总数:1

堆栈跟踪:

java.lang.Object.wait(Native Method)
java.lang.Thread.join(Thread.java:1258)
java.lang.Thread.join(Thread.java:1332)
java.lang.ApplicationShutdownHooks.runHooks(ApplicationShutdownHooks.java:106)
java.lang.ApplicationShutdownHooks$1.run(ApplicationShutdownHooks.java:46)
java.lang.Shutdown.runHooks(Shutdown.java:123)
java.lang.Shutdown.sequence(Shutdown.java:167)
java.lang.Shutdown.shutdown(Shutdown.java:234)
- locked java.lang.Class@127bd04

名称:Thread-1(这是我为调用 System.exit 添加的关闭挂钩) 状态:在 java.lang.Class@127bd04 上被阻塞 拥有者:DestroyJavaVM 阻塞总数:1 等待总数:0

堆栈跟踪:

java.lang.Shutdown.exit(Shutdown.java:212)
java.lang.Runtime.exit(Runtime.java:107)
java.lang.System.exit(System.java:960)
net.SocketClient$2.run(SocketClient.java:31)

名称:SIGINT 处理程序(这似乎是在按下 Control+C 时生成的)状态:在 java.lang.Class@127bd04 上被阻塞,拥有者:DestroyJavaVM 阻塞总数:1 等待总数:0

堆栈跟踪:

java.lang.Shutdown.exit(Shutdown.java:212)
java.lang.Terminator$1.handle(Terminator.java:52)
sun.misc.Signal$1.run(Signal.java:212)
java.lang.Thread.run(Thread.java:722)
4

3 回答 3

0

它不会停止,因为您正在运行实时线程(您的钩子)。还是您的意思是即使在向 java 进程发送 SIGTERM 或 SIGINT 信号后也无法停止它?

于 2012-07-21T07:10:16.277 回答
0

我不确定我在addShutdownHook这里看到使用的意义。从文档中:

关闭挂钩也应该快速完成它们的工作。当程序调用 exit 时,期望虚拟机将立即关闭并退出。当虚拟机由于用户注销或系统关闭而终止时,底层操作系统可能只允许关闭和退出的固定时间量。因此,不建议尝试任何用户交互或在关闭挂钩中执行长时间运行的计算。

当然不需要socket.close()终止,因为如果您的代码没有机会关闭它,操作系统会自动为您执行此操作。我会尝试在不使用关闭挂钩的情况下重新编写您的代码。

于 2012-07-21T07:15:06.827 回答
0

您不需要在关闭挂钩中调用 System.exit(),而且您当然不应该这样做,因为它可能会产生死锁或无限递归。你也不需要其他的。最好让你的线程守护线程。

于 2012-07-22T05:35:33.187 回答