??????? serverChannel.register(selector, SelectionKey.OP_ACCEPT);
??? }

??? /**
???? * 採用輪詢的方式監聽selector上是否有須要處理的事件。假設有，則進行處理
???? * @throws IOException
???? */
??? @SuppressWarnings("unchecked")
??? public void listen() throws IOException {
??????? System.out.println("服務端啟動成功！

");
??????? // 輪詢訪問selector
??????? while (true) {
??????????? //當註冊的事件到達時，方法返回。否則,該方法會一直堵塞
????????????selector.select();
??????????? // 獲得selector中選中的項的叠代器，選中的項為註冊的事件
??????????? Iterator ite = this.selector.selectedKeys().iterator();
??????????? while (ite.hasNext()) {
??????????????? SelectionKey key = (SelectionKey) ite.next();
??????????????? // 刪除已選的key,以防反復處理
??????????????? ite.remove();
??????????????? // client請求連接事件
??????????????? if (key.isAcceptable()) {
??????????????????? ServerSocketChannel server = (ServerSocketChannel) key
??????????????????????????? .channel();
??????????????????? // 獲得和client連接的通道
??????????????????? SocketChannel channel = server.accept();
??????????????????? // 設置成非堵塞
??????????????????? channel.configureBlocking(false);

??????????????????? //在這裏能夠給client發送信息哦
??????????????????? channel.write(ByteBuffer.wrap(new String("向client發送了一條信息").getBytes()));
??????????????????? //在和client連接成功之後。為了能夠接收到client的信息，須要給通道設置讀的權限。
????????????????????channel.register(this.selector, SelectionKey.OP_READ);

??????????????????? // 獲得了可讀的事件
??????????????? } else if (key.isReadable()) {
??????????????????? read(key);
??????????????? }

??????????? }

??????? }
??? }
??? /**
???? * 處理讀取client發來的信息 的事件
???? * @param key
???? * @throws IOException
???? */
??? public void read(SelectionKey key) throws IOException{
??????? // server可讀取消息:得到事件發生的Socket通道
??????? SocketChannel channel = (SocketChannel) key.channel();
??????? // 創建讀取的緩沖區
??????? ByteBuffer buffer = ByteBuffer.allocate(10);
??????? channel.read(buffer);
??????? byte[] data = buffer.array();
??????? String msg = new String(data).trim();
??????? System.out.println("服務端收到信息："+msg);
??????? ByteBuffer outBuffer = ByteBuffer.wrap(msg.getBytes());
??????? channel.write(outBuffer);// 將消息回送給client
??? }

??? /**
???? * 啟動服務端測試
???? * @throws IOException
???? */
??? public static void main(String[] args) throws IOException {
??????? NIOServer server = new NIOServer();
??????? server.initServer(8000);
??????? server.listen();
??? }
}



package com.sohu.tv.nio;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;
import java.util.Iterator;

/**
* NIOclient
* @author 小路
*/
public class NIOClient {
??? //通道管理器
??? private Selector selector;

??? /**
???? * 獲得一個Socket通道，並對該通道做一些初始化的工作
???? * @param ip 連接的server的ip
???? * @param port? 連接的server的端口號
???? * @throws IOException
???? */
??? public void initClient(String ip,int port) throws IOException {
??????? // 獲得一個Socket通道
??????? SocketChannel channel = SocketChannel.open();
??????? // 設置通道為非堵塞
??????? channel.configureBlocking(false);
??????? // 獲得一個通道管理器
??????? this.selector = Selector.open();

??????? // client連接server,事實上方法運行並沒有實現連接，須要在listen（）方法中調
??????? //用channel.finishConnect();才幹完畢連接
??????? channel.connect(new InetSocketAddress(ip,port));
??????? //將通道管理器和該通道綁定，並為該通道註冊SelectionKey.OP_CONNECT事件。

??????? channel.register(selector, SelectionKey.OP_CONNECT);
??? }

??? /**
???? * 採用輪詢的方式監聽selector上是否有須要處理的事件。假設有。則進行處理
???? * @throws IOException
???? */
??? @SuppressWarnings("unchecked")
??? public void listen() throws IOException {
??????? // 輪詢訪問selector
??????? while (true) {
??????????? selector.select();
??????????? // 獲得selector中選中的項的叠代器
??????????? Iterator ite = this.selector.selectedKeys().iterator();
??????????? while (ite.hasNext()) {
??????????????? SelectionKey key = (SelectionKey) ite.next();
??????????????? // 刪除已選的key,以防反復處理
??????????????? ite.remove();
??????????????? // 連接事件發生
??????????????? if (key.isConnectable()) {
??????????????????? SocketChannel channel = (SocketChannel) key
??????????????????????????? .channel();
??????????????????? // 假設正在連接，則完畢連接
??????????????????? if(channel.isConnectionPending()){
??????????????????????? channel.finishConnect();

??????????????????? }
??????????????????? // 設置成非堵塞
??????????????????? channel.configureBlocking(false);

??????????????????? //在這裏能夠給服務端發送信息哦
??????????????????? channel.write(ByteBuffer.wrap(new String("向服務端發送了一條信息").getBytes()));
??????????????????? //在和服務端連接成功之後，為了能夠接收到服務端的信息，須要給通道設置讀的權限。

??????????????????? channel.register(this.selector, SelectionKey.OP_READ);

??????????????????? // 獲得了可讀的事件
??????????????? } else if (key.isReadable()) {
??????????????????? read(key);
??????????????? }
??????????? }
??????? }
??? }
??? /**
???? * 處理讀取服務端發來的信息 的事件
???? * @param key
???? * @throws IOException
???? */
??? public void read(SelectionKey key) throws IOException{
??????? //和服務端的read方法一樣
??? }


??? /**
???? * 啟動client測試
???? * @throws IOException
???? */
??? public static void main(String[] args) throws IOException {
??????? NIOClient client = new NIOClient();
??????? client.initClient("localhost",8000);
??????? client.listen();
??? }

}