Basic code example for AsynchronousServerSocketChannel.

AsynchronousServerSocketChannelTest.java

AsynchronousServerSocketChannel listener = AsynchronousServerSocketChannel.open().bind(new InetSocketAddress(ip, port));

while (true) {

    Future<AsynchronousSocketChannel> future = listener.accept();
    AsynchronousSocketChannel channel = future.get();

    ByteBuffer buffer = ByteBuffer.allocate(5000);
    Future<Integer> byteCount = channel.read(buffer);
    System.out.println("Bytes read: " + byteCount.get());
    System.out.println(new String(buffer.array()));

    String content = "Hello World!";
    String response = "HTTP/1.0 200 OK\nContent-Type: text/plain\nContent-Length: " + content.length() + "\n\n" + content;
    byte[] responseBytes = response.getBytes();
    ByteBuffer responseBuffer = ByteBuffer.wrap(responseBytes);
    byteCount = channel.write(responseBuffer);
    System.out.println("Bytes written: " + byteCount.get());
}