Month: June 2013

package player.kent.chen.temp.learnnio.selector; import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.channels.SelectionKey; import java.nio.channels.Selector; import java.nio.channels.ServerSocketChannel; import java.nio.channels.SocketChannel; import java.util.Iterator; public class PlaySelector { public static void main(String[] args) throws IOException, InterruptedException { ServerSocketChannel serverChannel = ServerSocketChannel.open(); serverChannel.socket().bind(new InetSocketAddress(17547)); serverChannel.configureBlocking(false); Selector selector = Selector.open();//这个selector将同时用于serverChannel和accept()后针对单个连接的socketChannel serverChannel.register(selector, SelectionKey.OP_ACCEPT); //侦听ACCEPT就绪事件 System.out.println("开始侦听连接…"); while (true) { int n = selector.select(); //阻塞直到有事件发生 if …

NIO – Selector代码示例 Read More »

package player.kent.chen.temp.learnnio.socket; import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.channels.ServerSocketChannel; import java.nio.channels.SocketChannel; public class PlayServerSocketChannel { public static void main(String[] args) throws IOException, InterruptedException { ServerSocketChannel ssc = ServerSocketChannel.open(); ssc.socket().bind(new InetSocketAddress(17547)); ssc.configureBlocking(false); System.out.println("开始侦听连接…"); while (true) { SocketChannel sc = ssc.accept(); if (sc == null) {//非阻塞模式下，如果没有连接，accept()方法不会阻塞，而是直接返回null Thread.sleep(2000); } else { System.out.println("进来了一个连接。来自：" + sc.socket().getRemoteSocketAddress()); sc.write(ByteBuffer.wrap("尊姓大名: \n".getBytes())); //向客户端要求输入 …

NIO – ServerSocketChannel代码示例 Read More »

package player.kent.chen.temp.learnnio; import java.nio.ByteBuffer; import java.nio.ByteOrder; public class PlayEndian { public static void main(String[] args) { ByteBuffer buffer = ByteBuffer.wrap(new byte[20]); buffer.asCharBuffer().put("12345"); printBufferAsArray(buffer); //1, 打印0 49 0 50 0 51 … buffer.rewind(); //让buffer的位置移到最前 buffer.order(ByteOrder.BIG_ENDIAN); buffer.asCharBuffer().put("12345"); printBufferAsArray(buffer); //2, 打印结果将和#1一样，因为java默认的byte order就big endian buffer.rewind(); buffer.order(ByteOrder.LITTLE_ENDIAN); buffer.asCharBuffer().put("12345"); printBufferAsArray(buffer); //3，打印49 0 50 0 51 0 … } private static void …

NIO – Endian代码示例 Read More »

package player.kent.chen.temp.learnnio; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.nio.ByteBuffer; import java.nio.channels.FileChannel; public class PlayFileChannel { public static void main(String[] args) throws IOException { playOutput(); playInput(); } private static void playOutput() throws FileNotFoundException, IOException { FileChannel fc = new FileOutputStream("/home/kent/temp/data.txt").getChannel(); ByteBuffer buff = ByteBuffer.wrap("All the data".getBytes()); fc.write(buff); fc.close(); } private static void playInput() …

NIO – File Channel代码示例 Read More »