apache mina
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
INFO org.apache.mina.filter.logging.LoggingFilter - CREATED
INFO org.apache.mina.filter.logging.LoggingFilter - OPENED
INFO org.apache.mina.filter.logging.LoggingFilter - SENT: HeapBuffer
created successed !已成功传送至客户端
INFO org.apache.mina.filter.logging.LoggingFilter - SENT: HeapBuffer
open successed !已成功传送至客户端
INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer
INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer
INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer
INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer
INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer
---->ip:/127.0.0.1:4417---->message:fang
已收到客户端的消息
fang已成功传送至客户端
now time is :2013-12-04 06:10:37已成功传送至客户端
message send successed已成功传送至客户端
INFO org.apache.mina.filter.logging.LoggingFilter - SENT: HeapBuffer
INFO org.apache.mina.filter.logging.LoggingFilter - SENT: HeapBuffer
INFO org.apache.mina.filter.logging.LoggingFilter - SENT: HeapBuffer
INFO org.apache.mina.filter.logging.LoggingFilter - IDLE
idle1
idle2
INFO org.apache.mina.filter.logging.LoggingFilter - IDLE
idle3
INFO org.apache.mina.filter.logging.LoggingFilter - IDLE
INFO org.apache.mina.filter.logging.LoggingFilter - IDLE
idle4
idle5
INFO org.apache.mina.filter.logging.LoggingFilter - IDLE
INFO org.apache.mina.filter.logging.LoggingFilter - IDLE
idle6
idle7
INFO org.apache.mina.filter.logging.LoggingFilter - IDLE
INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer
INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer
INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer
INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer
INFO org.apache.mina.filter.logging.LoggingFilter - RECEIVED: HeapBuffer
INFO org.apache.mina.filter.logging.LoggingFilter - CLOSED
命令行显示如下图：
页:
[1]