Java के Non-blocking Sockets

import java.nio.channels.SocketChannel;
public class Main {
	public static void main(String[] args) throws Exception {
		SocketChannel channel = SocketChannel.open();
		channel.configureBlocking(false); // one thread can service many such channels
		System.out.println("Non-blocking: " + !channel.isBlocking());
		channel.close();
	}
}

Login to try C/C++/Java/PHP code in the editor

import java.nio.channels.ServerSocketChannel;
public class Main {
	public static void main(String[] args) throws Exception {
		ServerSocketChannel server = ServerSocketChannel.open();
		server.bind(new java.net.InetSocketAddress(0));
		server.configureBlocking(false); // can accept non-blockingly when registered with a Selector
		System.out.println("Listening on port " + server.socket().getLocalPort());
		server.close();
	}
}

Login to try C/C++/Java/PHP code in the editor

import java.nio.channels.*;
public class Main {
	public static void main(String[] args) throws Exception {
		Selector selector = Selector.open();
		ServerSocketChannel server = ServerSocketChannel.open();
		server.bind(new java.net.InetSocketAddress(0));
		server.configureBlocking(false);
		server.register(selector, SelectionKey.OP_ACCEPT); // interested in accept events only
		System.out.println("Registered for OP_ACCEPT");
		selector.close();
		server.close();
	}
}

Login to try C/C++/Java/PHP code in the editor

import java.nio.channels.*;
public class Main {
	public static void main(String[] args) throws Exception {
		Selector selector = Selector.open();
		ServerSocketChannel server = ServerSocketChannel.open();
		server.bind(new java.net.InetSocketAddress(0));
		server.configureBlocking(false);
		server.register(selector, SelectionKey.OP_ACCEPT);
		int ready = selector.selectNow(); // non-blocking check instead of select() for this demo
		System.out.println("Ready channels: " + ready);
		selector.close();
		server.close();
	}
}

Login to try C/C++/Java/PHP code in the editor

import java.nio.channels.*;
import java.net.InetSocketAddress;
public class Main {
	public static void main(String[] args) throws Exception {
		ServerSocketChannel server = ServerSocketChannel.open();
		server.bind(new InetSocketAddress(0));
		server.configureBlocking(false);
		// OP_ACCEPT-ready key -> server.accept() returns a new client SocketChannel
		// OP_READ-ready key -> that client channel has data waiting in a buffer
		System.out.println("Server ready to accept on port " + server.socket().getLocalPort());
		server.close();
	}
}

Login to try C/C++/Java/PHP code in the editor