781
Yet another nio framework for java
项目名称：Yanf4j(Yet another nio framework for java)项目地址：https://code.google.com/p/yanf4j/,当前版本0.30-beta1
协议：Apache License, Version 2.0
简单描述：
有这么多nio框架了，为什么要another？重复造轮子也罢，这框架脱胎于一个服务器项目的网络层代码，期间参考了cindy、grizzly等nio框架的实现，加上自己的一些心得体会实现的。特点是简单、小巧、超轻量级。项目没有多大野心，目标是高效、简单地实现非阻塞模式的Server（TCP、UDP）并且保证不错的性能要求，不提供客户端API 和阻塞模式。如果你的项目需要实现一个socket server并且不希望用太重量级的框架,yanf4j是个不错的选择。
例子，在source archive中带有例子，这里描述下tcp和udp的echo server的实现。
一、先看TCP的Echo Server
1、实现处理handler，继承HandlerAdapter类，实现相应的回调方法，这与其他nio框架没啥区别：
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);
}
});
}
}
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、实现EchoServer，核心是TCPController类的使用：
Configuration configuration = new Configuration();
configuration.setStatisticsServer(true);
configuration.setTcpSessionReadBufferSize(256 * 1024); // 设置读的缓冲区大小
AbstractController controller = new TCPController(configuration,
new StringCodecFactory());
controller.setPort(8080); // 设置端口
controller.setReadThreadCount(1); // 设置读线程数，通常为1
controller.setReceiveBufferSize(16 * 1024); // 设置socket接收缓冲区大小
controller.setReuseAddress(false); // 设置是否重用端口
controller.setHandler(new EchoHandler()); // 设置handler
controller.setHandleReadWriteConcurrently(true); // 设置是否允许读写并发处理
controller.addStateListener(new ServerStateListener());
controller.start();
configuration.setStatisticsServer(true);
configuration.setTcpSessionReadBufferSize(256 * 1024); // 设置读的缓冲区大小
AbstractController controller = new TCPController(configuration,
new StringCodecFactory());
controller.setPort(8080); // 设置端口
controller.setReadThreadCount(1); // 设置读线程数，通常为1
controller.setReceiveBufferSize(16 * 1024); // 设置socket接收缓冲区大小
controller.setReuseAddress(false); // 设置是否重用端口
controller.setHandler(new EchoHandler()); // 设置handler
controller.setHandleReadWriteConcurrently(true); // 设置是否允许读写并发处理
controller.addStateListener(new ServerStateListener());
controller.start();
Configuration 默认会在classpath查找yanf4j.properties属性文件，用于配置服务器属性，然而，你也看到，可以编码设置这些属性，具体参考wiki。
3、然后？没然后了，一个TCP的echo server已经搞定了，你可以telnet到8080端口试试了。
二、UDP的Echo server
1、handler，可以复用前面的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();
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();
更多细节，请参考项目主页上的wiki。
文章转自庄周梦蝶 ，原文发布时间2008-10-11
最后更新：2017-05-18 11:01:58