Posted on 2008-10-11 14:25
dennis 閱讀(2842)
評論(6) 編輯 收藏 所屬分類:
java 、
my open-source
項目名稱：Yanf4j(Yet another nio framework for java)
項目地址：
http://code.google.com/p/yanf4j/,當(dāng)前版本0.30-beta1
協(xié)議：Apache License, Version 2.0
簡單描述：
有這么多nio框架了，為什么要another？重復(fù)造輪子也罷，這框架脫胎于一個服務(wù)器項目的網(wǎng)絡(luò)層代碼，期間參考了cindy、grizzly等nio框架的實現(xiàn)，加上自己的一些心得體會實現(xiàn)的。特點是簡單、小巧、超輕量級。項目沒有多大野心，目標(biāo)是高效、簡單地實現(xiàn)非阻塞模式的Server（TCP、UDP）并且保證不錯的性能要求，不提供客戶端API 和阻塞模式。如果你的項目需要實現(xiàn)一個socket server并且不希望用太重量級的框架,yanf4j是個不錯的選擇。
例子，在source archive中帶有例子，這里描述下tcp和udp的echo server的實現(xiàn)。
一、先看TCP的Echo Server
1、實現(xiàn)處理handler，繼承HandlerAdapter類，實現(xiàn)相應(yīng)的回調(diào)方法，這與其他nio框架沒啥區(qū)別：
import com.google.code.yanf4j.nio.Dispatcher;
import com.google.code.yanf4j.nio.Session;
import com.google.code.yanf4j.nio.impl.HandlerAdapter;
import com.google.code.yanf4j.nio.util.DispatcherFactory;
public class EchoHandler extends HandlerAdapter<String> {
Dispatcher dispatcher = DispatcherFactory.newDispatcher(4);
@Override
public void onException(Session session, Throwable t) {
t.printStackTrace();
}
@Override
public void onMessageSent(Session session, String t) {
System.out.println("sent " + t + " to "
+ session.getRemoteSocketAddress());
}
@Override
public void onSessionStarted(Session session) {
System.out.println("session started");
session.setUseBlockingRead(true);
session.setUseBlockingWrite(false);
}
public void onSessionCreated(Session session) {
System.out.println(session.getRemoteSocketAddress().toString()
+ " connected");
}
public void onSessionClosed(Session session) {
System.out.println(session.getRemoteSocketAddress().toString()
+ " disconnected");
}
public void onReceive(final Session session, final String msg) {
System.out.println("recv:" + msg);
if (msg != null)
dispatcher.dispatch(new Runnable() {
public void run() {
if (msg.equals("q"))
session.close();
session.send(msg);
}
});
}
}
2、實現(xiàn)EchoServer，核心是TCPController類的使用：
Configuration configuration = new Configuration();
configuration.setStatisticsServer(true);
configuration.setTcpSessionReadBufferSize(256 * 1024); // 設(shè)置讀的緩沖區(qū)大小
AbstractController controller = new TCPController(configuration,
new StringCodecFactory());
controller.setPort(8080); // 設(shè)置端口
controller.setReadThreadCount(1); // 設(shè)置讀線程數(shù)，通常為1
controller.setReceiveBufferSize(16 * 1024); // 設(shè)置socket接收緩沖區(qū)大小
controller.setReuseAddress(false); // 設(shè)置是否重用端口
controller.setHandler(new EchoHandler()); // 設(shè)置handler
controller.setHandleReadWriteConcurrently(true); // 設(shè)置是否允許讀寫并發(fā)處理
controller.addStateListener(new ServerStateListener());
controller.start();
Configuration 默認(rèn)會在classpath查找yanf4j.properties屬性文件，用于配置服務(wù)器屬性，然而，你也看到，可以編碼設(shè)置這些屬性，具體參考wiki。
3、然后？沒然后了，一個TCP的echo server已經(jīng)搞定了，你可以telnet到8080端口試試了。
二、UDP的Echo server
1、handler，可以復(fù)用前面的EchoHandler
2、UDP的核心類是UDPController:
Configuration configuration = new Configuration();
configuration.setTcpPort(8090);
configuration.setTcpReuseAddress(false);
configuration.setStatisticsServer(true);
configuration.setTcpNoDelay(true);
configuration.setTcpReadThreadCount(1);
configuration.setTcpRecvBufferSize(16 * 1024);
UDPController controller = new UDPController(configuration);
controller.setMaxDatagramPacketLength(1024);
controller.setHandler(new EchoHandler());
controller.start();
更多細(xì)節(jié)，請參考項目主頁上的
wiki。