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。

相关文章

springboot security快速使用示例详解

springboot security快速使用示例详解

《springbootsecurity快速使用示例详解》：本文主要介绍springbootsecurity快速使用示例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝... 目录创www.chinasem.cn建spring boot项目生成脚手架配置依赖接口示例代码项目结构启用s
阅读更多...
Python Dash框架在数据可视化仪表板中的应用与实践记录

Python Dash框架在数据可视化仪表板中的应用与实践记录

《PythonDash框架在数据可视化仪表板中的应用与实践记录》Python的PlotlyDash库提供了一种简便且强大的方式来构建和展示互动式数据仪表板,本篇文章将深入探讨如何使用Dash设计一... 目录python Dash框架在数据可视化仪表板中的应用与实践1. 什么是Plotly Dash？1.1
阅读更多...
基于Flask框架添加多个AI模型的API并进行交互

基于Flask框架添加多个AI模型的API并进行交互

《基于Flask框架添加多个AI模型的API并进行交互》：本文主要介绍如何基于Flask框架开发AI模型API管理系统,允许用户添加、删除不同AI模型的API密钥,感兴趣的可以了解下... 目录1. 概述2. 后端代码说明2.1 依赖库导入2.2 应用初始化2.3 API 存储字典2.4 路由函数2.5 应
阅读更多...
Python GUI框架中的PyQt详解

Python GUI框架中的PyQt详解

《PythonGUI框架中的PyQt详解》PyQt是Python语言中最强大且广泛应用的GUI框架之一,基于Qt库的Python绑定实现,本文将深入解析PyQt的核心模块,并通过代码示例展示其应用场... 目录一、PyQt核心模块概览二、核心模块详解与示例1. QtCore - 核心基础模块2. QtWid
阅读更多...
最新Spring Security实战教程之Spring Security安全框架指南

最新Spring Security实战教程之Spring Security安全框架指南

《最新SpringSecurity实战教程之SpringSecurity安全框架指南》SpringSecurity是Spring生态系统中的核心组件,提供认证、授权和防护机制,以保护应用免受各种安... 目录前言什么是Spring Security？同类框架对比Spring Security典型应用场景传统
阅读更多...
C++快速排序超详细讲解

C++快速排序超详细讲解

《C++快速排序超详细讲解》快速排序是一种高效的排序算法,通过分治法将数组划分为两部分,递归排序,直到整个数组有序,通过代码解析和示例,详细解释了快速排序的工作原理和实现过程,需要的朋友可以参考下... 目录一、快速排序原理二、快速排序标准代码三、代码解析四、使用while循环的快速排序1.代码代码1.由快
阅读更多...
Win32下C++实现快速获取硬盘分区信息

Win32下C++实现快速获取硬盘分区信息

《Win32下C++实现快速获取硬盘分区信息》这篇文章主要为大家详细介绍了Win32下C++如何实现快速获取硬盘分区信息,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 实现代码CDiskDriveUtils.h#pragma once #include <wtypesbase
阅读更多...
Python FastAPI入门安装使用

Python FastAPI入门安装使用

《PythonFastAPI入门安装使用》FastAPI是一个现代、快速的PythonWeb框架,用于构建API,它基于Python3.6+的类型提示特性,使得代码更加简洁且易于绶护,这篇文章主要介... 目录第一节：FastAPI入门一、FastAPI框架介绍什么是ASGI服务（WSGI）二、FastAP
阅读更多...
Python结合Flask框架构建一个简易的远程控制系统

Python结合Flask框架构建一个简易的远程控制系统

《Python结合Flask框架构建一个简易的远程控制系统》这篇文章主要为大家详细介绍了如何使用Python与Flask框架构建一个简易的远程控制系统,能够远程执行操作命令（如关机、重启、锁屏等）,还... 目录1.概述2.功能使用系统命令执行实时屏幕监控3. BUG修复过程1. Authorization
阅读更多...
Spring AI与DeepSeek实战一之快速打造智能对话应用

Spring AI与DeepSeek实战一之快速打造智能对话应用

《SpringAI与DeepSeek实战一之快速打造智能对话应用》本文详细介绍了如何通过SpringAI框架集成DeepSeek大模型,实现普通对话和流式对话功能,步骤包括申请API-KEY、项目搭... 目录一、概述二、申请DeepSeek的API-KEY三、项目搭建3.1. 开发环境要求3.2. mav
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2