服務(wù)器代碼：

import java.net.*; 
import java.nio.*; 
import java.nio.channels.*; 
import java.util.*; 
public class server 
{ 
ServerSocketChannel ssc ; 
public void start() 
{ 
try 
{ 
Selector selector = Selector.open(); 
ServerSocketChannel ssc=ServerSocketChannel.open(); 
ssc.configureBlocking(false); 
ServerSocket ss=ssc.socket(); 
InetSocketAddress address = new InetSocketAddress(55555); 
ss.bind(address); 
ssc.register(selector, SelectionKey.OP_ACCEPT); 
System.out.println("端口注冊(cè)完畢!"); 
while(true) 
{ 
selector.select(); 
Set<SelectionKey> selectionKeys=selector.selectedKeys(); 
Iterator<SelectionKey> iter=selectionKeys.iterator(); 
ByteBuffer echoBuffer=ByteBuffer.allocate(20); 
SocketChannel sc; 
while(iter.hasNext()) 
{ 
SelectionKey key=iter.next(); 
if((key.readyOps()&SelectionKey.OP_ACCEPT)==SelectionKey.OP_ACCEPT) 
{ 
ServerSocketChannel subssc=(ServerSocketChannel)key.channel(); 
sc=subssc.accept(); 
sc.configureBlocking(false); 
sc.register(selector, SelectionKey.OP_READ); 
iter.remove(); 
System.out.println("有新連接:"+sc); 
} 
else if((key.readyOps()&SelectionKey.OP_READ)==SelectionKey.OP_READ) 
{ 
sc=(SocketChannel) key.channel(); 
while(true) 
{ 
echoBuffer.clear(); 
int a; 
try 
{ 
a=sc.read(echoBuffer); 
} 
catch(Exception e) 
{ 
e.printStackTrace(); 
break; 
} 
if(a==-1) break; 
if(a>0) 
{ 
byte[] b=echoBuffer.array(); 
System.out.println("接收數(shù)據(jù): "+new String(b)); 
echoBuffer.flip(); 
sc.write(echoBuffer); 
System.out.println("返回?cái)?shù)據(jù): "+new String(b)); 
} 
} 
sc.close(); 
System.out.println("連接結(jié)束"); 
System.out.println("============================="); 
iter.remove(); 
} 
} 
} 
} 
catch (Exception e) 
{ 
e.printStackTrace(); 
} 
} 
} 

客戶端代碼：

import java.net.*; 
import java.nio.*; 
import java.nio.channels.*; 
public class client 
{ 
public void start() 
{ 
try 
{ 
SocketAddress address = new InetSocketAddress("localhost",55555); 
SocketChannel client=SocketChannel.open(address); 
client.configureBlocking(false); 
String a="asdasdasdasddffasfas"; 
ByteBuffer buffer=ByteBuffer.allocate(20); 
buffer.put(a.getBytes()); 
buffer.clear(); 
int d=client.write(buffer); 
System.out.println("發(fā)送數(shù)據(jù): "+new String(buffer.array())); 
while(true) 
{ 
buffer.flip(); 
int i=client.read(buffer); 
if(i>0) 
{ 
byte[] b=buffer.array(); 
System.out.println("接收數(shù)據(jù): "+new String(b)); 
client.close(); 
System.out.println("連接關(guān)閉!"); 
break; 
} 
} 
} 
catch(Exception e) 
{ 
e.printStackTrace(); 
} 
} 

原文鏈接：http://blog.sina.com.cn/s/blog_5df388620100plwi.html

【編輯推薦】

1. 影響Java NIO框架性能的因數(shù)
2. java.nio.Buffer的一些基礎(chǔ)知識(shí)的備忘
3. 甲骨文Java專利遭拒 起訴Android侵權(quán)受挫
4. Java企業(yè)應(yīng)用問(wèn)題代碼最多
5. Java的NIO以及線程并發(fā)