`
jianchen
  • 浏览: 343565 次
  • 性别: Icon_minigender_1
  • 来自: 杭州
社区版块
存档分类
最新评论

MINA网络通信框架

 
阅读更多

基本介绍:

Apache MINA 2 是一个开发高性能和高可伸缩性网络应用程序的网络应用框架。它提供了一个抽象的事件驱动的异步 API,可以使用 TCP/IPUDP/IP、串口和虚拟机内部的管道等传输方式。Apache MINA 2 可以作为开发网络应用程序的一个良好基础。


Mina API 将真正的网络通信与我们的应用程序隔离开来,你只需要关心你要发送、

接收的数据以及你的业务逻辑即可。


mina的基本架构:





在图中的模块链中,IoService 便是应用程序的入口,相当于我们前面代码中的 IoAccepter,IoAccepter 便是 IoService 的一个扩展接口。IoService 接口可以用来添加多个 IoFilter,这些 IoFilter 符合责任链模式并由 IoProcessor 线程负责调用。而 IoAccepter 在 ioService 接口的基础上还提供绑定某个通讯端口以及取消绑定的接口。ioHandler则为应用逻辑处理类。

 

主要类以及接口:

(1.) IoService:这个接口在一个线程上负责套接字的建立,拥有自己的Selector,监

听是否有连接被建立。

 

(2.) IoProcessor:这个接口在另一个线程上负责检查是否有数据在通道上读写,也就是

说它也拥有自己的Selector,这是与我们使用JAVA NIO 编码时的一个不同之处,

通常在JAVA NIO 编码中,我们都是使用一个Selector,也就是不区分IoService

IoProcessor两个功能接口。另外,IoProcessor 负责调用注册在IoService

的过滤器,并在过滤器链之后调用IoHandler

 

(3.) IoFilter:这个接口定义一组拦截器,这些拦截器可以包括日志输出、黑名单过滤、

数据的编码(write 方向)与解码(read 方向)等功能,其中数据的encode decode

是最为重要的、也是你在使用Mina 时最主要关注的地方。

 

(4.) IoHandler:这个接口负责编写业务逻辑,也就是接收、发送数据的地方。

 

(5.)IoSession:Session可以理解为服务器与客户端的特定连接,该连接由服务器地址、端口以及客户端地址、端口来决定。客户端发起请求时,指定服务器地址和端口,客户端也会指定或者根据网络路由信息自动指定一个地址、自动分配一个端口。这个地址、端口对构成一个Session。Session是服务器端对这种连接的抽象,MINA对其进行了封装,定义了IoSession接口,用来代表客户端与服务器的连接,在服务器端来指代客户端,实现对客户端的操作、绑定与客户端有关的信息与对象。通过利用Session的这个概念,编写程序时就可以在服务器端非常方便地区分出是当前处理的是哪个客户端的请求、维持客户端的状态信息、可以实现客户端之间相互通讯。

一图胜千言,MINA的核心类图:


 

服务端代码大致如下:

 

        //初始化Acceptor—可以不指定线程数量,MINA2里面默认是CPU数量+2  
        //是你的工作主线程   
        NioSocketAcceptor acceptor = new NioSocketAcceptor(5);
        //建立线程池
        java.util.concurrent.Executor threadPool = newFixedThreadPool(1500);
        //加入过滤器(Filter)到Acceptor         
        acceptor.getFilterChain().addLast("exector", new ExecutorFilter(threadPool));
        //编码解码器
        acceptor.getFilterChain().addLast("codec",new ProtocolCodecFilter(new WebDecoder(),new XmlEncoder()));
        //日志      
        LoggingFilter filter = new LoggingFilter();
        filter.setExceptionCaughtLogLevel(LogLevel.DEBUG);
        filter.setMessageReceivedLogLevel(LogLevel.DEBUG);
        filter.setMessageSentLogLevel(LogLevel.DEBUG);
        filter.setSessionClosedLogLevel(LogLevel.DEBUG);
        filter.setSessionCreatedLogLevel(LogLevel.DEBUG);
        filter.setSessionIdleLogLevel(LogLevel.DEBUG);
        filter.setSessionOpenedLogLevel(LogLevel.DEBUG);
        acceptor.getFilterChain().addLast("logger", filter);
        //设置的是主服务监听的端口可以重用
        acceptor.setReuseAddress(true);
        //设置每一个非主监听连接的端口可以重用        
        acceptor.getSessionConfig().setReuseAddress(true);
        //MINA2中,当启动一个服务端的时候,要设定初始化缓冲区的长度,如果不设置这个值,系统默认为2048,当客户端发过来的消息超过设定值的时候,
        //MINA2的机制是分段接受的,将字符是放入缓冲区中读取,所以在读取消息的时候,需要判断有多少次。这样的好处就是可以节省通讯的流量。
        //设置输入缓冲区的大小
        acceptor.getSessionConfig().setReceiveBufferSize(1024);
        //设置输出缓冲区的大小
        acceptor.getSessionConfig().setSendBufferSize(10240);
        //设置为非延迟发送,为true则不组装成大包发送,收到东西马上发出         
        acceptor.getSessionConfig().setTcpNoDelay(true);
        //设置主服务监听端口的监听队列的最大值为100,如果当前已经有100个连接,再新的连接来将被服务器拒绝         
        acceptor.setBacklog(100);
        acceptor.setDefaultLocalAddress(new InetSocketAddress(port));
        //加入处理器(Handler)到Acceptor         
        acceptor.setHandler(new YourHandler());
        acceptor.bind();

 

 

客户端代码大致如下:

客户端的初始化和服务器端其实是一样的,就是初始化类不一样,客户端是作为发送者的。

 

        SocketConnector connector = new NioSocketConnector();
        connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(new XmlCodecFactory(Charset.forName(charsetName), null, sertType)));
        //指定线程池
        connector.getFilterChain().addLast("executor", new ExecutorFilter());
        //指定业务处理类
        connector.setHandler(this);

 

在IoHandler中定义了一些事件方法,比如messageReceived,sessionOpend,sessionCreated,exceptionCaught等,用户只需要在方法内部实现对应的处理逻辑即可。

 

心跳机制:

mina自身带的心跳机制好处在于,它附加了处理,让心跳消息不会传到业务层,在底层就完成了。

 

 

事件模型:

 

MINA可以看成是事件驱动的。通常在网络通讯中,可以将整个过程划分为几个基本的阶段,如建立连接、数据通信、关闭连接。

数据通信一般包括数据的发送和接收,由于在通信过程中,可能要多次发送和接收数据,以进行不同的业务交互。

不可能一直都接收和发送数据,因此就有Idle出现,在MINA中,如果在设定的时间内没有数据发送或接收,那么就会触发一个Idle事件。


附录:对与协议的理解,摘自ppt

http协议   对应于应用层  
tcp协议    对应于传输层   
ip协议     对应于网络层  
三者本质上没有可比性。  何况
HTTP协议是基于TCP连接的。 
TCP/IP是传输层协议,主要解决数据如何在网络中传输;而HTTP是应用层协议,主要解决如何包装数据。 
我们在传输数据时,可以只使用传输层(
TCP/IP),但是那样的话,由于没有应用层,便无法识别数据内容,如果想要使传输的数据有意义,则必须使用应用层协议,应用层协议很多,有HTTPFTPTELNET等等,也可以自己定义应用层协议。WEB使用HTTP作传输层协议,以封装HTTP文本信息,然后使用TCP/IP做传输层协议将它发送到网络上。 

Socket是对TCP/IP协议的封装,Socket本身并不是协议,而是一个调用接口(API),通过Socket,我们才能使用TCP/IP协议。 
这也就不难理解为什么有些内部的系统调用采用
socket,而不是http。 
本身
web的这种系统,HTTP已经将报文信息封装好了。各种JEEWEB框架,都能够直接获取报文中的信息,而socket方式,可以双方很方便的自己定义报文的内容,加密方式等等。

 

URL:应用层

SOCKET :网络传输层

Socket(套接字)

是一种基于网络传输层的远程进程间通信编程接口,有操作系统提供一个套接字包含,主机名、端口号两个部分。其中端口号是0~65535之间的一个整数。通常小于1024的端口号被统一分配给特定的网络服务,如ftp服务,21http服务, 80SMTP服务,25POP3服务,110telnet服务,23等等

套接字(socket)是通信的基石,是支持TCP/IP协议的网络通信的基本操作单元。它是网络通信过程中端点的抽象表示,包含进行网络通信必须的五种信息:连接使用的协议,本地主机的IP地址,本地进程的协议端口,远地主机的IP地址,远地进程的协议端口。 
应用层通过传输层进行数据通信时,
TCP会遇到同时为多个应用程序进程提供并发服务的问题。多个TCP连接或多个应用程序进程可能需要通过同一个 TCP协议端口传输数据。为了区别不同的应用程序进程和连接,许多计算机操作系统为应用程序与TCPIP协议交互提供了套接字(Socket)接口。

由于通常情况下Socket连接就是TCP连接,因此Socket连接一旦建立,通信双方即可开始相互发送数据内容,直到双方连接断开。但在实际网络应用中,客户端到服务器之间的通信往往需要穿越多个中间节点,例如路由器、网关、防火墙等,大部分防火墙默认会关闭长时间处于非活跃状态的连接而导致 Socket 连接断连,因此需要通过轮询告诉网络,该连接处于活跃状态。 
HTTP连接使用的是“请求响应”的方式,不仅在请求时需要先建立连接,而且需要客户端向服务器发出请求后,服务器端才能回复数据。 
很多情况下,需要服务器端主动向客户端推送数据,保持客户端与服务器数据的实时与同步。此时若双方建立的是
Socket连接,服务器就可以直接将数据传送给客户端;若双方建立的是HTTP连接,则服务器需要等到客户端发送一次请求后才能将数据传回给客户端,因此,客户端定时向服务器端发送连接请求,不仅可以保持在线,同时也是在“询问”服务器是否有新的数据,如果有就将数据传给客户端。

 

  • 大小: 27.4 KB
  • 大小: 62 KB
分享到:
评论

相关推荐

    MINA网络通信框架.pdf

    Apache MINA是一个强大的网络通信框架,专为构建高性能和高可扩展性的网络应用程序设计。它基于事件驱动和异步模型,支持多种传输协议,如TCP/IP、UDP/IP、串口通信以及虚拟机内部的管道。MINA的核心理念是将网络...

    mina apach 网络通信框架高性能例子

    Apache MINA(Multipurpose Infrastructure for Network Applications)是一个高级网络通信框架,主要针对Java平台设计,提供了高度可扩展和高性能的网络应用开发环境。MINA旨在简化网络编程,特别是对于TCP/IP和UDP...

    Mina通信框架应用示例

    《Mina通信框架应用详解》 Mina通信框架,全称为Apache MINA,是一个高度可扩展的、基于Java的网络应用程序开发框架。MINA的名字来源于多语言(Multi-purpose Infrastructure for Network Applications),它提供了...

    Apache Mina网络通信应用框架实例

    Apache Mina Server 是一个网络通信应用框架 基于 TCP/IP、UDP/IP协议栈的通信框架 支持串口和虚拟机内部的管道等传输方式 Mina 可以帮助我们快速开发高性能、高扩展性的网络通信应用 Mina 提供了事件驱动、异步操作...

    java-mina通信框架详解.docx

    Apache Mina是一个强大的网络通信框架,专为基于TCP/IP和UDP/IP协议栈的应用设计。它提供了JAVA对象的序列化和虚拟机内部通信的功能,使得开发者能够迅速构建高性能、高可扩展性的网络应用。Mina的核心特性是其事件...

    Mina网络通信传输

    Mina网络通信传输是基于Java开发的一个高性能、可伸缩的网络应用框架,常用于构建服务器和客户端之间的通信系统,尤其适用于即时聊天应用。Mina提供了丰富的API和工具,简化了网络编程的复杂性,使得开发者可以专注...

    mina网络通信实例

    《MINA网络通信实例解析》 MINA(Multipurpose Infrastructure for Network Applications)是Apache软件基金会的一个开源项目,它提供了一个高度可扩展且跨平台的网络应用程序框架,主要用于简化开发高性能和高可用...

    MINA长连接框架实现通讯

    MINA(Java Mini Asynchronous Network Application Framework)是一个高性能、异步事件驱动的网络应用程序框架,主要用于简化开发服务器和客户端的网络应用,特别是TCP和UDP协议的应用。MINA为开发者提供了高度抽象...

    mina2核心框架

    MINA(Java Multithreaded Network Application Framework)是一个由Apache软件基金会开发的开源网络通信框架,主要应用于构建高性能、高可用性的网络服务。MINA2作为其最新版本,尤其在处理大量并发连接时展现出了...

    高性能网络架构Mina框架 下载

    ### 高性能网络架构Mina框架...综上所述,Mina框架作为一款高性能的网络通信框架,在Java NIO环境下展现出了卓越的性能和稳定性。无论是对于初学者还是有经验的开发者而言,深入学习和掌握Mina都将是一笔宝贵的财富。

    Java springboot 整合mina 框架,nio通讯基础教程,mina框架基础教程.zip

    Mina框架是一个轻量级的网络通信框架,基于Java NIO构建,它简化了网络编程的复杂性,提供了高效的I/O处理能力。Mina支持多种协议,如TCP、UDP等,适用于开发服务器端和客户端应用。Mina的核心组件包括IoSession...

    Mina通信框架应用

    Apache Mina(Minimum Asynchronous Network Application framework)是一个开源的网络通信框架,主要设计用于简化高性能服务器的开发。它提供了一种与传输层协议无关的抽象层,允许开发者专注于业务逻辑,而无需...

    mina框架资源包

    通过阅读源码,开发者可以学习到如何设计和实现一个高性能的网络通信框架,也可以根据项目需求进行扩展和修改,增强Mina的功能,或者优化其性能。 3. **SLF4J日志库**:`slf4j-1.7.25.zip` Simple Logging Facade ...

    mina双向通信已测试

    它提供了简单的API来处理网络通信,包括创建服务端和客户端的连接,读写数据,以及处理各种网络事件。 **双向通信** 双向通信指的是客户端和服务端都可以主动发送数据。在Mina中,这一功能通过使用`IoSession`对象...

    Mina框架入门介绍

    Apache Mina 框架是一个强大的网络通信框架,它的核心目标是简化开发高效且可扩展的网络应用程序。Mina 提供了基于事件驱动和异步IO的编程模型,特别是利用了Java NIO作为其默认的底层支持,这使得开发者能够构建高...

    Mina2.0框架源码剖析.pdf

    * 实时通信系统:Mina2.0框架提供了高性能的网络通信能力,非常适合实时通信系统的开发。 * 网络游戏服务器:Mina2.0框架提供了灵活的API,非常适合网络游戏服务器的开发。 * 数据采集系统:Mina2.0框架提供了强大的...

    MINA通讯框架的两个简单实例和文档

    Apache的Mina(Multipurpose Infrastructure Networked Applications)是一个网络应用框架,可以帮助用户开发高性能和高扩展性的网络应用程序;它提供了一个抽象的、事件驱动的异步API,使Java NIO在各种传输协议...

    JAVA 通信框架MINA(包含心跳)

    Apache MINA 是一个开发高性能和高可伸缩性网络应用程序的网络应用框架。它提供了一个抽象的事件驱动的异步 API,可以使用 TCP/IP、UDP/IP、串口和虚拟机内部的管道等传输方式。Apache MINA 可以作为开发网络应用...

    mina简单通信需要的包

    总结来说,Apache Mina是一个强大的网络通信框架,而SLF4J是其日志支持。通过这两个库,开发者可以构建高效、灵活的网络应用,实现简单或复杂的通信协议。在实际开发中,理解Mina的核心概念、事件驱动模型以及如何与...

    Mina+Socket通信

    Mina和Socket是两种常见的网络通信框架和技术,它们在Java编程环境中被广泛使用。本篇文章将深入探讨如何使用Mina与Socket实现通信,并提供客户端和服务端的实现代码概述。 Mina(全称“MINA: Minimalistic ...

Global site tag (gtag.js) - Google Analytics