Java NIO Webservers

1-0.java

package net.shadowraze.vote4diamondz;

import java.io.IOException;

import java.net.InetSocketAddress;

import java.nio.ByteBuffer;

import java.nio.CharBuffer;

import java.nio.channels.SelectionKey;

import java.nio.channels.Selector;

import java.nio.channels.ServerSocketChannel;

import java.nio.channels.SocketChannel;

import java.nio.charset.Charset;

import java.nio.charset.CharsetDecoder;

import java.nio.charset.CharsetEncoder;

import java.util.Date;

import java.util.Iterator;

public final class WebServer extends Thread {

private ByteBuffer buf = ByteBuffer.allocate(2048);

private Charset charset = Charset.forName("UTF-8");

private CharsetDecoder decoder = charset.newDecoder();

private CharsetEncoder encoder = charset.newEncoder();

private Selector selector = Selector.open();

private ServerSocketChannel server = ServerSocketChannel.open();

private boolean isRunning = true;

public WebServer(InetSocketAddress address) throws IOException {

super("Web Server - " + address);

server.socket().bind(address);

server.configureBlocking(false);

server.register(selector, SelectionKey.OP_ACCEPT);

}

@Override

public void run() {

try {

while (isRunning) {

selector.select();

Iterator<SelectionKey> i = selector.selectedKeys().iterator();

while (i.hasNext()) {

SelectionKey key = i.next();

i.remove();

if (!key.isValid()) {

continue;

}

try {

// get a new connection

if (key.isAcceptable()) {

// accept them

SocketChannel client = server.accept();

// non blocking please

client.configureBlocking(false);

// show out intentions

client.register(selector, SelectionKey.OP_READ);

// read from the connection

} else if (key.isReadable()) {

// get the client

SocketChannel client = (SocketChannel) key.channel();

// reset our buffer

buf.rewind();

// read into it

client.read(buf);

// flip it so we can decode it

buf.flip();

// decode the bytes, handle it, and write the response

client.write(encoder.encode(CharBuffer.wrap("HTTP/1.1 200 OK\r\n\r\n" + handle(client, decoder.decode(buf).toString()) + "\r\n")));

}

} catch (Exception ex) {

System.err.println("Error handling client: " + key.channel());

System.err.println(ex);

System.err.println("\tat " + ex.getStackTrace()[0]);

} finally {

if (key.channel() instanceof SocketChannel) {

key.channel().close();

}

}

}

}

} catch (IOException ex) {

ex.printStackTrace();

} finally {

shutdown();

}

}

private String handle(SocketChannel client, String request) {

return "I liek cats. The current time is: " + new Date();

}

public void shutdown() {

isRunning = false;

try {

selector.close();

server.close();

} catch (IOException ex) {

// do nothing, its game over

}

buf = null;

charset = null;

decoder = null;

encoder = null;

selector = null;

server = null;

}

public static void main(String[] args) throws Exception {

new WebServer(new InetSocketAddress(5555)).start();

}

}

Highly appreciated. I used the one at https://bukkit.org/threads/ultra-fast-java-nio-webserver-less-than-350-lines.101080/ for my project. I'm just curious why the latest version is not in GitHub.