Mina入门 - 1 - Lullaby Us

yl.fighter

浏览: 257825 次
性别:
来自: 北京

最近访客更多访客>>

LiYunpeng

c4795712

wsl764263152

zo1698

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

Mina入门 - 1

Mina Apache 应用服务器网络应用网络协议

MINA 入门
1. 简介

a) Apache MINA是一个网络应用程序框架，用来帮助用户简单地开发高性能和高可靠性的网络应用程序。它提供了一个通过Java NIO在不同的传输例如TCP/IP和UDP/IP上抽象的事件驱动的异步API。
b) MINA结构:

i. 整体来说, 建立在应用至上的MINA分为三层:
1. I/O Service – 执行真正的I/O
2. I/O Filter Chain – 过滤/转换二进制为需要的数据结构
3. I/O Handler – 提供真正的业务逻辑

ii. 建立MINA
1. Create I/O service – 选择已有的, 或自己创建
2. Create Filter Chain – 选择已有的, 或自己创建
3. Create I/O Handler – 针对不同的消息写业务逻辑

2. HelloWorld
a) http://mina.apache.org/downloads.html下载mina
b) 创建项目,加入所需jar包:

i. mina-core-2.0.0.jar
ii. mina-example-2.0.0.jar
iii. slf4j-api-1.5.11.jar
iv. slf4j-log4j12-1.5.0.jar
v. log4j-1.2.15.jar

c) 写测试类
i. 服务器端注册是程序: MinaTimeServer.java

1.	package test.server;
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.	public class MinaTimeServer {
15.		
16.		private static final int PORT = 9123;
17.	
18.	    public static void main(String[] args) throws IOException {
19.	    	
20.	    	// 创建非阻塞式的接受器
21.	    	IoAcceptor acceptor = new NioSocketAcceptor();
22.	    	        
23.	    	// 添加两个过滤器 : a logger and a codec
24.	    	acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );
25.	    	// codec : 提供二进制或基于特定协议的数据 与 消息对象 之间的相互转换
26.	    	acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));
27.	    	   
28.	    	// 在这个服务上加入业务逻辑
29.	    	acceptor.setHandler( new TimeServerHandler() ); 
30.	
31.	    	// 配置缓存及闲置时间
32.	    	acceptor.getSessionConfig().setReadBufferSize( 2048 );
33.	    	acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );
34.	    	        
35.	    	// 添加绑定
36.	    	acceptor.bind( new InetSocketAddress(PORT) );
37.	
38.	    }
39.	}

ii. 服务器端的业务处理类: TimeServerHandler.java

1.	package test.server;
2.	
3.	import java.util.Date;
4.	
5.	import org.apache.mina.core.service.IoHandlerAdapter;
6.	import org.apache.mina.core.session.IdleStatus;
7.	import org.apache.mina.core.session.IoSession;
8.	
9.	public class TimeServerHandler extends IoHandlerAdapter{
10.	
11.	    @Override
12.	    public void exceptionCaught( IoSession session, Throwable cause ) throws Exception
13.	    {
14.	        cause.printStackTrace();
15.	    }
16.	
17.	    @Override
18.	    public void messageReceived( IoSession session, Object message ) throws Exception
19.	    {
20.	        String str = message.toString();
21.	        
22.	        if( str.trim().equalsIgnoreCase("quit") ) {
23.	            // "Quit" ? let's get out ...
24.	            session.close(true);
25.	            return;
26.	        }
27.	
28.	        // Send the current date back to the client
29.	        Date date = new Date();
30.	        session.write( date.toString() );
31.	        System.out.println("Message written...");
32.	    }
33.	
34.	    @Override
35.	    public void sessionIdle( IoSession session, IdleStatus status ) throws Exception
36.	    {
37.	        System.out.println( "IDLE " + session.getIdleCount( status ));
38.	    }
39.	}

iii. 首先测试服务器
1. Cmd窗口输入 telnet loaclhost 9123 连接上服务器
注: telnet 命令在window7 和vista 默认是不可用的, 解决方法为:
a. Start -> Control Pannel -> Uninstall a program -> Turn Windows features on or off
b. 勾选 "Telnet Client" 确定即可
2. 输入消息内容服务器返回信息系统时间即表示成功

分享到：