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。

相关文章

使用animation.css库快速实现CSS3旋转动画效果

使用animation.css库快速实现CSS3旋转动画效果

《使用animation.css库快速实现CSS3旋转动画效果》随着Web技术的不断发展，动画效果已经成为了网页设计中不可或缺的一部分，本文将深入探讨animation.css的工作原理，如何使用以及... 目录1. css3动画技术简介2. animation.css库介绍2.1 animation.cs
阅读更多...
SpringBoot快速搭建TCP服务端和客户端全过程

SpringBoot快速搭建TCP服务端和客户端全过程

《SpringBoot快速搭建TCP服务端和客户端全过程》：本文主要介绍SpringBoot快速搭建TCP服务端和客户端全过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,... 目录TCPServerTCPClient总结由于工作需要，研究了SpringBoot搭建TCP通信的过程
阅读更多...
POI从入门到实战轻松完成EasyExcel使用及Excel导入导出功能

POI从入门到实战轻松完成EasyExcel使用及Excel导入导出功能

《POI从入门到实战轻松完成EasyExcel使用及Excel导入导出功能》ApachePOI是一个流行的Java库,用于处理MicrosoftOffice格式文件,提供丰富API来创建、读取和修改O... 目录前言:Apache POIEasyPoiEasyExcel一、EasyExcel1.1、核心特性
阅读更多...
Spring框架中@Lazy延迟加载原理和使用详解

Spring框架中@Lazy延迟加载原理和使用详解

《Spring框架中@Lazy延迟加载原理和使用详解》：本文主要介绍Spring框架中@Lazy延迟加载原理和使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐... 目录一、@Lazy延迟加载原理1.延迟加载原理1.1 @Lazy三种配置方法1.2 @Component
阅读更多...
Python中模块graphviz使用入门

Python中模块graphviz使用入门

《Python中模块graphviz使用入门》graphviz是一个用于创建和操作图形的Python库,本文主要介绍了Python中模块graphviz使用入门,具有一定的参考价值,感兴趣的可以了解一... 目录1.安装2. 基本用法2.1 输出图像格式2.2 图像style设置2.3 属性2.4 子图和聚
阅读更多...
一文教你Python如何快速精准抓取网页数据

一文教你Python如何快速精准抓取网页数据

《一文教你Python如何快速精准抓取网页数据》这篇文章主要为大家详细介绍了如何利用Python实现快速精准抓取网页数据,文中的示例代码简洁易懂,具有一定的借鉴价值,有需要的小伙伴可以了解下... 目录1. 准备工作2. 基础爬虫实现3. 高级功能扩展3.1 抓取文章详情3.2 保存数据到文件4. 完整示例
阅读更多...
快速修复一个Panic的Linux内核的技巧

快速修复一个Panic的Linux内核的技巧

《快速修复一个Panic的Linux内核的技巧》Linux系统中运行了不当的mkinitcpio操作导致内核文件不能正常工作，重启的时候，内核启动中止于Panic状态，该怎么解决这个问题呢？下面我们就... 感谢China编程(www.chinasem.cn)网友 鸢一雨音 的投稿写这篇文章是有原因的。为了配置完
阅读更多...
Python利用ElementTree实现快速解析XML文件

Python利用ElementTree实现快速解析XML文件

《Python利用ElementTree实现快速解析XML文件》ElementTree是Python标准库的一部分,而且是Python标准库中用于解析和操作XML数据的模块,下面小编就来和大家详细讲讲... 目录一、XML文件解析到底有多重要二、ElementTree快速入门1. 加载XML的两种方式2.
阅读更多...
利用Python快速搭建Markdown笔记发布系统

利用Python快速搭建Markdown笔记发布系统

《利用Python快速搭建Markdown笔记发布系统》这篇文章主要为大家详细介绍了使用Python生态的成熟工具,在30分钟内搭建一个支持Markdown渲染、分类标签、全文搜索的私有化知识发布系统... 目录引言：为什么要自建知识博客一、技术选型：极简主义开发栈二、系统架构设计三、核心代码实现（分步解析
阅读更多...
使用Python实现快速搭建本地HTTP服务器

使用Python实现快速搭建本地HTTP服务器

《使用Python实现快速搭建本地HTTP服务器》：本文主要介绍如何使用Python快速搭建本地HTTP服务器,轻松实现一键HTTP文件共享,同时结合二维码技术,让访问更简单,感兴趣的小伙伴可以了... 目录1. 概述2. 快速搭建 HTTP 文件共享服务2.1 核心思路2.2 代码实现2.3 代码解读3.
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2