编辑“︁Java异步IO（Java Asynchronous I O）”︁（章节）

=== 案例：异步HTTP服务器 ===  
使用`AsynchronousServerSocketChannel`实现简单HTTP服务器：  

<syntaxhighlight lang="java">  
import java.nio.ByteBuffer;  
import java.nio.channels.*;  
import java.net.InetSocketAddress;  

public class AsyncHttpServer {  
    public static void main(String[] args) throws Exception {  
        AsynchronousServerSocketChannel server = AsynchronousServerSocketChannel.open()  
            .bind(new InetSocketAddress("localhost", 8080));  

        server.accept(null, new CompletionHandler<AsynchronousSocketChannel, Void>() {  
            @Override  
            public void completed(AsynchronousSocketChannel client, Void attachment) {  
                server.accept(null, this); // 接收下一个连接  
                handleRequest(client);  
            }  

            @Override  
            public void failed(Throwable exc, Void attachment) {  
                exc.printStackTrace();  
            }  
        });  

        Thread.sleep(Long.MAX_VALUE);  
    }  

    private static void handleRequest(AsynchronousSocketChannel client) {  
        ByteBuffer buffer = ByteBuffer.allocate(1024);  
        client.read(buffer, buffer, new CompletionHandler<Integer, ByteBuffer>() {  
            @Override  
            public void completed(Integer bytesRead, ByteBuffer attachment) {  
                attachment.flip();  
                String request = new String(attachment.array(), 0, bytesRead);  
                System.out.println("Received: " + request);  

                String response = "HTTP/1.1 200 OK\r\n\r\nHello from AIO Server!";  
                client.write(ByteBuffer.wrap(response.getBytes()));  
            }  

            @Override  
            public void failed(Throwable exc, ByteBuffer attachment) {  
                exc.printStackTrace();  
            }  
        });  
    }  
}  
</syntaxhighlight>