- 浏览: 550143 次
- 性别:
- 来自: 深圳
文章分类
最新评论
-
hdblocal_:
为什么messageReceived之后,再encode,有点 ...
MINA框架使用总结 -
andey007518:
MINA框架使用总结 -
ymm8505:
我自己的理解 CopyOnWriteArrayList 这个 ...
ArrayList遍历的同时删除 -
spring_springmvc:
可以参考最新的文档:如何在eclipse jee中检出项目并转 ...
Eclipse快捷键-方便查找 -
netwelfare:
文章讲解的不够详细,ArrayList在遍历的同时如果去删除或 ...
ArrayList遍历的同时删除
参考:http://xinsync.xju.edu.cn/index.php/archives/category/prglang/java/mina
简单介绍:MINA框架是对java的NIO包的一个封装,简化了NIO程序开发的难度,封装了很多底层的细节,然开发者把精力集中到业务逻辑上来,最近做了一个相关的项目,为了备忘对MINA做一个总结。
下面这个start方法用来初始化MINA:
private void start(int port, WebContext ctx) throws IOException, InstantiationException , IllegalAccessException, ClassNotFoundException { //初始化Acceptor NioSocketAcceptor acceptor = new NioSocketAcceptor(5); java.util.concurrent.Executor threadPool = Executors.newFixedThreadPool(1500);//建立线程池 //加入过滤器(Filter)到Acceptor acceptor.getFilterChain().addLast("exector", new ExecutorFilter(threadPool)); acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new WebDecoder(),new WebEncoder())); 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);//设置每一个非主监听连接的端口可以重用 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 WebHandler()); acceptor.bind(); }
NioSocketAcceptor是MINA的适配器,一切都是从这里开始的。MINA中有个过滤器和处理器的概念,过滤器用来过滤数据,处理器用来处理数据。具体来说MINA的处理模型就是request->过滤器A->过滤器B->处理器->过滤器B->过滤器A->response,这里的request和response类似serlvet的request和response。
acceptor.getFilterChain().addLast("exector", new ExecutorFilter(threadPool)); //加入一个线程池到适配器,这里用的是jdk自带的线程池
acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new WebDecoder(),new WebEncoder())); //这里是处理逻辑的关键部位,请求的处理都是在WebDecoder类和WebEncoder类中处理,可以明显从命名上看出来一个是用来解码,另一个是用来编码,requet过来后先进入WebDecoder类(实现了ProtocolDecoder接口)进行解码处理,这里可以加入自己的逻辑把传进来的流解码成自己需要的信息。而WebEncoder类(实现了ProtocolEncoder接口)是进行编码,在这个类里面加入自己的逻辑把处理后的信息组装发送给客户端(response)。而在解码和编码过程中WebHandler(扩展了IoHandlerAdapter抽象类)起到了处理器的作用。 //request->WebDecoder->WebHandler->WebEncode->response
现在详细描述一下request->WebDecoder->WebHandler->WebEncode->response的过程:
客户端发送一个请求到MINA服务器,这里相当于来了一个requet。请求首先来到
WebDecoder类(实现了ProtocolDecoder接口)中的 boolean decode(IoSession session, IoBuffer in, ProtocolDecoderOutput out) throws Exception{}方法 /* 参数in:用户请求信息全存在这里,读数据就从in这里读。 参数out:用来输出处理后的数据到Filter的下一个过滤器,如果没有过滤器了就输出到WebHandler,这里有点和 servelt的过滤器类似。利用out.write(Object object);这个函数可以把数据传到下一个Filter。我们可以自己定义 一个对象,我们假设为Request,用它来传递消息,那末这里就可以写成out.write(new RequsetMessage()); 如果这个方法返回false,就是说当前逻辑包还没接收完(也就是当前的IoBuffer并没有包含足够的数据),需要再次 执行decode方法(再次获取新的IoBuffer),用来获取足够的数据。如果返回值为true就表示可以不执行decode方 法了,但是要激活handler方法,必须要调用out.write方法。 public class RequestMessage{}//这里什么也不做 */
然后到
WebHandler(扩展了IoHandlerAdapter抽象类)中的 void messageReceived(IoSession session, Object message) throws Exception{}方法 WriteFuture future = session.write(response);//session中必须加入这个代码,才会激活encode方法 future.addListener(IoFutureListener.CLOSE);//这个的作用是发送完毕后关闭连接,加了就是短连接,不然是长连接 IoFutureListener里面有个operationComplete(IoFuture future)方法,当流发送完成之后才调用这个方法。 /* 参数message:用来获取Filter传递过来的对象.对应代码RequestMessage request = (RequestMessage) message; 参数session:用来发送数据到Filter.对应代码session.write(new ResponseMessage()); public class ResponseMessage{}//这里什么也不做,假设存放处理后的数据 注意:对于一个MINA程序而言,对于WebHandler类只生成一个对象,所以要考虑线程安全问题 */
然后到
WebEncoder类(实现了ProtocolEncoder接口)中的 boolean encode(IoSession session, Object message, ProtocolEncoderOutput out) throws Exception{} 方法 /* 参数message:用来获取上一个Filter节点的数据或者处理器的数据(如果这个过滤器为最靠近处理器的那个) ResponseMessage response = (ResponseMessage)message; 参数out:用来输出数据到下一个Filter节点过或者到客户端,用out.write(Object encodedMessage)把数据发送 出去,但是要注意的是,如果这个Filter下一个节点如果是客户端的话,那个这个encodedMessage数据必须为 IoBuffer类型的,可以利用IoBuffer.wrap(byte[] byteArray)这个方法来格式化输出数据 */
- NIO_TEST.rar (13.9 KB)
- 描述: 阻塞和非阻塞io的简单通信程序,自己写的(写的不好)放这里做个备份
- 下载次数: 1486
评论
6 楼
hdblocal_
2018-08-04
为什么messageReceived之后,再encode,有点没看懂这种操作...
5 楼
andey007518
2018-04-01
4 楼
coolhorse168
2015-02-28
多谢分享,
3 楼
alaa90
2013-03-26
收下了
2 楼
hotsmile
2012-11-16
mark 一下!!!!!!!!!!!!!
1 楼
chengen168
2012-05-27
MARK写的不错~~
发表评论
-
为何在使用CMS gc算法时会出现连续两次full gc
2011-09-01 11:04 4920现象: jstat -gcutil pid 1000观察到 ... -
配置filter拦截forward之类的内部转发
2011-02-18 17:19 5959在servlet-2.3中,Filter会过滤一切请求,包括服 ... -
request.getRequestURI 与request.getServletPath() 区别
2011-02-16 19:38 7815路径:resin/webapps/my_proj/test/r ... -
ConcurrentHashMap中的remove方法的bug
2010-04-30 11:48 5775最近研究了一下 ConcurrentHashMap中源码发现j ... -
搭建Android开发环境
2010-04-05 23:22 1512在eclipse上安装Android 1.安装eclipse ... -
IoServer源代码阅读笔记
2009-08-23 21:57 2114NIO:写事件要尽量早的被注销. 1,IOServer用一 ... -
一个webapp目录下部署多个web应用
2009-08-21 10:34 2122在同一个resin下的webapp目录部署多个web应用,发现 ... -
java 的深度克隆
2009-07-01 20:07 1743只有实现了cloneable接口才算是真正的深度克隆. 在复 ... -
try finally return
2009-03-20 19:21 1212class Entry { ... -
String和==号的问题
2009-03-09 19:45 1198String name = "you" ... -
Bit数组
2009-01-20 18:56 2856public class BitArray{//用byte数组 ... -
关于Java占用内存的研究 (转载请注明作者zms)
2009-01-20 15:28 2935版权声明:转载时请以 ... -
几种通讯协议的比较
2009-01-20 15:26 5318一、综述 本文比较了RMI ... -
java基础知识总结
2009-01-06 00:50 2808http://wiki.caucho.com/Hessian_ ... -
Java基础-关于session的详细解释
2008-12-01 23:49 1312一、术语session 在我的经验里,session这个词 ... -
关于大量缓存对象回收的思考
2008-12-01 15:34 2635前几天面试,被问到了一个问题,如果当前有数亿条记录,但是缓存最 ... -
java 快速排序demo
2008-11-29 19:52 2017快速排序算法思想如下,先选取一个元素作为基准,然后根据这个基准 ... -
java 实现简单的文件拷贝
2008-11-26 17:36 6238昨天面试,面试官要我在黑板上写个java文件复制的代码,但是一 ... -
HashMap的遍历效率讨论
2008-11-26 11:31 3659经常遇到对HashMap中的key和value值对的遍历操作 ... -
Java ArrayList 实现
2008-11-25 23:02 3720ArrayList是List接口的一个可变长数组实现。实现了 ...
相关推荐
nio的经典框架mina 在此基础上发展的netty是nio经典之中的经典
java mina框架使用总结
服务器框架MINA使用经验总结 socket协议通信框架
niosocket及其开源框架MINA学习总结收集.pdf
mina 通信框架应用,简单的入门,客户端和服务端的结构总结
mina是一个基于java nio的网络通信框架。主要屏蔽了网络通信的一些细节,对Socket进行封装,并且是NIO的一个实现架构,可以帮助我们快速的开发网络通信,常用于游戏的开发、中间件服务端的程序中。 Apache的Mina...
《Netty 权威指南(第2 版)》适合架构师、设计师、软件开发工程师、测试人员以及其他对Java NIO 框架、Netty 感兴趣的相关人士阅读,通过《Netty 权威指南(第2 版)》的学习,读者不仅能够掌握Netty 基础功能的...
《Netty 权威指南(第2 版)》适合架构师、设计师、软件开发工程师、测试人员以及其他对Java NIO 框架、Netty 感兴趣的相关人士阅读,通过《Netty 权威指南(第2 版)》的学习,读者不仅能够掌握Netty 基础功能的...
系统的基本环境是以MINAWeb发框架,同时使用微信开发者工具开发了微信applet户端,采用Postman为服务器界面的测试工具,使用SQLYog接数据库作为MySQL可视化管理工具 正常的文字识别一般将文档页作为识别目标,其...
4、网络通信采用MINA2.0,为整个项目省去socket和多线程的麻烦,好的框架才使得整个项目增添了如此之多的功能; 5、本人与朋友已经为消灭Bug做出了很多努力,但仍然不乏一些尚未实现或存在bug的功能,有不合理的...
1. 开篇导言 本节目标:对于入门篇的总结 目标用户:无编程经验,但对微信小程序感兴趣的同学。... -> MINA框架的目录结构,文件后缀及其定位。 了解,并习惯使用->调试工具:Wxml、Console、Sources
预览链接技术栈小程序MINA框架: 一个响应的数据绑定框架。分为两块视图层(View)和逻辑层(App Service)Flex:flex弹性布局Express : http服务框架websocket: 前后端消息的实时推送mongoose: 操作mongodb数据库pm2: ...