package com.msj.network.aio;

import java.net.InetSocketAddress;

import java.nio.channels.AsynchronousChannelGroup;

import java.nio.channels.AsynchronousServerSocketChannel;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

/**

* @author Vincent.M mengshaojie@188.com

* @date 2017/3/13 下午4:41

* @copyright ©2017 孟少杰 All Rights Reserved

* @desc AIO(NIO2.0) AIO它不需要通过多路复用器对注册的通道进行轮询操作即可实现异步读写，从而简化了NIO编程模型。

*/

public class Server {

//线程池

private ExecutorService executorService;

//线程组

private AsynchronousChannelGroup threadGroup;

//服务器通道

public AsynchronousServerSocketChannel assc;

public Server(int port){

try {

//创建一个缓存池

executorService = Executors.newCachedThreadPool();

//创建线程组

threadGroup = AsynchronousChannelGroup.withCachedThreadPool(executorService, 1);

//创建服务器通道

assc = AsynchronousServerSocketChannel.open(threadGroup);

//进行绑定

assc.bind(new InetSocketAddress(port));

System.out.println("server start , port : " + port);

//进行阻塞

assc.accept(this, new ServerCompletionHandler());

//一直阻塞 不让服务器停止，真正环境放到tomcat中，不用sleep

Thread.sleep(Integer.MAX_VALUE);

} catch (Exception e) {

e.printStackTrace();

}

}

public static void main(String[] args) {

Server server = new Server(8765);

}

}