Gobrs-Async (opens new window)是一款功能强大、配置灵活、带有全链路异常回调、内存优化、异常状态管理于一身的高性能异步编排框架。为企业提供在复杂应用场景下动态任务编排的能力。 针对于复杂场景下，异步线程复杂性、任务依赖性、异常状态难控制性； Gobrs-Async 为此而生。
#为什么写这个项目
在开发复杂中台业务过程中，难免会遇到调用各种中台业务数据， 而且会出现复杂的中台数据依赖关系，在这种情况下。代码的复杂程度就会增加。 如下图所示：
在电商平台业务中， 各中台数据可能依赖 商品Product 数据，而且需要依赖特殊属性中 Item的数据。（有朋友会问，为什么Product 数据不和 Item数据出自同一个中台呢？中台业务发展是多样性的，不同业务中台设计方式不同 ， 难道我们就不对接了吗？所以我们要针对于这种复杂多变的中台业务数据提供技术支撑才是一个合格的开发者应该做的）而且Item数据是HTTP的服务，但Product 是rpc服务。 如果按照Future的 开发方式。我们可能会这样开发
// 并行处理任务 Product 、 Item 的任务
@Resource
List<ParaExector> paraExectors;
// 依赖于Product 和 Item的 任务
@Resource
List<SerExector> serExectors;
public void testFuture(HttpServletRequest httpServletRequest) {
DataContext dataContext = new DataContext();
dataContext.setHttpServletRequest(httpServletRequest);
List<Future> list = new ArrayList<>();
for (AsyncTask asyncTask : paraExectors) {
Future<?> submit = gobrsThreadPoolExecutor.submit(() -> {
asyncTask.task(dataContext, null);
});
list.add(submit);
}
for (Future future : list) {
try {
future.get();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
List<Future> ser = new ArrayList<>();
for (AsyncTask asyncTask : serExectors) {
Future<?> submit = gobrsThreadPoolExecutor.submit(() -> {
asyncTask.task(dataContext, null);
});
ser.add(submit);
}
for (Future future : ser) {
try {
future.get();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
}
#存在的问题
以上示例中，Product数据是通过RPC 方式获取， Item是通过HTTP服务获取，大家都知道， RPC性能要高于HTTP性能。 但是通过Future 的方式， get会阻塞等待 Item数据返回后才会往下执行。 这样的话， 图书音像、装修数据、限购数据等都要等待Item数据返回，但是这些中台并不依赖Item返回的数据， 所以会产生等待时间影响系统整体QPS。
#起源
- 作者通过对开源中间件的源码详细阅读和二次开发的经验和使用心得总结而来。
- 用户的一些使用体验 包括业务的需求
#Gobrs-Async 核心能力
#业界对比
在开源平台找了挺多任务异步编排框架，发现都不是很理想，唯一一款现阶段比较好用的异步编排框架就数asyncTool比较好用。但是在使用时发现，API不是很好用。而且需要频繁的创建 WorkerWrapper 对象 用起来有点不爽。对于业务比较复杂的场景，在开发时需要写较多的 WorkerWrapper 代码，而且框架不能对全局异常进行拦截。只能通过任务的 result 方法捕捉单任务的异常。 不能在任意任务出现异常后 停止全局的异步任务。同时无法在发生全局异常的时候进行异常拦截。如果需要实现在发生需停止全局任务流的时候，发送报警邮件的功能。 asyncTool就显得力不从心了。
asyncTool 本身已经功能很强大了，本人与asyncTool 作者 都是在京东担任研发工作。 涉及到的场景大同小异。 会有很多业务场景，很复杂的中台接口调用关系。所以针对当前业务场景。需要探索更多的技术领域。本身技术是应该服务于业务，落地业务场景。
想给项目起一个简单易记的名字，类似于 Eureka、Nacos、Redis；经过再三考虑后，决定命名：Gobrs-Async
|
功能 |
asyncTool |
Gobrs-Async |
sirector |
|
多任务处理 |
是 |
是 |
是 |
|
单任务异常回调 |
是 |
是 |
否 |
|
全局异常中断 |
否 |
是 |
否 |
|
可配置任务流 |
否 |
是 |
否 |
|
自定义异常拦截器 |
否 |
是 |
否 |
|
内存优化 |
否 |
是 |
否 |
|
可选的任务执行 |
否 |
是 |
否 |
#它解决了什么问题
在请求调用各大中台数据时，难免会出现多个中台数据互相依赖的情况，现实开发中会遇到如下场景。
并行常见的场景 1 客户端请求服务端接口，该接口需要调用其他N个微服务的接口
譬如 请求我的购物车，那么就需要去调用用户的rpc、商品详情的rpc、库存rpc、***等等好多个服务。同时，这些服务还有相互依赖关系，譬如必须先拿到商品id后，才能去库存rpc服务请求库存信息。 最终全部获取完毕后，或超时了，就汇总结果，返回给客户端。
2 并行执行N个任务，后续根据这1-N个任务的执行结果来决定是否继续执行下一个任务
如用户可以通过邮箱、手机号、用户名登录，登录接口只有一个，那么当用户发起登录请求后，我们需要并行根据邮箱、手机号、用户名来同时查数据库，只要有一个成功了，都算成功，就可以继续执行下一步。而不是先试邮箱能否成功、再试手机号……
再如某接口限制了每个批次的传参数量，每次最多查询10个商品的信息，我有45个商品需要查询，就可以分5堆并行去查询，后续就是统计这5堆的查询结果。就看你是否强制要求全部查成功，还是不管有几堆查成功都给客户做返回
再如某个接口，有5个前置任务需要处理。其中有3个是必须要执行完毕才能执行后续的，另外2个是非强制的，只要这3个执行完就可以进行下一步，到时另外2个如果成功了就有值，如果还没执行完，就是默认值。
3 需要进行线程隔离的多批次任务。
如多组任务， 各组任务之间彼此不相关，每组都需要一个独立的线程池，每组都是独立的一套执行单元的组合。有点类似于hystrix的线程池隔离策略。
4 单机工作流任务编排。
5 其他有顺序编排的需求。
针对当前场景下 Gobrs-Async 应运而生
#它有什么特性
Gobrs-Async 在开发时考虑了众多使用者的开发喜欢，对异常处理的使用场景。并被运用到电商生产环境中，在京东经历着严酷的高并发考验。同时框架中 极简灵活的配置、全局自定义可中断全流程异常、内存优化、灵活的接入方式、提供SpringBoot Start 接入方式。更加考虑使用者的开发习惯。仅需要注入GobrsTask的Spring Bean 即可实现全流程接入。
Gobrs-Async 项目目录及其精简
- gobrs-async-example：Gobrs-Async 接入实例，提供测试用例。
- gobrs-async-starter：Gobrs-Async 框架核心组件
如若转载，请注明出处：https://www.51buycar.cn/2540.html
相关推荐
-
加油站储油罐？加油站储油罐一定要地埋吗
很多朋友对于加油站储油罐和加油站储油罐一定要地埋吗不太懂，今天就由小编来为大家分享，希望可以帮助到大家，下面一起来看看吧！本文目录加油站油罐体积计算公式加油站储油罐一定要地埋吗加油站算油罐体积怎么算加油站油罐与加油机之间管线共几根加油站油罐压力范围是
-
油桃热量高吗（吃油桃的好处有哪些）
油桃热量高吗（吃油桃的好处有哪些）油桃是一种果桃，但其表面无毛，营养价值高，口感好。许多人喜欢吃它，但是有些人担心油桃的热量很高，会导致肥胖，不会吃。那么，油桃的热量是高吗？平时吃油桃有什…油桃是一种果桃，但其表面无毛，营养价值高，口感好。许多人喜欢吃它，但是有些人担心油桃的热量很高，会导致肥胖，不会吃。那么，油桃的热量是高吗？平时吃油桃有什么好处？油桃热量高吗吃油
-
宝马530最新报价（宝马530最新报价2020）
中新经纬2月3日(牛朝阁)2022年开年，新势力花样开打“价格战”之际，宝马却开始涨价了。近日，有消息称宝马对旗下部分车型进行涨价，涨价幅度在2000元至20000元，涉及5系、i3、iX3等多款热门车型。宝马方面回应中新经纬称，部分BMW品牌在中国的在售车型确实在2023年2月1日正式上调厂商建议零售价，主要是受到全球范围内的通货膨胀、原材料及物流成本不断上涨，以及供应短缺等
-
国产特斯拉本地化率已超95% 对国内市场将有何等影响？
国产特斯拉本地化率已超95%对国内市场将有何等影响？【】8月15日，特斯拉方面宣布，上海超级工厂第100万辆整车已驶下生产线。与此同时，特斯拉CEO马斯克发文表示：“祝贺特斯拉上海超级工厂生产第100万辆车！特斯拉全球累计生产已超过300万辆。”此后，特斯拉对外事务副总裁陶琳表示，目前特斯拉上海工厂供应链本地化率已经超过95%，且上海工厂团队人员有99.9%由中国人组成。特斯拉汽车特斯拉上海
-
揽胜极光报价（路虎揽胜极光报价）
本文目录路虎极光2.0T每公里多少钱油？路虎揽胜极光怎么样？值得买吗？路虎极光2.0T每公里多少钱油？奇瑞路虎揽胜极光2015款致享版重庆现油价6.64.AB表显11，每公里0.73。我们这加油有优惠壳牌石化都差不多加油我6.14,实际油耗0.6754元。一般我只开手动挡，速度不上110km/h且转速不超1400r/min，车显7.5L/1
-
特斯拉modelx多少钱（特斯拉modely多少钱一辆）
（图片源于百度侵删）文▍陈博怎么也没有想到，原来这特斯拉ModelX是一辆专业赛车手都不一定能开得稳的车。当然，最近开不稳的不仅只是ModelX，还有特斯拉下半年的销量和近期波动不停的股价。首富，你究竟怎么了？壹这两天，林志颖、车祸、着火等三个关键词，又让全球著名车企特斯拉不知道第几回上了热搜。事情的经过差不多是这样：7月22日早上，林志颖开着ModelX在中国台湾桃园市中正北
-
2万以下二手车推荐 开几年后好出手有什么车
其实2万以下二手车推荐的问题并不复杂，但是又很多的朋友都不太了解推荐2万元左右二手车，要手动挡，使用成本低，开几年后好出手有什么车，因此呢，今天小编就来为大家分享2万以下二手车推荐的一些知识，希望可以帮助到大家，下面我们一起来看看这个问题的分析吧！本文目录有没有价值2万左右的二手车推荐，年限10年左右想
-
科目一好考吗，科目一难不难一般复习多久能考
大家好，关于科目一好考吗很多朋友都还不太明白，今天小编就来为大家分享关于科目一难不难一般复习多久能考的知识，希望对各位有所帮助！本文目录科目一为什么考不到90分科目一难不难一般复习多久能考科目一100分难吗2023年科目一容易吗新交规科目一难度科目一为什么考不到90分科目一模拟考85分总是上不
-
driver是什么意思，单词和司机有什么区别
老铁们，大家好，相信还有很多朋友对于driver是什么意思和driver单词和司机有什么区别的相关问题不太懂，没关系，今天就由我来为大家分享分享driver是什么意思以及driver单词和司机有什么区别的问题，文
-
比亚迪汉新增车型最新消息（比亚迪汉新闻发布会）
最近，网上曝光了一组疑似比亚迪汉EV新车型的图片。从这组图片可以看出新车的外观十分具有质感，采用金属灰色漆面，它或许将作为比亚迪汉EV的特殊版本车型出现。新车给人的第一眼就充满了时尚感，主要得益于新车的外观采用了具有质感的金属灰色漆面。前脸部分，新车采用封闭式的进气格栅，在饰板上还可以清晰地看到汉字“汉”的标志；前引擎盖上设计了几条隆起的筋线，彰显出车