PGET,一个简单、易用的并行调用框架
使用场景
相关概念
- BizData
- BizDataProvider
使用
<!-- 初始化框架,并设置用于并行获取业务数据的线程池配置 --> <bean class="com.dyz.pget.core.BizDataManager" init-method="init" destroy-method="destroy"> <property name="corePoolSize" value="12"/> <property name="maximumPoolSize" value="200"/> <property name="keepAliveTime" value="0"/> <property name="queueSize" value="1000"/> </bean>
第一步:自定义BizData对象
自定义的BizData对象需实现IBizData接口。切要提供无参构造方法。
public class UserInfoBizData implements IBizData{ private Long userId; private String name; private Integer age; /** * 必须提供默认构造参数 */ public UserInfoBizData() { } public UserInfoBizData(Long userId, String name, Integer age) { this.userId = userId; this.name = name; this.age = age; } /** * 如果此数据对象获取失败时的默认兜底值。如果不支持兜底,则返回null即可。 * @return */ @Override public IBizData defaultBizData() { return null; } @Override public String format2String() { return new StringBuilder() .append("ID:").append(userId) .append(",名字:").append(name) .append(",年龄:").append(age) .toString(); } } //篇幅问题,此处只贴了一个BizData的代码
第二步:编写对应的BizDataProvider
@BizDataProvider public class TestBizDataProvider { /** * 异常要抛出,框架会捕获 * @param userId * @return * @throws Exception */ public UserInfoBizData getUserInfoBizData(long userId)throws Exception{ //调用远程rpc或者其他数据源得到数据,并封装到UserInfoBizData对象中 return new UserInfoBizData(userId,"张三",20); } public ProductInfoBizData getProductInfoBizData(long shopId,long productId)throws Exception{ //调用远程rpc或者其他数据源得到数据,并封装到ProductInfoBizData对象中 return new ProductInfoBizData(productId,shopId,"啤酒"); } }
第三步:获取数据
@Test public void testGetter() throws BizDataFetchException { long userId = 1345L; long shopId = 11L; long productId = 11011L; //并行获取用户信息、商品信息、门店信息三个数据。超时时间是100毫秒 List<IBizData> bizDataList = BizDataGetter.build() .get(UserInfoBizData.class,userId) .get(ProductInfoBizData.class,shopId,productId) .get(ShopInfoBizData.class,shopId) .doGet(100L); UserInfoBizData userInfoBizData = (UserInfoBizData)bizDataList.get(0); ProductInfoBizData productInfoBizData = (ProductInfoBizData)bizDataList.get(1); ShopInfoBizData shopInfoBizData = (ShopInfoBizData)bizDataList.get(2); System.out.println(userInfoBizData.format2String()); System.out.println(productInfoBizData.format2String()); System.out.println(shopInfoBizData.format2String()); }
public class BizDataWrapper { private UserInfoBizData userInfoBizData; private ShopInfoBizData shopInfoBizData; private ProductInfoBizData productInfoBizData; public UserInfoBizData getUserInfoBizData() { return userInfoBizData; } public ShopInfoBizData getShopInfoBizData() { return shopInfoBizData; } public ProductInfoBizData getProductInfoBizData() { return productInfoBizData; } }
使用案例代码:
@Test public void testGetter() throws BizDataFetchException { long userId = 1345L; long shopId = 11L; long productId = 11011L; BizDataWrapper bizDataWrapper = new BizDataWrapper(); //并行获取用户信息、商品信息、门店信息三个数据。并注入到bizDataWrapper中,以方便使用。超时时间是100毫秒 BizDataInjector.build(bizDataWrapper) .inject(UserInfoBizData.class,userId) .inject(ProductInfoBizData.class,shopId,productId) .inject(ShopInfoBizData.class,shopId) .doInject(100L); System.out.println(bizDataWrapper.getUserInfoBizData().format2String()); System.out.println(bizDataWrapper.getProductInfoBizData().format2String()); System.out.println(bizDataWrapper.getShopInfoBizData().format2String()); }
结尾
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
CAAI云课堂丨深耕机器人研究23载,北大刘宏教授带你解读“机器人热潮”
屏幕架起连接智能科技知识的桥梁,云端互动开启讲师面对面模式。3月6日,由中国人工智能学会集结优质讲师资源重磅打造的CAAI云课堂将正式开讲,云课堂依托数字化平台,由中国科协绿平台支持,将以前沿优质的课程提供免费高质量的知识服务。特殊时期,让我们运用现代化科技手段为你搭建起一块“智慧黑板”,邀你共同遨游这片人工智能知识的海洋。 No.1 本期讲师 刘宏 CAAI副理事长,北京大学教授,CAAI Fellow。国家“万人计划”首批专家、国家“十三五”重点研发计划“智能机器人”总体组专家、国家“中青年科技创新领军人才”。北京大学深圳研究生院科研处处长、智能机器人开放实验室主任。全国智能机器人创新联盟副理事长,深圳市政协委员。先后承担20余项国家“863”“973”课题和国家自然科学基金等重要科研项目。获国家航天科技进步奖、吴文俊人工智能科学技术奖、日内瓦国际发明博览会奖、CAAI最佳青年科技成果奖等荣誉。 No.2 精彩课程 刘宏教授题为《机器人时代:狼真的来了》的演讲中,将系统分析近年来“机器人热”的国际国内技术和产业背景,在全面回顾人类社会工具发展历程基础上,提出智能机器人是人类社会工...
- 下一篇
维护通知:Gitee 系统将于 3 月 5 日凌晨升级扩容
Gitee 将于 2020 年 3 月 5 日(本周四)凌晨 01:00~01:30 对系统进行升级维护,扩容核心数据库。 届时 Gitee 服务将中断、无法访问,请提前做好安排,敬请谅解。 Gitee:https://gitee.com
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- Eclipse初始化配置,告别卡顿、闪退、编译时间过长
- Mario游戏-低调大师作品
- 2048小游戏-低调大师作品
- SpringBoot2初体验,简单认识spring boot2并且搭建基础工程
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
- SpringBoot2整合MyBatis,连接MySql数据库做增删改查操作
- SpringBoot2整合Thymeleaf,官方推荐html解决方案
- Red5直播服务器,属于Java语言的直播服务器
- 设置Eclipse缩进为4个空格,增强代码规范
- CentOS8安装MyCat,轻松搞定数据库的读写分离、垂直分库、水平分库