apache mina

dongnanfeng

　　http://mina.apache.org/
　　初试apache mina框架，参考mina官网做了一个服务端的简单示例，直接上代码，在这之前准备好要用的jar包，如下图：

　　



1 package mina;
2
3 import java.io.IOException;
4 import java.net.InetSocketAddress;
5 import java.nio.charset.Charset;
6
7 import org.apache.mina.core.service.IoAcceptor;
8 import org.apache.mina.core.session.IdleStatus;
9 import org.apache.mina.filter.codec.ProtocolCodecFilter;
10 import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
11 import org.apache.mina.filter.logging.LoggingFilter;
12 import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
13 /**
14  * mina入门示例
15  *
16  * @author Administrator
17  *
18  */
19 public class MinaTimeServer {
20
21     private static final int PORT = 9228;
22     
23     public static void main(String[] args) throws IOException{
24         //new一个IOAcceptor实例，用于侦听传入的连接
25         IoAcceptor acceptor = new NioSocketAcceptor();
26         //添加过滤器配置记录所有消息以及处理文本基础信息，也就是日志记录和将传递的数据编码成文本
27         acceptor.getFilterChain().addLast("logger", new LoggingFilter());
28         acceptor.getFilterChain().addLast("code", new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"))));
29         //创建处理器，此处理器必须实现IOHandler接口，这里扩展IOHandler的子类IoHandlerAdepter
30         acceptor.setHandler(new TimeServerHandler());
31         //设置IoHandler缓冲区大小和空闲会话属性
32         acceptor.getSessionConfig().setReadBufferSize(2048);
33         acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
34         //绑定端口
35         acceptor.bind(new InetSocketAddress(PORT));
36         
37         System.out.println("MinaTimeServer start successed , please open cmd input telnet localhost " + PORT);
38     }
39
40 }
　　



1 package mina;
2
3
4 import java.text.SimpleDateFormat;
5 import java.util.Date;
6
7 import org.apache.mina.core.service.IoHandlerAdapter;
8 import org.apache.mina.core.session.IdleStatus;
9 import org.apache.mina.core.session.IoSession;
10 /**
11  * 业务处理类
12  * 这里扩展了IoHandlerAdapter类
13  *
14  * @author Administrator
15  *
16  */
17 public class TimeServerHandler extends IoHandlerAdapter{
18
19     /**
20      * 异常发生时触发
21      */
22     @Override
23     public void exceptionCaught(IoSession session, Throwable cause)
24             throws Exception {
25         cause.printStackTrace();
26     }
27
28     /**
29      * 收到来自客户端的消息时触发
30      */
31     @Override
32     public void messageReceived(IoSession session, Object message)
33             throws Exception {
34         
35         if(message.toString().equalsIgnoreCase("quit")) {
36             session.close(false);
37             return;
38         }
39         
40         String ip = session.getRemoteAddress().toString();
41         System.out.println("---->ip:"+ip+"---->message:"+message);
42         session.write(message);
43         
44         Date date = new Date();
45         SimpleDateFormat simple = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
46         session.write("now time is :"+simple.format(date));
47         System.out.println("已收到客户端的消息");
48         session.write("message send successed");
49     }
50
51     /**
52      * 连接空闲时触发
53      */
54     @Override
55     public void sessionIdle(IoSession session, IdleStatus status)
56             throws Exception {
57         System.out.println("idle"+session.getIdleCount(status));
58     }
59
60     /**
61      * 消息传送到客户端后触发
62      */
63     @Override
64     public void messageSent(IoSession session, Object message) throws Exception {
65         // TODO Auto-generated method stub
66         super.messageSent(session, message);
67         System.out.println(message + "已成功传送至客户端");
68     }
69
70     /**
71      * 连接被关闭时触发，例如客户端意外退出等
72      */
73     @Override
74     public void sessionClosed(IoSession session) throws Exception {
75         // TODO Auto-generated method stub
76         super.sessionClosed(session);
77     }
78
79     /**
80      * 当一个新客户端连接后触发
81      */
82     @Override
83     public void sessionCreated(IoSession session) throws Exception {
84         session.write("created successed !");
85     }
86
87     /**
88      * 连接后打开时触发
89      */
90     @Override
91     public void sessionOpened(IoSession session) throws Exception {
92         session.write("open successed !");
93     }
94
95 }
　　
　　启动服务，console输出如下：



MinaTimeServer start successed , please open cmd input telnet localhost 9228
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - CREATED
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - OPENED
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - SENT: HeapBuffer[pos=0 lim=0 cap=0: empty]
created successed !已成功传送至客户端
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - SENT: HeapBuffer[pos=0 lim=0 cap=0: empty]
open successed !已成功传送至客户端
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer[pos=0 lim=1 cap=2048: 66]
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer[pos=0 lim=1 cap=2048: 61]
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer[pos=0 lim=1 cap=1024: 6E]
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer[pos=0 lim=1 cap=1024: 67]
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer[pos=0 lim=2 cap=512: 0D 0A]
---->ip:/127.0.0.1:4417---->message:fang
已收到客户端的消息
fang已成功传送至客户端
now time is :2013-12-04 06:10:37已成功传送至客户端
message send successed已成功传送至客户端
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - SENT: HeapBuffer[pos=0 lim=0 cap=0: empty]
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - SENT: HeapBuffer[pos=0 lim=0 cap=0: empty]
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - SENT: HeapBuffer[pos=0 lim=0 cap=0: empty]
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - IDLE
idle1
idle2
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - IDLE
idle3
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - IDLE
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - IDLE
idle4
idle5
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - IDLE
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - IDLE
idle6
idle7
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - IDLE
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer[pos=0 lim=1 cap=512: 71]
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer[pos=0 lim=1 cap=256: 75]
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer[pos=0 lim=1 cap=256: 69]
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer[pos=0 lim=1 cap=128: 74]
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer[pos=0 lim=2 cap=128: 0D 0A]
[NioProcessor-2] INFO org.apache.mina.filter.logging.LoggingFilter - CLOSED
　　命令行显示如下图：