- 浏览: 950417 次
文章分类
- 全部博客 (428)
- Hadoop (2)
- HBase (1)
- ELK (1)
- ActiveMQ (13)
- Kafka (5)
- Redis (14)
- Dubbo (1)
- Memcached (5)
- Netty (56)
- Mina (34)
- NIO (51)
- JUC (53)
- Spring (13)
- Mybatis (17)
- MySQL (21)
- JDBC (12)
- C3P0 (5)
- Tomcat (13)
- SLF4J-log4j (9)
- P6Spy (4)
- Quartz (12)
- Zabbix (7)
- JAVA (9)
- Linux (15)
- HTML (9)
- Lucene (0)
- JS (2)
- WebService (1)
- Maven (4)
- Oracle&MSSQL (14)
- iText (11)
- Development Tools (8)
- UTILS (4)
- LIFE (8)
最新评论
-
Donald_Draper:
Donald_Draper 写道刘落落cici 写道能给我发一 ...
DatagramChannelImpl 解析三(多播) -
Donald_Draper:
刘落落cici 写道能给我发一份这个类的源码吗Datagram ...
DatagramChannelImpl 解析三(多播) -
lyfyouyun:
请问楼主,执行消息发送的时候,报错:Transport sch ...
ActiveMQ连接工厂、连接详解 -
ezlhq:
关于 PollArrayWrapper 状态含义猜测:参考 S ...
WindowsSelectorImpl解析一(FdMap,PollArrayWrapper) -
flyfeifei66:
打算使用xmemcache作为memcache的客户端,由于x ...
Memcached分布式客户端(Xmemcached)
Mina 协议编解码过滤器一(协议编解码工厂、协议编码器):
http://donald-draper.iteye.com/blog/2376663
Mina 协议编解码过滤器二(协议解码器):
http://donald-draper.iteye.com/blog/2376679
前面这两篇文章中,都涉及到Queue,我们今天就来看一Queue是如何工作的。
从上来看队列Queue实际上为List,用一个对象数组items存放元素,一个实际容量计数器size,一个队头first和一个队尾索引last,默认队列容量为4。
/
来看ensureCapacity
再来看出队列
再来看其他操作:
总结:
队列Queue实际上为List,用一个对象数组items存放元素,一个实际容量计数器size,一个队头first和一个队尾索引last,默认队列容量为4。push元素时,先判断队列是否已满,如果已满,则扩容队列为原来的两倍。Queue实际为具有队列特性的List。Queue可以随机地访问队列索引。
http://donald-draper.iteye.com/blog/2376663
Mina 协议编解码过滤器二(协议解码器):
http://donald-draper.iteye.com/blog/2376679
前面这两篇文章中,都涉及到Queue,我们今天就来看一Queue是如何工作的。
/** * A unbounded circular queue. * * @author The Apache Directory Project (mina-dev@directory.apache.org) * @version $Rev$, $Date$ */ public class Queue extends AbstractList implements List, Serializable { private static final int DEFAULT_CAPACITY = 4;//默认容量 private static final int DEFAULT_MASK = DEFAULT_CAPACITY - 1;//默认掩码 private Object[] items;//存放队列元素数组 private int mask; private int first = 0;//队头 private int last = 0;//队尾 private int size = 0;//队列实际容量 /** * Construct a new, empty queue. 构造空队列 */ public Queue() { items = new Object[DEFAULT_CAPACITY]; mask = DEFAULT_MASK; } }
从上来看队列Queue实际上为List,用一个对象数组items存放元素,一个实际容量计数器size,一个队头first和一个队尾索引last,默认队列容量为4。
/
** * Enqueue into this queue.添加元素到队列 */ public void push(Object item) { if (item == null) { throw new NullPointerException("item"); } ensureCapacity();//确保队列可以存放元素 items[last] = item;//存放元素 increaseSize();//更新实际容量size,及队尾索引 }
来看ensureCapacity
private void ensureCapacity() { //如果队列未满,直接返回 if (size < items.length) { return; } // expand queue,否则扩容,为原来的两倍 final int oldLen = items.length; Object[] tmp = new Object[oldLen * 2]; //拷贝原始队列数据到新队列 if (first < last) { System.arraycopy(items, first, tmp, 0, last - first); } else { System.arraycopy(items, first, tmp, 0, oldLen - first); System.arraycopy(items, 0, tmp, oldLen - first, last); } first = 0; last = oldLen; items = tmp; mask = tmp.length - 1; } //更新队尾,及size private void increaseSize() { last = (last + 1) & mask; size++; }
再来看出队列
/** * Dequeues from this queue. * * @return <code>null</code>, if this queue is empty or the element is * really <code>null</code>. */ public Object pop() { if (size == 0) { return null; } //返回队头元素,置空原始队头 Object ret = items[first]; items[first] = null; decreaseSize();//更新size,及队头索引 return ret; } private void decreaseSize() { first = (first + 1) & mask; size--; }
再来看其他操作:
/** * Returns the capacity of this queue.返回队列容量 */ public int capacity() { return items.length; } /** * Clears this queue.清空队列 */ public void clear() { Arrays.fill(items, null); first = 0; last = 0; size = 0; } /** * Returns the first element of the queue. * 返回队头元素 * @return <code>null</code>, if the queue is empty, or the element is * really <code>null</code>. */ public Object first() { if (size == 0) { return null; } return items[first]; } /** * Returns the last element of the queue. * 获取队尾元素 * @return <code>null</code>, if the queue is empty, or the element is * really <code>null</code>. */ public Object last() { if (size == 0) { return null; } return items[(last + items.length - 1) & mask]; } /** * Returns <code>true</code> if the queue is empty.是否为空 */ public boolean isEmpty() { return (size == 0); } /** * Returns the number of elements in the queue. 获取队列元素个数 */ public int size() { return size; } //获取索引对应的队列元素 public Object get(int idx) { checkIndex(idx);//检查索引 return items[getRealIndex(idx)]; } //检查索引 private void checkIndex(int idx) { if (idx < 0 || idx >= size) { throw new IndexOutOfBoundsException(String.valueOf(idx)); } } //获取实际队列索引 private int getRealIndex(int idx) { return (first + idx) & mask; } ////////////////////////////////////////// // java.util.List compatibility methods // ////////////////////////////////////////// //添加元素到队列 public boolean add(Object o) { push(o); return true; } //更新索引对应的元素 public Object set(int idx, Object o) { checkIndex(idx); int realIdx = getRealIndex(idx); Object old = items[realIdx]; items[realIdx] = o; return old; } //添加元素到指定索引 public void add(int idx, Object o) { //如果为队列,直接添加 if (idx == size) { push(o); return; } //检查索引,确保容量可用 checkIndex(idx); ensureCapacity(); //获取实际索引 int realIdx = getRealIndex(idx); // Make a room for a new element. //下面这个操作,比较耗时,将realIdx索引对应的前后元素重新移动队列中,把索引 //对应的位置腾出 if (first < last) { System .arraycopy(items, realIdx, items, realIdx + 1, last - realIdx); } else { if (realIdx >= first) { System.arraycopy(items, 0, items, 1, last); items[0] = items[items.length - 1]; System.arraycopy(items, realIdx, items, realIdx + 1, items.length - realIdx - 1); } else { System.arraycopy(items, realIdx, items, realIdx + 1, last - realIdx); } } items[realIdx] = o; increaseSize();//更新size,及队尾last } //移除指定索引对应的元素 public Object remove(int idx) { if (idx == 0) { return pop(); } checkIndex(idx); int realIdx = getRealIndex(idx); Object removed = items[realIdx]; // Remove a room for the removed element. //下面这个操作,比较耗时,将realIdx索引对应的前后元素重新移动队列中,把索引 //对应的位置清空,即占有掉 if (first < last) { System.arraycopy(items, first, items, first + 1, realIdx - first); } else { if (realIdx >= first) { System.arraycopy(items, first, items, first + 1, realIdx - first); } else { System.arraycopy(items, 0, items, 1, realIdx); items[0] = items[items.length - 1]; System.arraycopy(items, first, items, first + 1, items.length - first - 1); } } items[first] = null; decreaseSize();//更新size,及队头last return removed; } /////////////////////////////////////////// // java.util.Queue compatibility methods // /////////////////////////////////////////// //添加元素 public boolean offer(Object o) { push(o); return true; } //获取队头元素 public Object poll() { return pop(); } //移除队头元素 public Object remove() { if (size == 0) { throw new NoSuchElementException(); } return pop(); } //查看队列是否有元素 public Object peek() { return first(); } //返回队列元素 public Object element() { if (size == 0) { throw new NoSuchElementException(); } return first(); }
总结:
队列Queue实际上为List,用一个对象数组items存放元素,一个实际容量计数器size,一个队头first和一个队尾索引last,默认队列容量为4。push元素时,先判断队列是否已满,如果已满,则扩容队列为原来的两倍。Queue实际为具有队列特性的List。Queue可以随机地访问队列索引。
发表评论
-
Mina 报文连接器(NioDatagramConnector)
2017-06-14 08:46 1339Mina 抽象Polling连接器(A ... -
Mina 报文监听器NioDatagramAcceptor二(发送会话消息等)
2017-06-13 16:01 1488Mina 报文监听器NioDatagramAcceptor一( ... -
Mina 报文监听器NioDatagramAcceptor一(初始化,Io处理器)
2017-06-13 09:51 2501Mina Io监听器接口定义及抽象实现:http://dona ... -
Mina 报文通信简单示例
2017-06-12 09:01 2483MINA TCP简单通信实例:http://donald-dr ... -
Mina socket连接器(NioSocketConnector)
2017-06-12 08:37 4640Mina 抽象Polling连接器(AbstractPolli ... -
Mina 抽象Polling连接器(AbstractPollingIoConnector)
2017-06-11 21:29 960Mina 连接器接口定义及抽象实现(IoConnector ) ... -
Mina 连接器接口定义及抽象实现(IoConnector )
2017-06-11 13:46 1770Mina IoService接口定义及抽象实现:http:// ... -
Mina socket监听器(NioSocketAcceptor)
2017-06-09 08:44 3336Mina IoService接口定义及抽象实现:http:// ... -
Mina 抽象polling监听器
2017-06-08 22:32 708Mina Io监听器接口定义及抽象实现:http://dona ... -
Mina Io监听器接口定义及抽象实现
2017-06-07 13:02 1295Mina IoService接口定义及抽象实现:http:// ... -
Mina IoService接口定义及抽象实现
2017-06-06 23:44 1125Mina IoHandler接口定义:http://donal ... -
Mina Nio会话(Socket,DataGram)
2017-06-06 12:53 1144Mina Socket会话配置:http://donald-d ... -
Mina 抽象Io会话
2017-06-05 22:45 967Mina Io会话接口定义:http://donald-dra ... -
Mina Io会话接口定义
2017-06-04 23:15 1094Mina Nio处理器:http://donald-drape ... -
Mina Nio处理器
2017-06-04 22:19 692Mina Io处理器抽象实现:http://donald-dr ... -
Mina Io处理器抽象实现
2017-06-03 23:52 1082Mina 过滤链抽象实现:http://donald-drap ... -
Mina IoHandler接口定义
2017-06-01 21:30 1669Mina 过滤链抽象实现:http://donald-drap ... -
MINA 多路复用协议编解码器工厂二(多路复用协议解码器)
2017-06-01 12:52 2193MINA 多路复用协议编解码器工厂一(多路复用协议编码器): ... -
MINA 多路复用协议编解码器工厂一(多路复用协议编码器)
2017-05-31 22:22 1790MINA 多路分离解码器实例:http://donald-dr ... -
Mina 累计协议解码器
2017-05-31 00:09 1155MINA 编解码器实例:http://donald-drape ...
相关推荐
队列,mina通信的结合实例,4种队列实例,已经mina通讯模块的研究使用
mina连接,mina心跳连接,mina断线重连。其中客户端可直接用在android上。根据各方参考资料,经过自己的理解弄出来的。CSDN的资源分太难得了。
mina-core-2.0.0-M6.jar mina-example-2.0.0-M6.jar mina-filter-codec-netty-2.0.0-M6.jar mina-filter-compression-2.0.0-M6.jar mina-integration-beans-2.0.0-M6.jar mina-integration-jmx-2.0.0-M6.jar mina-...
mina的使用初步入门mina的使用初步入门mina的使用初步入门
里面包含mina2.0的api(英文)和mina自学手册,还有mina的开发指导
mina的高级使用,mina文件图片传送,
Apache MINA是 Apache 组织一个较新的项目,它为开发高性能和高可用性的网络应用程序提供了非常便利的框架。 当前发行的 MINA 版本支持基于 Java NIO 技术的 TCP/UDP 应用程序开发、串口通讯程序(只在最新的预览版...
Apache Mina Server 2.0中文参考手册V1.0,Apache Mina2.0学习笔记(修订版)Apache Mina Server 2.0中文参考手册V1.0,Apache Mina2.0学习笔记(修订版)
深入理解Apache_Mina_(1)----_Mina的几个类 深入理解Apache_Mina_(2)----_与IoFilter相关的几个类 深入理解Apache_Mina_(3)----_与IoHandler相关的几个类 深入理解Apache_Mina_(4)----_IoFilter和IoHandler的区别和...
mina内部源码,可以深入的研究下,重构修改后获得的效率更加突出
mina.jar 包,内涵mina所需的所有jar包, 解压即可,测试可用。mina.jar 包,内涵mina所需的所有jar包, 解压即可,测试可用。
项目包含有mina的服务端与客户端,客户端发送心跳包,服务端响应心跳包
mina客户端,服务器端的demo
mina运行最基本的demo,实现客户端输入数据的返回。其中还包含mina的jar包
1.mina socket客户度工程相关类,添加mina jar包后可独立运行。 2.mina若有空闲连接则使用已有连接,若无则新建mina连接; 3.mina空闲连接超过保活时间25分钟后,自动删除; 4.mina发送指令后,接收指定时长内收到的...
mina新手案例,mina新手教程源码 mina+springboot最简单的案例。用的IDEA * mina服务端 * 1、添加@Controller注解和 @PostConstruct注解,代表启动springboot项目时也调用该类下的该方法, * 启动springboot项目...
许多刚接触mina的朋友,对于mina的编解码器的编写很迷惑.希望这个文档可以帮助朋友们少走弯路。 资源中是一个比较典型的编解码器写法。生成了可执行文件。并对编解码器的代码有详细注释。
mina mina传输对象的示例 mina框架 mina示例
MINA 2.0 User Guide Part I - Basics Chapter 1 - Getting Started Chapter 2 - Basics Chapter 3 - Service Chapter 4 - Session Chapter 5 - Filters Chapter 6 - Transports Chapter 7 - Handler Part II - ...
mina源码