Apache MINA框架「建议收藏」

ApacheMINA(MultipurposeInfrastructureforNetworkApplications)是Apache组织一个较新的项目,它为开发高性能和高可用性的网络应用程序提供了非常便利的框架。当前发行的MINA版本支持基于JavaNIO技术的TCP/UDP应用程序开发、串口通讯程序(只在最新的预览版中提供),MINA所支持的功能也在进一步的扩展

大家好,又见面了,我是你们的朋友全栈君。

          Apache MINA(Multipurpose Infrastructure for Network Applications) 是 Apache 组织一个较新的项目,它为开发高性能和高可用性的网络应用程序提供了非常便利的框架。当前发行的 MINA 版本支持基于 Java NIO 技术的 TCP/UDP 应用程序开发、串口通讯程序(只在最新的预览版中提供),MINA 所支持的功能也在进一步的扩展中。目前正在使用 MINA 的软件包括有:Apache Directory Project、AsyncWeb、AMQP(Advanced Message Queuing Protocol)、RED5 Server(Macromedia Flash Media RTMP)、ObjectRADIUS、Openfire 等等。

       MINA的几个重要接口:

IoServiece :这个接口在一个线程上负责套接字的建立,拥有自己的 Selector,监听是否有连接被建立。
IoProcessor :这个接口在另一个线程上负责检查是否有数据在通道上读写,也就是说它也拥有自己的 Selector,这是与我们使用 JAVA NIO 编码时的一个不同之处,通常在JAVA NIO 编码中,我们都是使用一个 Selector,也就是不区分 IoService与 IoProcessor 两个功能接口。另外,IoProcessor 负责调用注册在 IoService 上的过滤器,并在过滤器链之后调用 IoHandler。  
IoAccepter :相当于网络应用程序中的服务器端,它继承自IoServiece,并进行了扩展。
IoConnector :相当于客户端,它继承自IoServiece,并进行了扩展。
IoSession :当前客户端到服务器端的一个连接实例。
IoHandler :这个接口负责编写业务逻辑,也就是接收、发送数据的地方。这也是实际开发过程中需要用户自己编写的部分代码。
IoFilter :过滤器用于悬接通讯层接口与业务层接口,这个接口定义一组拦截器,这些拦截器可以包括日志输出、黑名单过滤、数据的编码(write 方向)与解码(read 方向)等功能,其中数据的 encode与 decode是最为重要的、也是你在使用 Mina时最主要关注的地方。

        MINA的基础架构图:

Apache MINA框架「建议收藏」

下面是使用Mina实现TCP的一个小例子:

TCPServer.java

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

import org.apache.mina.core.service.IoAcceptor;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.LineDelimiter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;

/**
 * @description:Mina 实现TcpServer
 * @date:(2015-11-22 下午3:46:23)
 * @author
 * @version v1.0
 * @since v1.0
 * 
 *        Modified history
 * 
 *        Modified date: Modifier user: description:
 * 
 * */
public class TcpServer{

	public static void main(String[] args) throws IOException {
		
		IoAcceptor acceptor=new NioSocketAcceptor();
		//设置缓冲区大小
		acceptor.getSessionConfig().setReadBufferSize(2048);
		//设置通道10秒内没有任何操作将处于空闲状态
		acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
		//使用字符串编码
		acceptor.getFilterChain().addLast("codec",
				new ProtocolCodecFilter(new TextLineCodecFactory(
						Charset.forName("UTF-8"), LineDelimiter.WINDOWS.getValue()
						,LineDelimiter.WINDOWS.getValue())));
		//设置业务处理逻辑
		acceptor.setHandler(new MyIOHandler());
		acceptor.bind(new InetSocketAddress(9123));
	
	}

}

MyIOHandler.java

import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;

/**
 * @description:主要是一些业务逻辑,如发送,接收消息
 * @date:(2015-11-24 上午9:37:02)
 * @author Administrator
 * @version v1.0
 * @since v1.0
 *
 * Modified history
 *
 *    Modified date:  
 *    Modifier user:     
 *    description: 
 *
 * */
public class MyIOHandler extends IoHandlerAdapter{
	
	/**
	 * 当有异常发生时触发
	 * */
	@Override
	public void exceptionCaught(IoSession session, Throwable cause)
			throws Exception {
		
		super.exceptionCaught(session, cause);
		session.close(true);
	}
	
	/**
	 * 有新连接是触发
	 * */
	@Override
	public void sessionOpened(IoSession iosession) throws Exception {
		
		 System.out.println("session open for " + iosession.getRemoteAddress());
	}
	
	/**
	 * 连接被关闭是触发
	 * */
	@Override
	public void sessionClosed(IoSession iosession) throws Exception {
		
		 System.out.println("session closed from " + iosession.getRemoteAddress());
	}
	
	/**
	 * 收到来自客户端的消息
	 */
	@Override
	public void messageReceived(IoSession iosession, Object message)
			throws Exception {
		
		String str=message.toString();
		System.out.println("The message received is [" + str + "]");
		if(str.endsWith("quit")){
			iosession.close(true);
		}
		
	}

}

启动服务,在dos窗口中telnet 127.0.0.1 9123

输入:Helllo,MINA.

控制台将输出:

session open for /127.0.0.1:55344
The message received is [hello MINA]

Mina实现TCP客户端:

MyCient.java

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

import org.apache.mina.core.service.IoConnector;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.LineDelimiter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.nio.NioSocketConnector;

/**
 * @description:MINA 实现TCP 客户端
 * @date:(2015-11-24 下午10:06:43)
 * @author Administrator
 * @version v1.0
 * @since v1.0
 *
 * Modified history
 *
 *    Modified date:  
 *    Modifier user:     
 *    description: 
 *
 * */
public class MyCient {
	
	public static void main(String[] args) {
		
		IoConnector connector=new NioSocketConnector();
		connector.setConnectTimeoutMillis(30000);
		connector.getFilterChain().addLast("codec", 
				new ProtocolCodecFilter(
						new TextLineCodecFactory(Charset.forName("UTF-8"),
						LineDelimiter.WINDOWS.getValue(),
						LineDelimiter.WINDOWS.getValue())));
		connector.setHandler(new ClientHandler("你好!\r\n 大家好!"));
		connector.connect(new InetSocketAddress("127.0.0.1", 9123));
		
	}

}

ClientHandler.java

import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;

/**
 * @description
 * @date:(2015-11-24 下午10:14:04)
 * @author Administrator
 * @version v1.0
 * @since v1.0
 *
 * Modified history
 *
 *    Modified date:  
 *    Modifier user:     
 *    description: 
 *
 * */
public class ClientHandler extends IoHandlerAdapter{
	
	private String values;
	
	public ClientHandler(String values){
		this.values=values;
	}
	
	@Override
	public void sessionOpened(IoSession session) throws Exception {
		session.write(values);
	}

}

运行TCPServer,java,MyClient.java

server端控制台输出:

session open for /127.0.0.1:56992
The message received is [你好!]
The message received is [ 大家好!]

参考文档:

http://www.ibm.com/developerworks/cn/opensource/os-cn-apmina/

http://www.cnblogs.com/xuekyo/archive/2013/03/06/2945826.html

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/127745.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • Kali Linux更新及配置更新源

    Kali Linux更新及配置更新源默认状态下查看更新源root@kali2019:~#cat/etc/apt/sources.list更改Kali的更新源root@kali2019:~#vim/etc/apt/sources.list若更新源不可用,在执行apt-getupdate之后如下所示:更改为中科大更新源执行获取更新命令执行安装更新命令apt-getupdradekali官方源以…

  • curl调用单笔接口结合shell循环实现批量操作

    curl调用单笔接口结合shell循环实现批量操作shell脚本相关获取年月日时分秒来设置请求的时间echo$(date+%Y%m%d%H%M%S)请求中的随机数生成,根据请求报文格式得知

  • 数据结构:数组和链表的区别(数组和链表的优缺点 & 数组和链表的适用场景)

    数据结构:数组和链表的区别(数组和链表的优缺点 & 数组和链表的适用场景)数组和链表是两种基本的数据结构,他们在内存存储上的表现不一样,所以也有各自的特点数组一、数组的特点1.在内存中,数组是一块连续的区域2.数组需要预留空间在使用前需要提前申请所占内存的大小,这样不知道需要多大的空间,就预先申请可能会浪费内存空间,即数组空间利用率低ps:数组的空间在编译阶段就需要进行确定,所以需要提前给出数组空…

  • 谷歌地图 离线地图_地图谷歌高清手机版

    谷歌地图 离线地图_地图谷歌高清手机版离线地图解决方案,除了买地图数据,使用专业的ArcGIS来做外,也可以使用GMap.Net来做。关于GMap的开发教程,可以看我以前的文章:基于GMap.Net的地图解决方案使用了GMap一年了,也有了一些积累,开发了一个可以下载ArcGIS、百度、谷歌、高德、腾讯SOSO、天地图、Here等地图的地图下载器。百度和google地图加载显示如下:百度普通地图:百度混合地图:…

  • 深信服SCSA安全认证工程师

    深信服SCSA安全认证工程师深信服SCSA安全认证工程师考试实验环境在线学习课程讲师在线学习视频(SCSI)学员在线学习视频(SCSA)在线题库考试考试入口试卷自动批阅错题集记录联系方式微信联系18849911

  • 特殊字符乱码问题

    特殊字符乱码问题1、使用标签建议用(标签可以控制转换特殊字符):<html:textproperty=“instruction”readonly=“true”styleClass=“mylongreadonly”size=“32”/><inputname=“instruction”type=“hidden”value=”<mycim2:writename=“objec…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号