private ServerSocketChannel server;
/**
* Selector对象,负责监控所有的连接到服务器的网络事件的发生
*/
private Selector selector;
/**
* 总的活动连接数
*/
private int activeSockets;
/**
* 服务器Channel绑定的端口号
*/
private int port ;
/**
*
* 构造函数
*/
public TestServer()throws IOException
{
activeSockets=0;
port=9999;//初始化服务器Channel绑定的端口号为9999
selector= Selector.open();//初始化Selector对象
server=ServerSocketChannel.open();//初始化服务器Channel对象
ServerSocket socket=server.socket();//获取服务器Channel对应的//ServerSocket对象
socket.bind(new InetSocketAddress(port));//把Socket绑定到监听端口9999上
server.configureBlocking(false);//将服务器Channel设置为非阻塞模式
server.register(selector,SelectionKey.OP_ACCEPT);//将服务器Channel注册到
Selector对象,并指出服务器Channel所感兴趣的事件为可接受请求操作
}
public void run()
{
while(true)
{
try
{
/**
*应用Select机制轮循是否有用户感兴趣的新的网络事件发生,当没有
* 新的网络事件发生时,此方法会阻塞,直到有新的网络事件发生为止
*/