Mina框架快速入门

2024-05-25 09:08
文章标签 入门 快速 框架 mina

本文主要是介绍Mina框架快速入门，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

翻译网址：http://mina.apache.org/mina-project/quick-start-guide.html
第一次写了一个比较正式的译文，如不好请指正~！

Mina框架快速入门
此教程将带你构建一个基于Mina的程序.它将带你构建一个时间服务器.
此教程需要以下先决条件:
  • MINA 2.0.7 Core
  • JDK 1.5 or greater
  • [SLF4J|http://www.slf4j.org/] 1.3.0 or greater
    • Log4J 1.2 users: slf4j-api.jar, slf4j-log4j12.jar, and Log4J 1.2.x
    • Log4J 1.3 users: slf4j-api.jar, slf4j-log4j13.jar, and Log4J 1.3.x
    • java.util.logging users: slf4j-api.jar and slf4j-jdk14.jar
    • 重要: 请确保你使用正确的 slf4j-*.jar 以匹配你的logging框架. 例如, slf4j-log4j12.jar and log4j-1.3.x.jar 不能一起使用, 会出故障.

我已经在Windows2000专业版和Linux上测试过程序.如果你运行该程序有任何问题请不要犹豫,联系我们,与Mina开发者对话.同时,这个教程一直尝试保持独立的开发环境(IDE，编辑器．．．等等)．此教程可运行在任何你熟知的环境下。编辑指令和步进执行此程序已经因为简洁被移除。如果你需要学习如何编辑执行Java程序的帮助，请查阅此Java教程： http://docs.oracle.com/javase/tutorial/

编写MINA时间服务器
我们将以通过创建一个名叫MinaTimeServer.java的文件开始。初始代码如下： 
   
  1. public class MinaTimeServer {
  3.     public static void main(String[] args) {
  4.         // code will go here next
  5.     }
  6. }
这段代码对所有人来说应该是简单的。我们简单定义一个mian方法用来启动程序。在这点上，我们将开始添加代码以补足我们的服务器。首先，我们需要一个对象用来监听进来的连接。因为这个程序是基于TCP/IP的，所以我们将给我们的程序添加一个SocketAcceptor。 
   
  1. import org.apache.mina.core.service.IoAcceptor;
  2. import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
  4. public class MinaTimeServer
  5. {
  6.     public static void main( String[] args )
  7.     {
  8.         IoAcceptor acceptor = new NioSocketAcceptor();
  9.     }
  10. }
在NioSocketAcceptor的地方，我们就可以开始定义 处理类，并将NioSocketAcceptor绑定到一个端口。

接下来，我们给配置添加一个过滤器。这个过滤器将记录所有信息，比如：新创建的会话，接收到的消息，发送过的消息，会话关闭。下一个过滤器是一个 ProtocolCodecFilter。这个过滤器将翻译二进制或 协议的 特定数据到消息对象，反之亦然。我们使用一个存在的TextLine factory(文本行工厂)，因为它将为你处理文本消息（你不必再编写编码解码部分了） 
   
  1. import java.nio.charset.Charset;
  3. import org.apache.mina.core.service.IoAcceptor;
  4. import org.apache.mina.filter.codec.ProtocolCodecFilter;
  5. import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
  6. import org.apache.mina.filter.logging.LoggingFilter;
  7. import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
  9. public class MinaTimeServer
  10. {
  11.     public static void main( String[] args )
  12.     {
  13.         IoAcceptor acceptor = new NioSocketAcceptor();
  15.         acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );
  16.         acceptor.getFilterChain().addLast( "codec",new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));
  17.     }
  18. }

这时，我们将定义处理类用以服务客户端连接和当前时间的请求。这个处理类是一个必需实现IoHandler接口的类。因为几乎所有程序都使用MINA，所以这里变成了程序的重中之重，因为它服务 所有 来自客户端进来的请求。在这个教程，我们将扩展类 IoHandlerAdapter。这个是一个适配器模式类，用以简化需要编写的代码数量，为了满足传递实现IoHandler接口的类的要求。 
   
  1. import java.io.IOException;
  2. import java.nio.charset.Charset;
  4. import org.apache.mina.core.service.IoAcceptor;
  5. import org.apache.mina.filter.codec.ProtocolCodecFilter;
  6. import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
  7. import org.apache.mina.filter.logging.LoggingFilter;
  8. import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
  10. public class MinaTimeServer
  11. {
  12.     public static void main( String[] args ) throws IOException
  13.     {
  14.         IoAcceptor acceptor = new NioSocketAcceptor();
  16.         acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );
  17.         acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));
  19.         acceptor.setHandler(  new TimeServerHandler() );
  20.     }
  21. }
我们现在将添加NioSocketAcceptor配置。这允许我们给socket做特定的套接字设置，用来接收来自客户端的连接。 
    
  1. import java.io.IOException;
  2. import java.nio.charset.Charset;
  4. import org.apache.mina.core.session.IdleStatus;
  5. import org.apache.mina.core.service.IoAcceptor;
  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;
  11. public class MinaTimeServer
  12. {
  13.     public static void main( String[] args ) throws IOException
  14.     {
  15.         IoAcceptor acceptor = new NioSocketAcceptor();
  17.         acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );
  18.         acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));
  20.         acceptor.setHandler(  new TimeServerHandler() );
  22.         acceptor.getSessionConfig().setReadBufferSize( 2048 );
  23.         acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );
  24.     }
  25. }
在MinaTimeServer类里有2行新的代码。这些方法设置IoHandler,输入缓冲区的大小和会话的空闲属性。
缓冲区大小 被指定是为了告诉底层操作系统 给进来的数据 分配多少空间。
第二行指定何时检查空闲的会话。在调用的setIdleTime中，第一个参数定义了当一个会话空闲了，以什么方式来检查，第二个参数定义了 会话会被认为是空闲之前的 以秒为单位的时间的长度。

处理类的代码显示如下： 
    
  1. import java.util.Date;
  3. import org.apache.mina.core.session.IdleStatus;
  4. import org.apache.mina.core.service.IoHandlerAdapter;
  5. import org.apache.mina.core.session.IoSession;
  7. public class TimeServerHandler extends IoHandlerAdapter
  8. {
  9.     @Override
  10.     public void exceptionCaught( IoSession session, Throwable cause ) throws Exception
  11.     {
  12.         cause.printStackTrace();
  13.     }
  15.     @Override
  16.     public void messageReceived( IoSession session, Object message ) throws Exception
  17.     {
  18.         String str = message.toString();
  19.         if( str.trim().equalsIgnoreCase("quit") ) {
  20.             session.close();
  21.             return;
  22.         }
  24.         Date date = new Date();
  25.         session.write( date.toString() );
  26.         System.out.println("Message written...");
  27.     }
  29.     @Override
  30.     public void sessionIdle( IoSession session, IdleStatus status ) throws Exception
  31.     {
  32.         System.out.println( "IDLE " + session.getIdleCount( status ));
  33.     }
  34. }
在这个类中使用的方法为 exceptionCaught, messageReceived and sessionIdle;
exceptionCaught
为了处理进程 和 处理远程连接的正常过程中出现的异常， exceptionCaught 应该总是被定义。如果这个方法没有被定义，异常可能不被及时报告。
exceptionCaught方法将简单打印错误的栈轨迹，并且关闭会话。对大部分程序来说，这个标准的做法，除非处理类能恢复这个异常条件。

messageReceived
messageReceived方法 将从客户端接收数据并写回给客户端以当前时间。如果从客户端接收的消息是单词"quit"，这时 会话 将被关闭。这个方法也对客户端打印出当前时间。依靠你使用的编码解码协议，进到这个方法来的对象（第二个参数）是不同的，以及你用session.write(对象)方法传递给这个会话的对象。如果你没有做特定的编码解码协议，你将最可能接收到一个IoBuffer对象，并要求写回一个IoBuffer对象。

sessionIdle
一旦会话持续空闲 达到你调用  acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 )  指定的 总时间， sessionIdle方法  将被调用。

剩下要做的是定义 服务器要监听的 socket的地址，并实际调用以开启服务器。
代码显示如下： 
   
  1. import java.io.IOException;
  2. import java.net.InetSocketAddress;
  3. import java.nio.charset.Charset;
  5. import org.apache.mina.core.service.IoAcceptor;
  6. import org.apache.mina.core.session.IdleStatus;
  7. import org.apache.mina.filter.codec.ProtocolCodecFilter;
  8. import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
  9. import org.apache.mina.filter.logging.LoggingFilter;
  10. import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
  12. public class MinaTimeServer
  13. {
  14.     private static final int PORT = 9123;
  16.     public static void main( String[] args ) throws IOException
  17.     {
  18.         IoAcceptor acceptor = new NioSocketAcceptor();
  20.         acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );
  21.         acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));
  23.         acceptor.setHandler( new TimeServerHandler() );
  24.         acceptor.getSessionConfig().setReadBufferSize( 2048 );
  25.         acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );
  26.         acceptor.bind( new InetSocketAddress(PORT) );
  27.     }
  28. }

试验时间服务器
这时我们可以继续并编译程序。一旦你编译成功，你就可以运行这个程序，检测其会发生什么。测试这个程序最便捷的方式是启动这个程序，然后 telnet 这个程序。
Client Output Server Output
user@myhost:~> telnet 127.0.0.1 9123
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is '^]'.
hello
Mon Apr 09 23:42:55 EDT 2007
quit
Connection closed by foreign host.
user@myhost:~>		 MINA Time server started.
Session created...
Message written...
下一步？
请访问我们用户指导页http://mina.apache.org/mina-project/userguide/user-guide-toc.html，会发现更多的资源。


这篇关于Mina框架快速入门的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1001069。

相关文章

从入门到精通MySQL联合查询

从入门到精通MySQL联合查询

《从入门到精通MySQL联合查询》：本文主要介绍从入门到精通MySQL联合查询,本文通过实例代码给大家介绍的非常详细,需要的朋友可以参考下... 目录摘要1. 多表联合查询时mysql内部原理2. 内连接3. 外连接4. 自连接5. 子查询6. 合并查询7. 插入查询结果摘要前面我们学习了数据库设计时要满
阅读更多...
从入门到精通C++11 ＜chrono＞ 库特性

从入门到精通C++11 ＜chrono＞ 库特性

《从入门到精通C++11＜chrono＞库特性》chrono库是C++11中一个非常强大和实用的库,它为时间处理提供了丰富的功能和类型安全的接口,通过本文的介绍,我们了解了chrono库的基本概念... 目录一、引言1.1 为什么需要<chrono>库1.2<chrono>库的基本概念二、时间段（Durat
阅读更多...
Spring 框架之Springfox使用详解

Spring 框架之Springfox使用详解

《Spring框架之Springfox使用详解》Springfox是Spring框架的API文档工具,集成Swagger规范,自动生成文档并支持多语言/版本,模块化设计便于扩展,但存在版本兼容性、性... 目录核心功能工作原理模块化设计使用示例注意事项优缺点优点缺点总结适用场景建议总结Springfox 是
阅读更多...
解析C++11 static_assert及与Boost库的关联从入门到精通

解析C++11 static_assert及与Boost库的关联从入门到精通

《解析C++11static_assert及与Boost库的关联从入门到精通》static_assert是C++中强大的编译时验证工具,它能够在编译阶段拦截不符合预期的类型或值,增强代码的健壮性,通... 目录一、背景知识：传统断言方法的局限性1.1 assert宏1.2 #error指令1.3 第三方解决
阅读更多...
Linux如何快速检查服务器的硬件配置和性能指标

Linux如何快速检查服务器的硬件配置和性能指标

《Linux如何快速检查服务器的硬件配置和性能指标》在运维和开发工作中,我们经常需要快速检查Linux服务器的硬件配置和性能指标,本文将以CentOS为例,介绍如何通过命令行快速获取这些关键信息,... 目录引言一、查询CPU核心数编程（几C？）1. 使用 nproc（最简单）2. 使用 lscpu（详细信
阅读更多...
从入门到精通MySQL 数据库索引(实战案例)

从入门到精通MySQL 数据库索引(实战案例)

《从入门到精通MySQL数据库索引(实战案例)》索引是数据库的目录,提升查询速度,主要类型包括BTree、Hash、全文、空间索引,需根据场景选择,建议用于高频查询、关联字段、排序等,避免重复率高或... 目录一、索引是什么？能干嘛？核心作用：二、索引的 4 种主要类型（附通俗例子）1. BTree 索引（
阅读更多...
Redis 配置文件使用建议redis.conf 从入门到实战

Redis 配置文件使用建议redis.conf 从入门到实战

《Redis配置文件使用建议redis.conf从入门到实战》Redis配置方式包括配置文件、命令行参数、运行时CONFIG命令,支持动态修改参数及持久化,常用项涉及端口、绑定、内存策略等,版本8... 目录一、Redis.conf 是什么？二、命令行方式传参（适用于测试）三、运行时动态修改配置（不重启服务
阅读更多...
Python的端到端测试框架SeleniumBase使用解读

Python的端到端测试框架SeleniumBase使用解读

《Python的端到端测试框架SeleniumBase使用解读》：本文主要介绍Python的端到端测试框架SeleniumBase使用,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全... 目录SeleniumBase详细介绍及用法指南什么是 SeleniumBase？SeleniumBase
阅读更多...
MySQL DQL从入门到精通

MySQL DQL从入门到精通

《MySQLDQL从入门到精通》通过DQL,我们可以从数据库中检索出所需的数据,进行各种复杂的数据分析和处理,本文将深入探讨MySQLDQL的各个方面,帮助你全面掌握这一重要技能,感兴趣的朋友跟随小... 目录一、DQL 基础：SELECT 语句入门二、数据过滤：WHERE 子句的使用三、结果排序：ORDE
阅读更多...
一文详解如何在idea中快速搭建一个Spring Boot项目

一文详解如何在idea中快速搭建一个Spring Boot项目

《一文详解如何在idea中快速搭建一个SpringBoot项目》IntelliJIDEA作为Java开发者的‌首选IDE‌,深度集成SpringBoot支持,可一键生成项目骨架、智能配置依赖,这篇文... 目录前言1、创建项目名称2、勾选需要的依赖3、在setting中检查maven4、编写数据源5、开启热
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2