Java NIO Demo

在讀Amoeba源碼的時(shí)候，里面采用java NIO進(jìn)行通信管理，以前也了解過一些關(guān)于這方面的知識但是都不太系統(tǒng)，最近兩天抽時(shí)間對這塊進(jìn)行一下掃盲。我主要參考以下兩篇文章，個(gè)人認(rèn)為這兩篇文章還是不錯(cuò)的入門級文章，講的比較通俗易懂。
1.http://www.ibm.com/developerworks/cn/education/java/j-nio/section11.html
比較系統(tǒng)的講述了Channel（通道）、Buffer（緩沖區(qū)）、position，limit，capacity in buffer等；其示例代碼在：
http://code.google.com/p/astudy/source/browse/trunk/applications/astudy/nio/MultiPortEcho.java?spec=svn141&r=141下

2.http://tutorials.jenkov.com/java-nio/index.html
這個(gè)站點(diǎn)也是一個(gè)不錯(cuò)的入門級別介紹，雖然是e文，但講解的比較細(xì)致。

3.我的demo
這個(gè)小例子，模擬了一個(gè)echo服務(wù)，客戶端向echo服務(wù)器發(fā)送一段信息，echo收到信息后，返回給客戶端，然后，連接關(guān)閉。代碼如下：

/***************************************/

客戶端代碼：

package com.zxl.channel;

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.nio.charset.Charset;

import java.util.Set;

public class EchoClient {

/**

* @param args

* @throws IOException

public static void main(String[] args) throws IOException {

SocketChannel channel = SocketChannel.open();

channel.configureBlocking(false);

InetSocketAddress s = new InetSocketAddress("localhost",2000);

channel.connect(s);

Selector selector = Selector.open();

channel.register(selector, SelectionKey.OP_CONNECT|SelectionKey.OP_READ);

Charset charset=Charset.forName("GBK");

boolean isFinished = false;

while(!isFinished){

int num = selector.select();

if(num>0){

Set<SelectionKey> keys = selector.selectedKeys();

for(SelectionKey k:keys){

if(k.isConnectable()){

SocketChannel sc = (SocketChannel) k.channel();

sc.configureBlocking(false);

sc.finishConnect();

sc.register(selector, SelectionKey.OP_READ);

ByteBuffer echoBuffer = ByteBuffer.allocate(1024);

ByteBuffer info =charset.encode("好了克隆技術(shù)杜洛克防水堵漏開發(fā)!");

echoBuffer.put(info);

echoBuffer.flip();

sc.write(echoBuffer);

echoBuffer.clear();

}else if (k.isValid() && k.isReadable()) {

ByteBuffer echoBuffer = ByteBuffer.allocate(1024);

SocketChannel sc = (SocketChannel) k.channel();

sc.read(echoBuffer);

echoBuffer.flip();

System.out.println("echo server return:"+charset.decode(echoBuffer).toString());

echoBuffer.clear();

isFinished = true;

k.cancel();

sc.close();

selector.close();

}

/*********************************************/

服務(wù)端代碼：

package com.zxl.channel;

import java.io.IOException;

import java.net.InetSocketAddress;

import java.net.ServerSocket;

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.nio.charset.Charset;

import java.util.Iterator;

import java.util.Set;

public class MultiPortEchoServer {

private Charset charset=Charset.forName("GBK");

private int[] ports;

/**

* @param args

public static void main(String[] args) {

int[] ps = {2000,2001}; //默認(rèn)監(jiān)聽2000,2001端口

new MultiPortEchoServer(ps);

}

public MultiPortEchoServer(int[] ports){

this.ports = ports;

try {

go();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

public void go() throws IOException{

Selector selector = Selector.open();

for(int i=0;i<ports.length;i++){

ServerSocketChannel channel = ServerSocketChannel.open();

channel.configureBlocking(false);

ServerSocket socket = channel.socket();

InetSocketAddress address = new InetSocketAddress("localhost",ports[i]);

socket.bind(address);

//注冊接受連接事件

channel.register(selector, SelectionKey.OP_ACCEPT);

System.out.println( "Going to listen on "+ports[i] );

}

while(true){

int num = selector.select();

Set<SelectionKey> keys = selector.selectedKeys();

Iterator<SelectionKey> iter = keys.iterator();

while(iter.hasNext()){

SelectionKey key = iter.next();

if((key.readyOps()&SelectionKey.OP_ACCEPT)==SelectionKey.OP_ACCEPT){

ServerSocketChannel ssc = (ServerSocketChannel) key.channel();

SocketChannel sc = ssc.accept();

sc.configureBlocking(false);

sc.register(selector, SelectionKey.OP_READ);

iter.remove();

}else if((key.readyOps()&SelectionKey.OP_READ)==SelectionKey.OP_READ){

SocketChannel sc = (SocketChannel) key.channel();

if(!sc.isOpen()){

selector = Selector.open();

}else{

ByteBuffer echoBuffer = ByteBuffer.allocate(1024);

//int x = sc.read(echoBuffer);

while(sc.read(echoBuffer)>0){

System.out.println( "Echoed "+charset.decode(echoBuffer).toString()+" from "+sc.socket().getInetAddress().getHostAddress() );

echoBuffer.flip();

sc.write(echoBuffer);

echoBuffer.clear();

}

iter.remove();

/*返回信息后關(guān)閉連接*/

key.cancel();

sc.close();

}

keys.clear();

}

posted on 2011-06-30 16:24 zhangxl 閱讀(2792) 評論(1) 編輯收藏所屬分類: java concurrency

FeedBack:

# re: Java NIO Demo

2014-11-24 09:47 | zuidaima

java demo學(xué)習(xí)實(shí)例教程源代碼下載:http://zuidaima.com/share/kjava-p1-s1.htm 回復(fù) 更多評論

新用戶注冊刷新評論列表


只有注冊用戶登錄后才能發(fā)表評論。




網(wǎng)站導(dǎo)航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關(guān)文章: 使用java nio 實(shí)現(xiàn) Ping Java NIO Demo

2011年6月

日

一

二

三

四

五

六

常用鏈接

留言簿(1)

隨筆分類(17)

隨筆檔案(28)

文章分類(30)

文章檔案(30)

相冊

my picture

收藏夾(2)

我的關(guān)注(2)

hibernate

java基礎(chǔ)

serialization

mysql

mysql debin

xml

IBM XSL
w3c標(biāo)準(zhǔn)的xpath說明
web service ibm
XPath 示例
XPath 簡單語法
XQuery 1.0 and XPath 2.0 Full-Text Use Cases

常用鏈接

留言簿(1)

隨筆分類(17)

隨筆檔案(28)

文章分類(30)

文章檔案(30)

相冊

收藏夾(2)

hibernate

java基礎(chǔ)

mysql

xml

關(guān)注

壓力測試

算法

最新隨筆

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜