Mina入门：mina版之HelloWorld[z]

时间：2022-06-01 19:05:26

Mina入门：mina版之HelloWorld

[z]

一，前言：

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

http://i.cnblogs.com/EditPosts.aspx?opt=1

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

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

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

  1. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  2. <modelVersion>4.0.0</modelVersion>
  3. <groupId>com.androidwhy</groupId>
  4. <artifactId>mina-helloworld</artifactId>
  5. <version>0.0.1-SNAPSHOT</version>
  6. <packaging>jar</packaging>
  7. <name>mina-helloworld</name>
  8. <url>http://www.androidwhy.com</url>
  9. <properties>
  10. <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  11. </properties>
  12. <dependencies>
  13. <dependency>
  14. <groupId>org.apache.mina</groupId>
  15. <artifactId>mina-core</artifactId>
  16. <version>2.0.4</version>
  17. </dependency>
  18. <dependency>
  19. <groupId>org.slf4j</groupId>
  20. <artifactId>jcl-over-slf4j</artifactId>
  21. <version>1.6.1</version>
  22. </dependency>
  23. <dependency>
  24. <groupId>org.slf4j</groupId>
  25. <artifactId>slf4j-nop</artifactId>
  26. <version>1.6.1</version>
  27. </dependency>
  28. <dependency>
  29. <groupId>junit</groupId>
  30. <artifactId>junit</artifactId>
  31. <version>3.8.1</version>
  32. <scope>test</scope>
  33. </dependency>
  34. </dependencies>
  35. </project>

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

三，编写服务器

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

MinaTimeServer的主代码如下。

package com.androidwhy.mina.helloworld.server;

  1. import java.io.IOException;
  2. import java.net.InetSocketAddress;
  3. import java.nio.charset.Charset;
  4. import org.apache.mina.core.service.IoAcceptor;
  5. import org.apache.mina.core.session.IdleStatus;
  6. import org.apache.mina.filter.codec.ProtocolCodecFilter;
  7. import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
  8. import org.apache.mina.filter.logging.LoggingFilter;
  9. import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
  10. public class MinaTimeServer {
  11. <span style="white-space: pre;">    </span>private static final int PORT = 8888;
  12. public static void main(String[] args) throws IOException {
  13. // Create the acceptor
  14. IoAcceptor acceptor = new NioSocketAcceptor();
  15. // Add two filters : a logger and a codec
  16. acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );
  17. acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));
  18. // Attach the business logic to the server
  19. acceptor.setHandler( new HelloWorldServerHandler() );
  20. // Configurate the buffer size and the iddle time
  21. acceptor.getSessionConfig().setReadBufferSize( 2048 );
  22. acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );
  23. // And bind !
  24. acceptor.bind( new InetSocketAddress(PORT) );
  25. }
  26. }

Handler代码如下：

package com.androidwhy.mina.helloworld.server;

  1. import org.apache.mina.core.service.IoHandlerAdapter;
  2. import org.apache.mina.core.session.IdleStatus;
  3. import org.apache.mina.core.session.IoSession;
  4. public class HelloWorldServerHandler extends IoHandlerAdapter
  5. {
  6. /**
  7. * Trap exceptions.
  8. */
  9. @Override
  10. public void exceptionCaught( IoSession session, Throwable cause ) throws Exception
  11. {
  12. cause.printStackTrace();
  13. }
  14. /**
  15. * If the message is 'quit', we exit by closing the session. Otherwise,
  16. * we return the message.
  17. */
  18. @Override
  19. public void messageReceived( IoSession session, Object message ) throws Exception
  20. {
  21. String str = message.toString();
  22. if( str.trim().equalsIgnoreCase("quit") ) {
  23. // "Quit" ? let's get out ...
  24. session.close(true);
  25. return;
  26. }
  27. System.out.println("Received message:"+str);
  28. // Send the "Hello, I am Server!" back to the client
  29. String helloWorld = "Hello, I am Server!";
  30. session.write(helloWorld);
  31. System.out.println("Message written...");
  32. }
  33. /**
  34. * On idle, we just write a message on the console
  35. */
  36. @Override
  37. public void sessionIdle( IoSession session, IdleStatus status ) throws Exception
  38. {
  39. System.out.println( "IDLE " + session.getIdleCount( status ));
  40. }
  41. }

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

四，运行程序

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

五，总结

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

相关文章