在服务器上关闭 AtomicBoolean 太晚了（Java）

Question

我正在开发一个客户端-服务器应用程序，我想在通过套接字接收到停止消息时关闭服务器。我的服务器的代码如下所示

public class Server extends Thread {

 private AtomicBoolean running = new AtomicBoolean(true);


  public synchronized void setRunning(boolean value){
        running.set(value);
    }

 public void run(){

        while(running.get()){
                try {
                     clientSocket = serverSocket.accept();
                     //doing stuff...

                }catch (IOException e) {
                    logger.error("{} \n",e.getMessage());
                }
        }

变量 running 设置在另一个处理我的消息的类中。函数是这样写的

public synchronized void onReceive(Message message){

       if(message.equals(stopMessage)){

           server.setRunning(false);
           for(Client c : clients)
               c.shutdown();
           server.shutdown();
       }
}

我的问题是服务器中的 while 循环在将运行变量设置为 false 之前再执行一次迭代，并且服务器尝试检查套接字，即使它为空，因为连接到该套接字的客户端已经关闭（客户端是也是一个线程）。我做错了什么，但我不知道是什么。有任何想法吗？谢谢！

Answer 1

像这样更改您的 while 循环：

while( running.get() )
{
    try( clientSocket = serverSocket.accept() ) 
    {
        if( !running.get() ) break;
        //doing stuff...

    }
    catch( SocketTimeoutException e )
    {
        continue;
    }
    catch( SocketException e )
    {
        if( !serverSocket.isClosed() ) logger.error( "{} \n", e.getMessage() );
        break;
    }
    catch( IOException e ) 
    {
        logger.error( "{} \n", e.getMessage() );
        break;
    }
}

循环在serverSocket.accept() 中等待，并且只会在传入连接或超时时继续。更改 running 不会唤醒它，因此它只会在 while 循环的下一个循环中识别更改。

并且在出现错误异常后，您不应该继续循环。即使是SocketTimeoutException，continue 也可能不正确/不充分。