`
qianhao_1987
  • 浏览: 20229 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类
最新评论

Apache Mina简单实例

阅读更多
一.简介
MINA是一个网络应用框架,也可被称之为NIO框架库、客户端/服务器框架库、网络套接字 (socket)库,可以帮助用户开发高性能和高可扩展性的网络应用程序,支持(TCP/IP、UDP/IP协议)等。

二.工作流程
MINA处于中间层,它不关心数据是如何在底层网络进行传输,只负责接受底层数据,将数据通过过滤器过滤并装换成JAVA对象,供应用程序使用,然后在应用程序对数据做过业务处理之后,将响应值过滤且转换成底层能识别的二进制数据,提供给底层传输。总之,MINA是底层数据和应用程序交互的接口。
第一步,创建服务对象(服务端、客户端)  ----IoService接口实现
第二步,数据过滤(编解码器)           ----IoFilter接口实现
第三步,业务处理                       ----IoHandler接口实现

IoFilter是MINA的精髓,可以进行日志记录,信息过滤,编解码等操作,把数据接收发送从业务层独立出来。
IoService对NIO进行了封装,提供简介接口,来创建服务对象。
IoHandler是我们最关心的部分,负责对接收/发送数据做了业务逻辑处理

三.服务端实例
private static Logger logger = Logger.getLogger(Demo1Server.class);
	private static final int PORT = 3005;

	public static void main(String[] args) {
		IoAcceptor acceptor = new NioSocketAcceptor();
		acceptor.addListener(new ServerListener());
		acceptor.getFilterChain().addLast(
				"codec",
				new ProtocolCodecFilter(new MyTextLineCodecFactory()));
		// 设置读取数据的缓冲区大小
		acceptor.getSessionConfig().setReadBufferSize(2048);
		// 读写通道10秒内无操作进入空闲状态
		acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
		// 绑定逻辑处理起器
		acceptor.setHandler(new Demo1ServerHandler());
		// 绑定端口
		try {
			acceptor.bind(new InetSocketAddress(PORT));
			logger.info("服务器启动成功。。。。端口为:" + PORT);
		} catch (IOException e) {
			logger.error("服务器启动异常。。。。", e);
			e.printStackTrace();
		}
	}


四.客户端实例
private Logger logger = Logger.getLogger(Demo2Client.class);
	private static final String HOST = "127.0.0.1";
	private static final int PORT = 3005;

	public static void main(String[] args) {
		// 创建一个非阻塞的客户端程序
		IoConnector connector = new NioSocketConnector();
		// 设置连接超时时间 单位毫秒
		connector.setConnectTimeout(30000);
		// 添加过滤器
		connector.getFilterChain().addLast(
				"codec",
				new ProtocolCodecFilter(new MyTextLineCodecFactory()));
		// 添加业务逻辑处理类
		connector.setHandler(new Demo2ClientHandler());
		// 创建连接
		IoSession session = null;
		try {
			ConnectFuture connect = connector.connect(new InetSocketAddress(
					HOST, PORT));
			// 等待连接创建完成
			connect.awaitUninterruptibly();
			// 获取session
			session = connect.getSession();
			session.write("我爱你,mina!!!!");
		} catch (Exception e) {
			System.out.println("客户端连接异常");
		}
		session.getCloseFuture().awaitUninterruptibly();
		connector.dispose();
	}


五.编解码器实例

5.1 编码器
private Logger logger = Logger.getLogger(MyTextLineCodecEncoder.class);
	//字符编码类型
	private Charset charset = Charset.forName("UTF-8");
	@Override
	public void dispose(IoSession arg0) throws Exception {
		
	}

	@Override
	public void encode(IoSession arg0, Object obj, ProtocolEncoderOutput out)
			throws Exception {
		logger.info("开始编码...........");
		IoBuffer io = IoBuffer.allocate(100).setAutoExpand(true);
		CharsetEncoder ce = charset.newEncoder();
		io.putString(obj.toString(), ce);
		io.put((byte)'\r');
		io.put((byte)'\n');
		io.flip();
		out.write(io);
	}

5.2 解码器
private Logger logger = Logger.getLogger(MyTextLineCodecDecoder.class);
	//字符编码类型
	private Charset charset = Charset.forName("UTF-8");
	//设置数据存放的IoBuffer大小
	private IoBuffer ioBuffer = IoBuffer.allocate(1024).setAutoExpand(true);
	@Override
	public void decode(IoSession session, IoBuffer in, ProtocolDecoderOutput out)
			throws Exception {
		logger.info("开始解码...........");
		while(in.hasRemaining()){
			byte by = in.get();
			//将数据存放到IoBuffer中
			ioBuffer.put(by);
			//数据解码结束标记
			if(by == '\n'){
				ioBuffer.flip();
				byte[] b = new byte[ioBuffer.limit()];
				ioBuffer.get(b);
				String msg = new String(b,charset);
				//重置ioBuffer
				ioBuffer = IoBuffer.allocate(100).setAutoExpand(true);
				out.write(msg);
			}
		}
	}
分享到:
评论

相关推荐

    apache mina实例免费下载

    apache mina实例免费下载,有很多实例代码简单易懂欢迎大家下载!

    Apache MINA java UDP例子|byte数组

    最近做rfid读写,C#和java都用udp不用厂家的动态库,udp自己写也简单,但是试了一下Apache mina ,接收的不是string,二十byte[] 数组,简单实现了UDP,网上也有例子,但是不是我要的。可用。

    apache mina 框架实例

    apache mina 框架 实例 自定义协议包 自定义编码器 解码器 服务端 客户端

    Apache mina2学习笔记DEMO

    这个是我学的apache mina2.0学习笔记的实例

    Apache Mina2服务器和客户端简单实例

    至于MINA2是什么,这里就不介绍了,有兴趣的可以自己去问一下度娘!

    apache-mina例子

    mina例子,服务端和客户端,MinaTimeServer是启动服务端,然后运行MinaClient就能看到结果了

    apache mina socket实例

    mina简单示例,Apache Mina Server 是一个网络通信应用框架,也就是说,它主要是对基于TCP/IP、UDP/IP协议栈的通信框架(当然,也可以提供JAVA 对象的序列化服务、虚拟机管道通信服务等),Mina 可以帮助我们快速...

    ApacheMina典型例子分析参考.pdf

    ApacheMina典型例子分析参考.pdf

    apache mina

    Mina 2.0.16 简介 代码实例 Mina 是Apache开发的一个开源的网络通信框架,基于java NIO实现。 建立server与client之间的会话连接,对会话消息进行过滤; 非阻塞消息会话机制; 通过自定义的通信协议进行编解码消息。

    基于Apache Mina实现的TCP长连接和短连接实例

    基于Apache Mina实现的TCP长连接和短连接实例 详细说明,可参见blog http://blog.csdn.net/peterwanghao/article/details/6900523

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

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

    ApacheMINA传递对象实例[借鉴].pdf

    ApacheMINA传递对象实例[借鉴].pdf

    Apache +mina使用介绍(包含API介绍)

    基于java NIO技术的TCP/UDP应用程序开发,串口通讯开发。 内部包含实例应用,有利于新手上手!

    Mina开发实例(服务端、客户端)DEMO

    Apache Mina Server 是一个网络通信应用框架,本项目是Mina开发的 服务端、客户端,例子,maven构建

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

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

    一个Apache MINA使用案例源代码

    摘要:Java源码,网络相关,Apache 一个Apache MINA使用案例源代码,消息接收的例子,显示接收到的消息,通过这个例子你可以学习一下会话创建、打开会话,与sessionCreated最大的区别是它是从另一个线程处调用的、会话...

    mina权威性能测试例子

    apache mina性能测试实例 四台客户端机器,服务器能跑到1w。mina的jar包自己去下,我上传的其他资源里也有。

    mina入门实例

    mina 基础的入门实例,使用maven+jdk1.7进行构建,使用客户端直接可以进行测试

Global site tag (gtag.js) - Google Analytics