`

Apache MINA 快速入门指南

 
阅读更多
最近用到Socket套接字编程,在服务器监听方面还没有具体思路,朋友推荐了Apahce Mina,就在官方看了一下快速入门文档。原文是英文的,学习之余就将它翻译出来和大家共享!关于Mina的中文简介内容不多就摘抄了一些。

“MINA是一个Socket的网络框架,但是它提供了方便的Protocol支持,通过它的Encoder和Decoder,你将你的应用可以方便的扩展并支持各种基于Socket的网络协议,比如HTTP服务器、FTP服务器(当然,这很复杂)、Telnet服务器等等。基于MINA用户可以容易地开发高性能和高伸缩性的网络应用程序。”

下面是对官方入门文档的中文译版,由于完全参照官方文档在程序具体运行时遇到一些import不足的情况,在示例源码的import是我在亲自实践后修改过的,其他的地方都和原文一样。

Apache MINA 快速入门

1简介

建立一个基于MINA的时间服务器,下面的内容需要先准备好。

1,Mina 1.1 Core
2,JDK 1.5 or greater
3,SLF4J 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 。比如说slf4j-log4j12.jar 和log4j-1.3.x.jar 是不能在一起使用的,将会出现功能障碍。


(我用了1.2系列,那么所有的软件包就是:
log4j-1.2.14.jar;
mina-core-1.1.2.jar;
slf4j-api-1.2.jar;
slf4j-jdk14-1.2.jar;
slf4j-log4j12-1.2.jar)

这个程序只测试了Windows2000pro 和 Linux系统,并且在做的时候没有依赖于一些开发平台的环境。

2编写MINA时间服务


下面先建立一个文件MinaTimeServer.java,代码如下:

public class MinaTimeServer {
    public static void main(String[] args) {
      // code will go here next
    }
}


下面会慢慢将这个类写完,这里先定义一个main用于启动程序。这一步结束后,还需要一个监听连接的对象,因为这个程序是基于TCP/IP的,这里将增加一个SocketAcceptor。

import org.apache.mina.common.IoAcceptor;
import org.apache.mina.transport.socket.nio.SocketAcceptor;

public class MinaTimeServer {
    public static void main(String[] args) {
      // The following two lines change the default buffer type to 'heap',
      // which yields better performance.
      ByteBuffer.setUseDirectBuffers(false);
      ByteBuffer.setAllocator(new SimpleByteBufferAllocator());
      IoAcceptor acceptor = new SocketAcceptor();
    }
}


通过这里的SocketAcceptor类,下面将把它绑定到一个端口上,如果你想增加一个线程模型到该类的话,参考"配置线程模型"部分。

   现在我们为SocketAcceptor添加设置。它允许我们为Socekt配置明确套接字用于允许来自客户端的连接。

import java.io.IOException;
import java.net.InetSocketAddress;
import org.apache.mina.common.IoAcceptor;
import org.apache.mina.transport.socket.nio.SocketAcceptor;

public class MinaTimeServer {

    private static final int PORT = 9123;

    public static void main(String[] args) throws IOException {
        ByteBuffer.setUseDirectBuffers(false);
        ByteBuffer.setAllocator(new SimpleByteBufferAllocator());

        IoAcceptor acceptor = new SocketAcceptor();

        SocketAcceptorConfig cfg = new SocketAcceptorConfig();
        cfg.getSessionConfig().setReuseAddress( true );
        cfg.getFilterChain().addLast( "logger", new LoggingFilter() );
        cfg.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));

    }
}


   SocketAcceptorConfig类的实例用于当我们每次准备启动acceptor的时候进入这个acceptor。

    首先,我们设置一个重用地址标识。从 JDK Documentation可以了解更多关于这里的知识。

     然后我们在配置中添加一个过滤器。这个过滤器filter将记录所有信息,例如最近创建的sessions,收到的消息,发送的消息,session关闭。

    下一个过滤器是一个ProtocolCodecFilter。这个过滤器可以将二进制数据或编码协议数据转换成消息对象和代替法。

下面的部分来为acceptor绑定端口。这个方法标志着服务器进程的启动,如果这个方法没有被调用,服务器将不会与客户端进行连接。

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.charset.Charset;

import org.apache.mina.common.ByteBuffer;
import org.apache.mina.common.IoAcceptor;
import org.apache.mina.common.SimpleByteBufferAllocator; 
import org.apache.mina.transport.socket.nio.SocketAcceptor;
import org.apache.mina.filter.LoggingFilter;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.nio.SocketAcceptorConfig;

public class MinaTimeServer {

    private static final int PORT = 9123;

    public static void main(String[] args) throws IOException {
        ByteBuffer.setUseDirectBuffers(false);
        ByteBuffer.setAllocator(new SimpleByteBufferAllocator());

        IoAcceptor acceptor = new SocketAcceptor();

        SocketAcceptorConfig cfg = new SocketAcceptorConfig();
        cfg.getFilterChain().addLast( "logger", new LoggingFilter() );
        cfg.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));

        acceptor.bind( new InetSocketAddress(PORT), new TimeServerHandler(), cfg);
        System.out.println("MINA Time server started.");
    }
}


这里定义了一个整型的端口变量,呼叫SocketAcceptor.bind(SocketAddress,IoHandler,cfg),第一个参数是要监听的网址,是本地的9123端口。

第二个参数传的是实现IoHandler接口的类,是服务于所有的客户端请求的。在这里,将会扩展IoHandlerAdapter类,这类遵循"适配器设计模式"的。

第三个参数是配置对象,用于配置日志和编码过滤器。每一个信息都会通过在IoAcceptor中定义的过滤器链的所有过滤器。在这风景点,将会将信息通过日志和编码过滤器。日志过滤器用SL4J库记录信息,而编码过滤器则反编码所有收到的信息,并且将所有TextLineCodecFactory发送的信息进行编码。

下面就是TimeServerHandler类的代码:

import java.util.Date;
import org.apache.mina.common.IoHandlerAdapter;
import org.apache.mina.common.IoSession;

public class TimeServerHandler extends IoHandlerAdapter {

    public void exceptionCaught(IoSession session, Throwable t) throws Exception {
      t.printStackTrace();
      session.close();
    }

    public void messageReceived(IoSession session, Object msg) throws Exception {
      String str = msg.toString();
      if( str.trim().equalsIgnoreCase("quit") ) {
        session.close();
        return;
      }
      Date date = new Date();
      session.write( date.toString() );
      System.out.println("Message written...");
    }

    public void sessionCreated(IoSession session) throws Exception {
      System.out.println("Session created...");
      if( session.getTransportType() == TransportType.SOCKET )
        ((SocketSessionConfig) session.getConfig() ).setReceiveBufferSize( 2048 );
      session.setIdleTime( IdleStatus.BOTH_IDLE, 10 );
    }
}


这里用于管理信息,覆盖了exceptionCaught,messageReceived 和 sessionCreated 方法,如前所示,该类扩展了IoHandlerAdapter。

exceptionCaught 方法将会打印错误并且关闭对话,对于大多数的情况来讲,这是标准的处理方法,除非能从异常中恢复过来。

messageReceived 方法将收到从客户端发来的数据,并且写回当前时间。如果收到了"quit",对话将被关闭。该方法将当前时间发往客户端,依赖于你使用的协议编码,发送至方法的对象(第二个参数)会有不同,发送到session.write(Object)方法的对象类同。如果你没有指定协议编码,则一般会收到ByteBuffer对象,而发送的也要是ByteBuffer对象。

sessionCreated 方法用于对话初始化,在这里,先打印一条信息,然后判断对话的类型,再设置缓冲大小,这里设置的是2048个字节。空闲时间设置为10秒,如果覆盖了sessionIdle方法,则该方法每10秒被呼叫一次。

3测试

到这里,编译程序。如果成功,那么启动程序,登陆telnet访问程序,如下所示:

客户端内容:
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... 




4 参考文档
    Apache MINA Quick Start Guide http://mina.apache.org/documentation.html

(ps:setReuseAddress( true )这个方法正好解决了我最近遇到的一个难题。就是,一个JAVA的SOCKET服务,在LINUX服务器上kill掉了,但是端口仍然被占用,要过一段时间才能释放)
分享到:
评论

相关推荐

    Apache MINA 2.0 用户指南中英文对照阅读版[带书签]

    本资源包含两个 pdf 文档,一本根据官方最新文档 (http://mina.apache.org/mina-project/userguide/user-guide-toc.html) 整理的 mina_2.0_user_guide_en.pdf,一个中文翻译的 mina_2.0_user_guide_cn.pdf。...

    Apache MINA基于JAVA的网络服务器框架 教程.zip

    3. **Apache MINA 快速入门 lj棒.txt**:这可能是一个快速入门指南,帮助开发者快速理解MINA的基本概念和实现一个简单的网络服务器。 4. **SmartFoxServer 是专门为Adobe Flash设计的跨平台socket服务器**:...

    apache mina

    - 通过Apache_Mina入门资料,我们可以学习如何创建服务器和客户端,设置IoFilter和IoHandler,以及如何处理网络事件。 - Apache MINA Server 2.0中文参考手册提供了详细的技术指南,包括API的使用、配置示例和最佳...

    apache_mina2收集的教程

    《Mina2.0快速入门与源码剖析》是一份快速上手指南,适合初学者。它会引导你完成Mina2的安装和基本应用开发,同时也会带你走进Mina的源码世界,帮助你理解框架内部的工作流程,这对于进一步的定制和扩展非常有帮助。...

    3本mina教程和mina帮助文档

    **Apache+Mina+ABC.pdf**:这个文档可能是对Mina的基础知识进行简单介绍的教程,"ABC"通常代表"基础、基本、入门",所以这本书可能会涵盖Mina的基本概念、安装步骤、第一个Mina应用的创建等内容,为初学者提供一个...

    MINA_API+MINA_DOC+mina

    MINA (Java IO Network ...总的来说,这个压缩包为初学者提供了一套完整的MINA学习资源,涵盖了理论知识、API详解和实战指导,有助于开发者快速入门并精通MINA框架,从而在实际工作中实现高效、稳定的网络通信应用。

    mina 学习资料

    2. **参考文档**:在压缩包中可能包含的MINA官方文档,通常包括用户指南、API参考和开发者指南,这些文档详尽解释了MINA的核心概念、类库和方法,帮助开发者快速熟悉MINA的工作机制。 3. **教程**:教程可能是MINA...

    MINA开发手册和JAR包

    1. **入门指南**:介绍如何搭建MINA环境,以及快速创建一个简单的MINA应用。 2. **核心概念**:解释MINA中的关键组件,如Session、Filter、ProtocolDecoder和ProtocolEncoder等。 3. **API详解**:详细阐述MINA提供...

    Mina 2.0.0包

    2. **文档**:压缩包可能包含了API文档、用户指南和开发者手册,这些都是了解Mina API和最佳实践的重要资源。通过阅读这些文档,开发者可以快速上手并理解如何有效地使用Mina框架。 3. **示例**:Mina通常会提供...

    mina学习笔记

    《Mina2.0快速入门与源码剖析》这本书可能是MINA 2.0版本的指南,它可能包含以下内容: 1. 快速入门教程:针对MINA 2.0的新特性,提供快速搭建和运行MINA服务端和客户端的步骤。 2. 源码分析:对MINA的关键模块进行...

    Mina2.0阅读源码笔记(很值得一看)

    - **QuickStart**: 快速入门指南,非常适合初学者快速上手。 - **UserGuide**: 用户指南,涵盖了 Mina 的基本概念和多个实用示例,是深入理解 Mina 功能的关键文档。 #### 二、Mina 核心概念与组件 1. **Io...

    MINA2的实用参考手册

    《MINA2的实用参考手册》是一份详细阐述Apache MINA框架的实用指南,主要针对开发者和系统架构师。MINA(Multipurpose Infrastructure for Network Applications)是一个高性能、跨平台的网络应用程序开发框架,尤其...

    MINA2 用户手册(中英文2个版本)加API(英文)

    它们帮助开发者快速入门,理解MINA2的工作原理,并逐步掌握其高级特性。 8. **应用场景**:MINA2广泛应用于高性能的网络应用开发,例如在线游戏服务器、实时数据交换系统、分布式计算节点通信等,尤其适合需要处理...

    java8源码-book:书

    入门指南 Atom 飞行手册中文版 AWK程序设计语言 Backbone.js入门教程第二版 Beyond the C++ Standard Library 中文版 Bootstrap3 中文官方文档 Beautiful Soup 4.2.0 文档 C/C++ API 参考(英文) C/C++ 中文参考 ...

    java版飞机大战源码-Books:图书

    入门指南 Atom 飞行手册中文版 AWK程序设计语言 Backbone.js入门教程第二版 Beyond the C++ Standard Library 中文版 Bootstrap3 中文官方文档 Beautiful Soup 4.2.0 文档 C/C++ API 参考(英文) C/C++ 中文参考 ...

    安卓java读取网页源码-it-ebooks-archive:it-ebooks-archive

    安卓java读取网页源码计算机开放电子书汇总 100个gcc小技巧 ...入门指南 Atom 飞行手册中文版 AWK程序设计语言 Backbone.js 中文文档1.1.2 Backbone.js入门教程第二版 Beyond the C++ Standard Library 中文版

    camel-manual-2.8.0

    ### 快速入门指南 为了快速开始使用Apache Camel,读者可以从本章节的一些简单示例入手。这些示例将引导用户了解如何设置环境、创建基本的路由和处理消息传递。 ### 结论 Apache Camel 2.8.0版本为企业级集成提供...

    java8集合源码分析-it-ebooks-archive:计算机开放电子书(不完全)汇总

    java8 集合源码分析计算机开放电子书汇总 100个gcc小技巧 100个gdb小技巧 ...入门指南 Atom 飞行手册中文版 AWK程序设计语言 Backbone.js 中文文档1.1.2 Backbone.js入门教程第二版 Beyond the C++ Standa

    java版飞机大战源码-it-ebooks-archive:https://github.com/it-ebooks/it-ebooks-ar

    java版飞机大战源码计算机开放电子书汇总 100个gcc小技巧 100个gdb小技巧 ...入门指南 Atom 飞行手册中文版 AWK程序设计语言 Backbone.js 中文文档1.1.2 Backbone.js入门教程第二版 Beyond the C++ Standar

    camel2.2.0 手册

    - 快速入门(Quickstart):提供快速启动指南和示例。 - 开始(Getting Started):引导用户如何开始使用 Camel。 - 架构(Architecture):详细介绍 Camel 的内部架构。 - 企业集成模式(Enterprise Integration ...

Global site tag (gtag.js) - Google Analytics