赞
踩
1. 功能说明
直接上干货,废话不多!暂存队列小工具基于开源代码BigQueue封装,以达到数据被吃掉的目的,即咱们常说的生产消费模式。
优点:身轻如燕,依赖者少(仅依赖log4j和fastjson,看pom.xml文件即可知晓),上手容易,使用快捷,不用服务依赖,JAR包工具库直接使用。
缺点:没有amq、kafka、redis庞大,也没有它们有名,不能跨程序,仅在本项目内部使用。
2. 使用示例:
2.1. 生产数据示例:
2.2. 消费数据示例:
2.3. 小结
开发者在put数据的时候,声明了队列名称【全局唯一标识身份】,哪个实现类去处理数据,数据对象三个参数即可。在具体处理实现类的onData方法写自己的逻辑就可以了。
3. 使用工具方法讲解
3.1. 工具类说明
上图是笔者用暂存队列组件V1.0版本的封装,1.0版本不支持随时修改队列的处理线程数量,所以在2.0版本增加了这个功能,并且对组件JAVA类文件的命名重新规划了一下。好东西要分享,希望能帮到需要的人。
队列的出队速度取决于开发者自己业务里的onData方法效率,onData越高效,出队速度越快。至于开发者想要在onData里是做消息分发,或是数据入库或是http中转就悉听尊便了。
4. 源码说明
4.1. 包路径结构如下图所示:
全部源代码及文档已经上传,大家可搜索下载共同研究!!!
下载地址:https://download.csdn.net/download/lovexuan0609/12160501
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。