Java在侦听主线程中的套接字时读取线程中的控制台输入

Question

我对套接字和以这种方式使用线程相当陌生。

我遇到了一个问题，一个扫描器在等待用户输入，一个输入流阅读器在等待套接字通信。我的程序试图与客户机/服务器系统通信，这很好，但我也希望能够通过扫描仪或类似的东西直接将命令输入控制台。但是，主线程的while循环阻塞了套接字通信，而扫描器阻塞了InputThread的while循环。

我的问题是，如果我在控制台中发送命令关闭服务器（将布尔'running'设置为false)，主线程的while循环仍然等待套接字通信输入。一旦它接收到任何消息，它就会逃离while循环，因为bool'running'被设置为false，但只有当任何消息被发送时，它才会在检查while的条件之前等待消息。

我的另一个问题是基本相同的概念，但在InputThread的while循环中。如果主线程的while循环中断，那么输入线程仍然会阻止扫描器，直到它接收到用户输入。一旦它接收到任何用户输入，它就会因为线程被中断而脱离while循环（while循环的条件）。

因此，为了让我的程序退出，我必须通过套接字和用户输入发送“重启服务器”消息，当我想以任何一种方式发送它时，程序才能正确退出。

我怎么解决这个问题？我会假设当我接收到结束服务器的套接字时取消扫描器的阻塞，但我如何做到这一点？我觉得有更好的方法，有什么想法吗？

inputThread = new Thread(new Runnable() {
    @Override
    public void run() {
        Logger.log("Starting input thread...");
        while(!Thread.currentThread().isInterrupted()) {
            try {
                scanner = new Scanner(System.in);
                String reply = runCommand(scanner.nextLine());
                Logger.log(reply);
                if(reply.equals("server restarted")) {
                    // TODO: Cancel socket input blocking?
                }
            } catch(Exception e) {
                e.printStackTrace();
            }
        }
        Logger.log("Closing input thread...");
    }
});
inputThread.start();
ServerSocket socket = null;
InputStreamReader inputStream = null;
BufferedReader input = null;
try {
    int port = getPort();
    socket = new ServerSocket(port);
    Logger.log("Server running on port " + port);
    while(running) {
        connection = socket.accept();
        inputStream = new InputStreamReader(connection.getInputStream());
        input = new BufferedReader(inputStream);
        String reply = runCommand(input.readLine());
        if(reply.equals("server restarted")) {
            // TODO: Cancel scanner input blocking?
        }
        reply(reply);
    }
} catch(Exception e) {
    e.printStackTrace();
} finally {
    if(socket != null) {
        try {
            socket.close();
        } catch(IOException e) {
            e.printStackTrace();
        }
    }
    if(connection != null) {
        try {
            connection.close();
        } catch(IOException e) {
            e.printStackTrace();
        }
    }
    if(inputStream != null) {
        try {
            inputStream.close();
        } catch(IOException e) {
            e.printStackTrace();
        }
    }
    if(input != null) {
        try {
            input.close();
        } catch(IOException e) {
            e.printStackTrace();
        }
    }
    if(response != null) {
        try {
            response.close();
        } catch(IOException e) {
            e.printStackTrace();
        }
    }
}
inputThread.interrupt();

谢谢你的阅读

Answer 1

第一个问题是ServerSocket::Accept调用。它正在阻塞，但不响应中断（如果是的话，它将被声明为抛出interruptedexception)。立即解除阻塞的方法是从另一个线程关闭套接字。然后，accept()调用将立即抛出SocketException。

第二个问题实际上更容易解决：while循环也应该检查running标志。因此，当给出命令行输入以停止程序时，输入线程不会开始等待下一个命令。