Java消息发布插件
2016-04-23 00:00
232 查看
摘要: 本文对信息发布的功能进行了梳理,将信息发布功能进行抽象,使用队列和定时任务实现异步触发,支持信息的延迟和非延迟发布
介绍
日常的程序开发中,或多或少会遇到信息发布等功能,在指定操作结束后,发送信息给第三方,而Java是同步的,调用发送方法,要等返回结果之后才能继续执行后面的代码,特别是执行的发送方法较多时,会影响此操作的主方法响应。基于此种情况,本文对信息发布功能进行了简单的抽象集成,以阻塞队列和定时任务的方式,实现消息的异步发送,使用者只需要实现接口接口需要的相关方法,即可完成消息发布功能的快速开发,旨在为开发人员减少必要的工作量。此为最初版本,后续会继续扩展,各位童鞋有好的想法也可以与楼主联系,群策群力。下面放出git地址。
插件依赖
集成步骤
1.导入jar包:carpo-infopubs-1.0 下载地址:carpo-infopubs-1.0.jar git地址:http://git.oschina.net/carpo/Carpo.InfoPubs
2.将carpo-info-pubs.xml加入到spring启动项中 在web.xml中,contextConfigLocation中加入carpo-info-pubs.xml
3.实现IBaseInfoService
实现接口中的方法,指定自己service类的名称,确保组件运行时实现类能正确被调
用,例如截图中将service名称定义为“carpo”
4.设置定时任务执行时间
系统默认为30分钟执行一次,使用者可以修改carpo-info-pubs.xml中
的quartzTaskTime值,如图:
5.在自己系统中需要发送信息的地方,初始化TInfos数据,并调用IBaseInfoService的saveTInfos()
方法即可。
注意:platForm应与service实现类名称一致,isLazy表示此消息是否延迟发送
其他字段可根据自己业务赋值,字段注释如下
介绍
日常的程序开发中,或多或少会遇到信息发布等功能,在指定操作结束后,发送信息给第三方,而Java是同步的,调用发送方法,要等返回结果之后才能继续执行后面的代码,特别是执行的发送方法较多时,会影响此操作的主方法响应。基于此种情况,本文对信息发布功能进行了简单的抽象集成,以阻塞队列和定时任务的方式,实现消息的异步发送,使用者只需要实现接口接口需要的相关方法,即可完成消息发布功能的快速开发,旨在为开发人员减少必要的工作量。此为最初版本,后续会继续扩展,各位童鞋有好的想法也可以与楼主联系,群策群力。下面放出git地址。
插件依赖
集成步骤
1.导入jar包:carpo-infopubs-1.0 下载地址:carpo-infopubs-1.0.jar git地址:http://git.oschina.net/carpo/Carpo.InfoPubs
2.将carpo-info-pubs.xml加入到spring启动项中 在web.xml中,contextConfigLocation中加入carpo-info-pubs.xml
3.实现IBaseInfoService
实现接口中的方法,指定自己service类的名称,确保组件运行时实现类能正确被调
用,例如截图中将service名称定义为“carpo”
4.设置定时任务执行时间
系统默认为30分钟执行一次,使用者可以修改carpo-info-pubs.xml中
的quartzTaskTime值,如图:
5.在自己系统中需要发送信息的地方,初始化TInfos数据,并调用IBaseInfoService的saveTInfos()
方法即可。
注意:platForm应与service实现类名称一致,isLazy表示此消息是否延迟发送
其他字段可根据自己业务赋值,字段注释如下
相关文章推荐
- java对世界各个时区(TimeZone)的通用转换处理方法(转载)
- java-注解annotation
- java-模拟tomcat服务器
- java-用HttpURLConnection发送Http请求.
- java-WEB中的监听器Lisener
- Android IPC进程间通讯机制
- Android Native 绘图方法
- Android java 与 javascript互访(相互调用)的方法例子
- 介绍一款信息管理系统的开源框架---jeecg
- 聚类算法之kmeans算法java版本
- java实现 PageRank算法
- PropertyChangeListener简单理解
- c++11 + SDL2 + ffmpeg +OpenAL + java = Android播放器
- 插入排序
- 冒泡排序
- 堆排序
- 快速排序
- 二叉查找树