Apache MINAを使ってみよう - Apache MINAで簡易なサーバ作成

import java.io.IOException;
import java.net.InetSocketAddress;

import org.apache.mina.common.*;
import org.apache.mina.transport.socket.nio.*;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;

/**
 * ApacheMina使ったみよう。サンプル
 */
public class TestApacheMinaMyServer {
    private static final int PORT = 8080;

    /**
     * 
     */
    public static void main(String[] args) throws IOException {
        //１）SocketAcceptorでIoAcceptor生成（サーバサイド）
        IoAcceptor acceptor = new SocketAcceptor();
        
        //２）設定
        IoAcceptorConfig config = new SocketAcceptorConfig();
        DefaultIoFilterChainBuilder chain = config.getFilterChain();
        // テキスト・codec
        chain.addLast("codec", new ProtocolCodecFilter(
                new TextLineCodecFactory()));
        
        //３）ApacheMinaMyServer起動
        acceptor.bind(new InetSocketAddress(PORT), new MyHandler(), config);
        System.out.println("ApacheMinaServer started on port " + PORT);
    }
}

/**
 * 処理用Handlerクラス
 */
class MyHandler extends IoHandlerAdapter {
    /**
     * 異常があった場合呼び出される
     */
    @Override
    public void exceptionCaught(IoSession ssn, Throwable cause) {
        cause.printStackTrace();
        ssn.close();
    }

    /**
     * セッションを開く時呼び出される
     */
    @Override
    public void sessionOpened(IoSession ssn) throws Exception {
        System.out.println("session open for " + ssn.getRemoteAddress());
    }

    /**
     * セッションを閉じる時呼び出される
     */
    @Override
    public void sessionClosed(IoSession ssn) throws Exception {
        System.out.println("session closed from " + ssn.getRemoteAddress());
    }

    /**
     * クライアントからのメッセージがあった時呼び出される
     */
    public void messageReceived(IoSession ssn, Object msg) throws Exception {
        String ip = ssn.getRemoteAddress().toString();
        System.out.println("===> Message From " + ip + " : " + msg);
        ssn.write("Hello " + msg);
    }
}