Java IO多路复用技术简介

/**
?* @author qifuguang
?* @date 15-2-4 下午2:07
?*/
public class TimeServerMain {
? ? public static void main(String[] args) throws Exception {
? ? ? ? // 启动时间服务器
? ? ? ? new Thread(new SelectorTimeServer()).start();
? ? }
}

?

/**
?* @author qifuguang
?* @date 15-2-4 下午2:09
?*/
public class TimeClientMain {
? ? public static void main(String[] args) throws Exception {
? ? ? ? // 创建100个客户端连接到服务器
? ? ? ? for (int i = 0; i < 100; i++) {
? ? ? ? ? ? new Thread(new SelectorTimeClient(i + 1)).start();
? ? ? ? }
? ? }
}

?

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.text.SimpleDateFormat;
import java.util.Date;
import java.util.Iterator;

/**
?* @author qifuguang
?* @date 15-2-4 下午1:21
?*/
public class SelectorTimeServer implements Runnable {
? ? private static final String TIME_ORDER = "Query Time";
? ? private Selector selector;
? ? private ServerSocketChannel serverChannel;
? ? private volatile boolean stop = false;

? ? /**
? ? * 创建Selector, 创建ServerSocketChannel,并设置为非阻塞模式, 注册到selector.
? ? *
? ? * @throws Exception
? ? */
? ? public SelectorTimeServer() throws Exception {
? ? ? ? selector = Selector.open();
? ? ? ? serverChannel = ServerSocketChannel.open();
? ? ? ? serverChannel.socket().bind(new InetSocketAddress(8080));
? ? ? ? serverChannel.configureBlocking(false);
? ? ? ? serverChannel.register(selector, SelectionKey.OP_ACCEPT);
? ? }

? ? /**
? ? * 轮询监听selector.
? ? */
? ? @Override
? ? public void run() {
? ? ? ? try {
? ? ? ? ? ? System.out.println("时间服务器启动！");
? ? ? ? ? ? while (!stop) {
? ? ? ? ? ? ? ? selector.select(1000);
? ? ? ? ? ? ? ? Iterator iterator = selector.selectedKeys().iterator();
? ? ? ? ? ? ? ? while (iterator.hasNext()) {
? ? ? ? ? ? ? ? ? ? SelectionKey key = iterator.next();
? ? ? ? ? ? ? ? ? ? iterator.remove();
? ? ? ? ? ? ? ? ? ? handleKey(key);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? ? ? if (selector != null) {
? ? ? ? ? ? ? ? selector.close();
? ? ? ? ? ? }
? ? ? ? } catch (Exception e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }
? ? }