java web----MINA框架使用

http://mina.apache.org/

import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.SocketAcceptor;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;

import java.io.*;
import java.net.InetSocketAddress;

public class Server{
    public static void main(String[] args) {
        //创建一个非堵塞的Server(Socker),[NIO模式]
        SocketAcceptor acceptor = new NioSocketAcceptor();
        //创建一个过滤器对象
        DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();

        //设定一个过滤器，一行一行的读取数据(/r/n)
        chain.addLast("myChain",new ProtocolCodecFilter(new TextLineCodecFactory()));
        //设置服务器的消息处理器
        acceptor.setHandler(new MinaServerHandle());
        int port = 8080; //服务器的端口号
        try {
            //绑定端口,并且启动服务器，立刻返回，不会堵塞
            acceptor.bind(new InetSocketAddress(port));

        } catch (IOException e) {
            e.printStackTrace();
        }
        System.out.println("MINA服务器已经开启,端口号："+port);
    }
}

//服务器端的消息处理器
class MinaServerHandle extends IoHandlerAdapter {
    //会话开始
    @Override
    public void sessionOpened(IoSession session) throws Exception {
        super.sessionOpened(session);
        System.out.println(session.getRemoteAddress()+"已连接");//获取客户端连接的ip地址
    }
    //会话结束
    @Override
    public void sessionClosed(IoSession session) throws Exception {
        System.out.println("会话结束");
    }

    //接受消息
    @Override
    public void messageReceived(IoSession session, Object message) throws Exception {
        super.messageReceived(session, message);
        System.out.println(message); //接受消息
        session.write("hellow");
    }
}