当前位置:   article > 正文

JAVA小工具——持久暂存队列【V2.0】_bigqueue

bigqueue

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

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/数据科学创新者/article/detail/62168
推荐阅读
相关标签
  

闽ICP备14008679号