Thread: Non blocking server example...

Well I was having a good look through the NIO API libary and came up with this.

Code:

import java.io.*;
import java.nio.*;
import java.nio.channels.*;
import java.net.*;
import java.util.*;
import java.nio.charset.*;
import java.lang.*;

public class RSX
{
    public Selector sel = null;
    public ServerSocketChannel server = null;
    public SocketChannel socket = null;
    public int port = 5659;
    String result = null;


    public RSX()
    {
    }
    
	public RSX(int port)
    {
		port = port;
    }

    public void initializeOperations() throws IOException,UnknownHostException
    {
		sel = Selector.open();
		server = ServerSocketChannel.open();
		server.configureBlocking(false);
		InetAddress ia = InetAddress.getLocalHost();
		InetSocketAddress isa = new InetSocketAddress(ia,port);
		server.socket().bind(isa);
    }
    
	public void startServer() throws IOException
    {
        initializeOperations();
		SelectionKey acceptKey = server.register(sel, SelectionKey.OP_ACCEPT );	
	
		while (acceptKey.selector().select() > 0 )
		{	
	    
			Set readyKeys = sel.selectedKeys();
			Iterator it = readyKeys.iterator();

			while (it.hasNext()) {
				SelectionKey key = (SelectionKey)it.next();
				it.remove();
                
				if (key.isAcceptable()) {
					ServerSocketChannel ssc = (ServerSocketChannel) key.channel();
					socket = (SocketChannel) ssc.accept();
					socket.configureBlocking(false);
					SelectionKey another = socket.register(sel,SelectionKey.OP_READ|SelectionKey.OP_WRITE);
				}
			}
		}
    }
    public static void main(String args[])
    {
		RSX nb = new RSX();
		try
		{
			nb.startServer();
		}
		catch (IOException e)
		{
			e.printStackTrace();
			System.exit(-1);
		}
		
	}
}

I have tested this works really well, this will accept all connections in the matter of a few millisecounds...

WARNING: IF YOU HAVE A SMALL CPU PUT A SLEEP IN THE THREAD OR THIS WILL PWN YOUR CPU!