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);
                }
            });
    }

}

        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 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();