0

クライアントをリッスンしているサーバーソケットを停止するにはどうすればよいですか。私のコードは以下のようになります

 private ServerSocket serverSocket;

class ServerThread implements Runnable {

    private BufferedReader input;
    public void run() {
    Socket socket = null;

        try {
            serverSocket = new ServerSocket(SERVE_LISTEN_RPORT);
        } catch (IOException e) {
            e.printStackTrace();
        }

        while (!Thread.currentThread().isInterrupted()) {

            try {

                socket = serverSocket.accept();
                try {

        this.input = new BufferedReader(new InputStreamReader(socket.getInputStream()));

                } catch (IOException e) {
                    e.printStackTrace();
                }

                try {
                     String read = input.readLine();
                                 //Do something
                    }

                } catch (IOException e) {
                    e.printStackTrace();
                }

            } catch (IOException e) {
                e.printStackTrace();
            }
        }


             try {
              serverSocket.close();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

    }
}

別のスレッドからコマンドを取得したときに、このスレッドを停止する必要があります。私はすでにこの質問をしていますが、それを実装する方法がわかりません。

4

2 に答える 2

2

他のスレッドからソケットを閉じる方法の例を次に示します。

private static volatile ServerSocket serverSocket;

public static void main(String[] args) throws InterruptedException, IOException {
    Thread serverThread = new Thread(new ServerThread());
    serverThread.start();
    Thread.sleep(1000); // wait a  bit, then close
    serverSocket.close();
}

static class ServerThread implements Runnable {

    private BufferedReader input;

    public void run() {
        try {
            serverSocket = new ServerSocket(25);
            while (true) {
                Socket socket = serverSocket.accept();
                // client request handling logic
            }

        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}
于 2013-08-31T10:14:37.767 に答える
1

サーバー ソケットはrun()メソッドの外にある必要があり、スレッドによって共有される必要があります。

呼び出しているスレッドを中断する必要がある場合socket.accept()、他のスレッドが呼び出しsocket.close()てaccept()例外をスローすることができます。

于 2013-08-31T10:11:14.960 に答える