tcp.rar_SocketChannel_SocketChannel HTTPS_java socketchannel_非阻

package com.channel.socket.tcp; import java.io.IOException; import java.net.InetSocketAddress; import java.net.ServerSocket; 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.nio.charset.Charset; public class Server { public static void main(String[] args) throws IOException { ServerSocketChannel sschannel; sschannel = ServerSocketChannel.open(); sschannel.configureBlocking(false); ServerSocket ss = sschannel.socket(); ss.bind(new InetSocketAddress(8888)); Selector selector = Selector.open(); sschannel.register(selector, SelectionKey.OP_ACCEPT); while (true) { System.out.println("***1***"); int nKeys = selector.select(1000); if (nKeys > 0) { for (SelectionKey key : selector.selectedKeys()) { if (key.isAcceptable()) { System.out.println("***2***"); ServerSocketChannel server = (ServerSocketChannel) key .channel(); SocketChannel sc = server.accept(); if (sc == null) { continue; } sc.configureBlocking(false); sc.register(selector, SelectionKey.OP_READ); } else if (key.isReadable()) { System.out.println("***3***"); ByteBuffer buffer = ByteBuffer.allocate(1024); SocketChannel sc = (SocketChannel) key.channel(); int readBytes = 0; String message = null; try { int ret; try { while ((ret = sc.read(buffer)) > 0) { readBytes += ret; } } catch (Exception e) { readBytes = 0; } finally { buffer.flip(); } if (readBytes > 0) { message = Charset.forName("UTF-8") .decode(buffer).toString(); buffer = null; } } finally { if (buffer != null) buffer.clear(); } if (readBytes > 0) { System.out .println("message from client:" + message); if ("quit".equalsIgnoreCase(message.trim())) { sc.close(); selector.close(); System.out.println("Server has been shutdown!"); System.exit(0); } String outMessage = "server response:" + message; sc.write(Charset.forName("UTF-8") .encode(outMessage)); } } } selector.selectedKeys().clear(); } } } }