/** * BIO模型编写的服务器，一个socket对一个线程 * 端口为：6666 * * 客户端cmd发送方式： * - telnet * - ctrl+] * - [send] + your word */
package yiki.mybatis.netty_learn.basic; import java.io.InputStream; import java.net.ServerSocket; import java.net.Socket; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class BIOserver { /*线程池机制 - 创建一个线程池 - 如有客户端连接就创建一个线程与之通讯 */ public static void startBIO() throws Exception { ExecutorService newCachedThreadPool = Executors.newCachedThreadPool(); System.out.println("BIO Server Started"); ServerSocket serverSocket = new ServerSocket(6666); while (true) { // 监听 final Socket socket = serverSocket.accept(); System.out.println("FInd an Client"); newCachedThreadPool.execute(new Runnable() { @Override public void run() {//重写 // 和客户端 handler(socket); } }); } } //与客户端通讯的方法 public static void handler(Socket socket) { try { System.out.println("id: "+Thread.currentThread().getId()); System.out.println("name: "+Thread.currentThread().getName()); byte[] bytes = new byte[1024]; //通过socket获得一个输入流 InputStream inputStream = socket.getInputStream(); //循环读取客户端发送的数据 while (true) { // read会造成阻塞 int read = inputStream.read(bytes); if (read != -1) { System.out.println(new String(bytes,0,read)); } else { break; } } } catch (Exception e) { System.out.println(e); } finally { //不管发生了什么都要执行关闭 System.out.println("server is closed"); try { socket.close(); } catch (Exception e) { e.printStackTrace(); } } } }跑
NIOserver.NIOserve();即可
package yiki.mybatis.util; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.net.InetSocketAddress; import java.nio.Buffer; import java.nio.ByteBuffer; import java.nio.IntBuffer; import java.nio.channels.*; import java.util.Arrays; import java.util.Iterator; import java.util.Set; /* Non-blocking IO 同步非阻塞, for BLOCK to handle data - tread - tread | ... - selector (listening events from channel) - channel - channel || || - buffer - buffer * */ public class NIOserver { // what's buffer : there are various types of buffer public void basicBuffer() { // create an 5size buffer IntBuffer buffer = IntBuffer.allocate(5); //store data to buffer buffer.put(10); buffer.put(10); buffer.put(10); buffer.put(10); // get data from buffer // switch read or write //buffer's position would change buffer.flip(); while (buffer.hasRemaining()) { // get->index changes System.out.println(buffer.get()); } } //what's channel public void basicFileChannelWrite() throws Exception { String str = "hello"; //create an output stream FileOutputStream outputStream = new FileOutputStream("d:\\file.01.text"); // the real type of channel is "FileChannelImpl" FileChannel channel = outputStream.getChannel(); //create an buffer zone ->buffer ByteBuffer byteBuffer = ByteBuffer.allocate(1024); byteBuffer.put(str.getBytes()); //because position had changed,so flipped it byteBuffer.flip(); //put data that from buffer write to fileChannel channel.write(byteBuffer); //Don't forget to close your stream outputStream.close(); } public void basicFileChannelRead() throws Exception { // create an inputStream File file = new File("d:\\file.text"); FileInputStream inputStream = new FileInputStream(file); FileChannel channel = inputStream.getChannel(); //crete buffer zone ByteBuffer buffer = ByteBuffer.allocate((int) file.length()); // read data that from channel into buffer channel.read(buffer); //turn byte to string System.out.println(new String(buffer.array())); inputStream.close(); } //what's selector public void basicSelector() { /* NIO client-> serverSocketChannel-> socketChannel->register to selector ->return selectionKey -> selector would listening select func -> return channel number of events that happened */ } //Scattering: use buffer array write in order //Gathering: read data from the buffer, use buffer array read in order public static void scattering_gathering() throws Exception { ServerSocketChannel channel = ServerSocketChannel.open(); InetSocketAddress address = new InetSocketAddress(7000); // bind port to socket and open it channel.socket().bind(address); System.out.println("serve started"); ByteBuffer[] byteBuffer = new ByteBuffer[2]; byteBuffer[0] = ByteBuffer.allocate(5); byteBuffer[1] = ByteBuffer.allocate(3); //waiting for the client to connect SocketChannel socketChannel = channel.accept(); int msgLen = 8;// limit client data is 8 bytes //read in loop while (true) { int byteRead = 0; while (byteRead < 8) { System.out.println("loop started"); long count = socketChannel.read(byteBuffer); byteRead += count; // use stream to print Arrays.asList(byteBuffer).stream().map (item -> item.position() + item.limit()). forEach(System.out::println); //reverse Arrays.asList(byteBuffer).forEach(item -> item.flip()); // return back to your client long byteWrite = 0; while (byteWrite < msgLen) { long count2 = socketChannel.write(byteBuffer); byteWrite += count2; } System.out.println("byteRead: " + byteRead); System.out.println("byteWrite: " + byteWrite); System.out.println("clear buffer"); //clear buffer Arrays.asList(byteBuffer).forEach(item -> { item.clear(); }); } } } public static void NIOserve() throws Exception { //create serverSocketChannel ServerSocketChannel channel = ServerSocketChannel.open(); // get a selector obj Selector selector = Selector.open(); //bind a port channel.socket().bind(new InetSocketAddress(6666)); // set to no-blocking module channel.configureBlocking(false); System.out.println("NIO Service started"); //register 'channel' to selector, OP_ACCEPT channel.register(selector, SelectionKey.OP_ACCEPT); // loop for listening, waiting for client's connection while (true) { if (selector.select(1000) == 0) { System.out.println("passed 1s, no connection"); continue;//not to block the thread } // >0 => selectionKey sets => Set<SelectionKey> selectionKeys = selector.selectedKeys(); Iterator<SelectionKey> iterator = selectionKeys.iterator(); while (iterator.hasNext()) { SelectionKey key = iterator.next(); if (key.isAcceptable()) {// means has a new client's connection // create a new socketChannel for this client SocketChannel newChannel = channel.accept(); System.out.println("accept..."); // no-block module newChannel.configureBlocking(false); // register this newChannel to selector, and connected it to an buffer newChannel.register(selector, SelectionKey.OP_READ, ByteBuffer.allocate(1024) ); } if (key.isReadable()) {//OP_READ SocketChannel channel1 = (SocketChannel) key.channel(); ByteBuffer buffer = (ByteBuffer) key.attachment();//is a buffer // read it channel1.read(buffer); System.out.println("from client: " + new String(buffer.array())); } // remove current key from set, avoid has repeat operation iterator.remove(); } } } }
