Mina入门：mina版之HelloWorld

一，前言：

在完成上篇文章《Mina入门：Java NIO框架Mina、Netty、Grizzly简介与对比》之后，我们现在可以正式切入Mina入门学习了。

二，搭建项目结构与解决项目依赖

本人使用Maven来管理项目的依赖。好了，废话也不多说，直接上pom.xml。这里主要是加入mina-core以及其依赖的SLF4J。

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

Xml代码 
 alt="收藏代码" src="https://img.php1.cn/3cd4a/1eebe/cd5/6c257b6ba227cc3e.webp">

1.      class="attribute">xsi:schemaLocation= class="attribute-value">"http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" class="tag">>  


2.     <modelVersion class="tag">>4.0.0modelVersion class="tag">>  


3.   


4.     <groupId class="tag">>com.androidwhy class="tag-name">groupId class="tag">>  


5.     <artifactId class="tag">>mina-helloworld class="tag-name">artifactId class="tag">>  


6.     <version class="tag">>0.0.1-SNAPSHOT class="tag-name">version class="tag">>  


7.     <packaging class="tag">>jar class="tag-name">packaging class="tag">>  


8.   


9.     <name class="tag">>mina-helloworld class="tag-name">name class="tag">>  


10.     <url class="tag">>http://www.androidwhy.com class="tag">url class="tag">>  


11.   


12.     <properties class="tag">>  


13.          class="tag">< class="tag-name">project.build.sourceEncoding class="tag">>UTF-8project.build.sourceEncoding class="tag">>  


14.     properties class="tag">>  


15.   


16.     <dependencies class="tag">>  


17.          class="tag"><dependency>  


18.              class="tag"><groupId class="tag">>org.apache.mina class="tag-name">groupId class="tag">>  


19.              class="tag"><artifactId>mina-core class="tag">artifactId>  


20.              class="tag"><version class="tag">>2.0.4version class="tag">>  


21.          class="tag">dependency>  


22.   


23.          class="tag"><dependency>  


24.              class="tag"><groupId class="tag">>org.slf4jgroupId class="tag">>  


25.              class="tag"><artifactId>jcl-over-slf4j class="tag">artifactId>  


26.              class="tag"><version class="tag">>1.6.1version class="tag">>  


27.          class="tag">dependency>  


28.   


29.          class="tag"><dependency>  


30.              class="tag"><groupId class="tag">>org.slf4jgroupId class="tag">>  


31.              class="tag"><artifactId>slf4j-nop class="tag">artifactId>  


32.              class="tag"><version class="tag">>1.6.1version class="tag">>  


33.          class="tag">dependency>  


34.   


35.          class="tag"><dependency>  


36.              class="tag"><groupId class="tag">>junitgroupId class="tag">>  


37.              class="tag"><artifactId>junit class="tag">artifactId>  


38.              class="tag"><version class="tag">>3.8.1version class="tag">>  


39.              class="tag"><scope class="tag">>testscope class="tag">>  


40.          class="tag">dependency>  


41.     dependencies class="tag">>  


42. class="tag-name">project class="tag">>  

 这里需要注意一点的就是Mina与SLF4J版本的匹配，官方也有文档提到了，注意一下就是。

三，编写服务器

我们的mina版的HelloWorld的业务逻辑很简单，就是接收客户端的请求，并回应给客户端一个字符"Hello,I am
Server!"就可以了。

MinaTimeServer的主代码如下。

package com.androidwhy.mina.helloworld.server;

Java代码 
 alt="收藏代码" src="https://img.php1.cn/3cd4a/1eebe/cd5/6c257b6ba227cc3e.webp">

1. class="keyword">import java.io.IOException;  


2. class="keyword">import java.net.InetSocketAddress;  


3. class="keyword">import java.nio.charset.Charset;  


4.   


5. class="keyword">import org.apache.mina.core.service.IoAcceptor;  


6. class="keyword">import org.apache.mina.core.session.IdleStatus;  


7. class="keyword">import org.apache.mina.filter.codec.ProtocolCodecFilter;  


8. class="keyword">import org.apache.mina.filter.codec.textline.TextLineCodecFactory;  


9. class="keyword">import org.apache.mina.filter.logging.LoggingFilter;  


10. class="keyword">import org.apache.mina.transport.socket.nio.NioSocketAcceptor;  


11.   


12.   


13. public  class="keyword">class MinaTimeServer {  


14.   


15. "white-space: pre;">     class="keyword">private  class="keyword">static  class="keyword">final  class="keyword">int PORT =  class="number">8888;  


16.   


17.      class="keyword">public  class="keyword">static  class="keyword">void main(String[] args) throws IOException {  


18.         // Create the acceptor  


19.         IoAcceptor acceptor =  class="keyword">new NioSocketAcceptor();  


20.           


21.         // Add two filters : a logger and a codec  


22.         acceptor.getFilterChain().addLast(  class="string">"logger",  class="keyword">new LoggingFilter() );  


23.         acceptor.getFilterChain().addLast(  class="string">"codec",  class="keyword">new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName(  class="string">"UTF-8" ))));  


24.      


25.         // Attach the business logic to the server  


26.         acceptor.setHandler(  class="keyword">new HelloWorldServerHandler() );  


27.   


28.         // Configurate the buffer size and the iddle time  


29.         acceptor.getSessionConfig().setReadBufferSize(  class="number">2048 );  


30.         acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE,  class="number">10 );  


31.           


32.         // And bind !  


33.         acceptor.bind(  class="keyword">new InetSocketAddress(PORT) );  


34.     }  


35. }  

Handler代码如下：

package com.androidwhy.mina.helloworld.server;

Java代码 
 alt="收藏代码" src="https://img.php1.cn/3cd4a/1eebe/cd5/6c257b6ba227cc3e.webp">

1. class="keyword">import org.apache.mina.core.service.IoHandlerAdapter;  


2. class="keyword">import org.apache.mina.core.session.IdleStatus;  


3. class="keyword">import org.apache.mina.core.session.IoSession;  


4.   


5. public  class="keyword">class HelloWorldServerHandler extends IoHandlerAdapter  


6. {  


7.      class="comment">/** 


8. class="comment">     * Trap exceptions. 


9. class="comment">     */  


10.      class="annotation">@Override  


11.      class="keyword">public  class="keyword">void exceptionCaught( IoSession session, Throwable cause )  class="keyword">throws Exception  


12.     {  


13.         cause.printStackTrace();  


14.     }  


15.   


16.      class="comment">/** 


17. class="comment">     * If the message is ‘quit‘, we exit by closing the session. Otherwise, 


18. class="comment">     * we return the message. 


19. class="comment">     */  


20.      class="annotation">@Override  


21.      class="keyword">public  class="keyword">void messageReceived( IoSession session, Object message )  class="keyword">throws Exception  


22.     {  


23.         String str = message.toString();  


24.           


25.         if( str.trim().equalsIgnoreCase( class="string">"quit") ) {  


26.              class="comment">// "Quit" ? let‘s get out ...  


27.             session.close( class="keyword">true);  


28.              class="keyword">return;  


29.         }  


30.           


31.         System.out.println( class="string">"Received message:"+str);  


32.   


33.         // Send the "Hello, I am Server!" back to the client  


34.         String helloWorld =  class="string">"Hello, I am Server!";  


35.         session.write(helloWorld);  


36.         System.out.println( class="string">"Message written...");  


37.     }  


38.   


39.      class="comment">/** 


40. class="comment">     * On idle, we just write a message on the console 


41. class="comment">     */  


42.      class="annotation">@Override  


43.      class="keyword">public  class="keyword">void sessionIdle( IoSession session, IdleStatus status )  class="keyword">throws Exception  


44.     {  


45.         System.out.println(  class="string">"IDLE " + session.getIdleCount( status ));  


46.     }  


47. }  

 
你会发现，使用Mina写一个Server就是如此之简单！上面的MinaTimeServer主是建立一个监听在8888端口（建议使用大于1024的端口号，因为1024以下的是系统保留的）服务，并设置了一个日志filter与一个编码的filter；HelloWorldServerHandler对handler的各位状态进行了处理，在这里最为主要的就是override了messageReceived方法，并在其中处理我们的业务逻辑。

四，运行程序

到目前为止，我们只是写了一个Server，那程序怎么跑呢？客户端就暂时采用Telnet吧！

五，总结

我只想说一句：任何开源框架的入门都是如此的Easy，Mina也一样。

Mina入门：mina版之HelloWorld,布布扣,bubuko.com