• 欢迎访问开心洋葱网站,在线教程,推荐使用最新版火狐浏览器和Chrome浏览器访问本网站,欢迎加入开心洋葱 QQ群
  • 为方便开心洋葱网用户,开心洋葱官网已经开启复制功能!
  • 欢迎访问开心洋葱网站,手机也能访问哦~欢迎加入开心洋葱多维思维学习平台 QQ群
  • 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏开心洋葱吧~~~~~~~~~~~~~!
  • 由于近期流量激增,小站的ECS没能经的起亲们的访问,本站依然没有盈利,如果各位看如果觉着文字不错,还请看官给小站打个赏~~~~~~~~~~~~~!

终于可以愉快的撸Java异步代码了!

JAVA相关 白菜园 2523次浏览 0个评论

  异步响应式编程可以极大的提高系统的并发呑吐量,但由于Java没有类似于其他语言的Async/Await机制,所以只能通过CompletableFuture.thenXXX()来串联各个异步任务,这给习惯了写同步增删改查的小伙伴们带来了些小麻烦。如果说C#基于状态机在编译时实现了await转换,那么Java肯定也可以基于相同的原理实现await,作者上网一搜果然找到了ea-async,使用与C#相同的方式实现了await异步方法,这回终于可以愉快的撸Java异步代码了。

一、 示例代码

  举个扣减库存并保存订单的例子,在没有await方式下的示例代码如下:

public CompletableFuture<?> saveOrder(Order order) {
    //1.开始事务
    return DataStore.DemoDB.beginTransaction().thenCompose(txn -> {
        //2.扣库存
        var cmd = new SqlUpdateCommand<Order>();
        cmd.update(e -> e.Stock = e.Stock - order.Quantity); //当前量扣除订单量
        cmd.where(e -> e.ProductId == order.ProductId);
        var outs = cmd.output(e -> e.Stock);
        return cmd.execAsync(txn).thenCompose(rows -> {
            //3.判断库存
            if (rows == 0 || outs.get(0) < 0) 
                return CompletableFuture.failedFuture("库存不足");
            //4.保存订单
            return order.saveAsync(txn);
        }).thenCompose(r -> txn.commitAsync()); //5.递交事务
    }).thenApply(r -> "Done.");
}

  WTF! 一层套一层的回调,这还只是个简单的例子啊。但是如果使用await的方式,业务逻辑就变得清爽多了:

import static sys.Async.await;

public CompletableFuture<?> saveOrder(Order order) {
    //1.开始事务
    var txn = await(DataStore.DemoDB.beginTransaction());
    //2.扣库存
    var cmd = new SqlUpdateCommand<Order>();
    cmd.update(e -> e.Stock = e.Stock - order.Quantity); //当前量扣除订单量
    cmd.where(e -> e.ProductId == order.ProductId);
    var outs = cmd.output(e -> e.Stock); 
    var rows = await(cmd.execAsync(txn));
    //3.判断库存
    if (rows == 0 || outs.get(0) < 0)
        return CompletableFuture.failedFuture("库存不足");
    //4.保存订单
    await(order.saveAsync(txn));
    //5.递交事务
    await(txn.commitAsync());
    return CompletableFuture.completedFuture("Done.");
}

二、 实现原理

  核心思想没有变,还是代码分析转换。作者原本想利用JDT在源码层进行await转换,但是工作量还是比较大的,在这里感谢github/ea-async项目,使得作者只修改了十几行代码就实现了上述效果,具体转换过程如下:

  1. 服务模型的虚拟代码经过JDT分析、转换、编译为class文件(参考前篇说明);
  2. 调用ea-async的Transformer类直接分析与转换class文件内的await方法调用,生成新的class文件。

具体参考源码PublishService的compileService()及transformAsync()方法。

三、 本篇小结

  先解释一下上篇”优雅的Java ORM”小伙伴们的评论,有说这么多ORM干吗还要造一个的,也有说不够”优雅”的,其实造轮子最根本的原因是:异步支持!,Spring WebFlux及VertX有相应的异步操作数据库的支持,但本框架没法集成。MyBatis之类的全是同步操作,小的应用系统没有问题,高并发系统的呑吐量就非常可怜了,这个大家可以测一下Spring MVC与WebFlux的性能对比。

  软件技术日新月异,新一代的开发框架必定是异步的!对于作者来讲Spring还不够简单优雅,运行的也不够快,所以才会尝试重新造这个大轮子,争取让应用系统的开发人员有更多的时间关注数据结构、业务逻辑和用户体验,也争取让小伙伴们有一个丝般顺滑的开发体验。

边码代码边码文实属不易,作者需要您的支持请您多多点赞推荐!另欢迎感兴趣的小伙伴加入我们!


开心洋葱 , 版权所有丨如未注明 , 均为原创丨未经授权请勿修改 , 转载请注明终于可以愉快的撸Java异步代码了!
喜欢 (0)

您必须 登录 才能发表评论!

加载中……