Yet another nio framework for java

项目名称：Yanf4j(Yet another nio framework for java)
项目地址：http://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);
                }
            });
    }

}

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 默认会在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();

更多细节，请参考项目主页上的wiki。

文章转自庄周梦蝶，原文发布时间2008-10-11

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/290349.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！