SimpleReact来自AOL的一个小型的支持并发的库包,其直接基于Java 8的CompletableFuture, JDK函数接口和Streams API构建,它的Fluent API能够提供解决90%的Reactive使用场景,重要的是没有带入任何复杂性。可以实现Functional Reactive Programming范式(简称:FRP,函数式响应编程)
使用SimpleReact能够方便扩展微服务,它能用于管理微服务的远程调用,能够应付高并发大型高性能平台的要求。
使用SimpleReact能够建立非堵塞的微服务和REST客户端。
SimpleReact启动于Supplier数组,其主要产生其他函数需要响应的数据,每个supplier会传递给Executor执行,都是以单独的线程执行方式。
List<CompletableFuture<Integer>> futures = new SimpleReact() .<Integer> react(() -> 1, () -> 2, () -> 3) .with(it -> it * 100);
在这个案例中,3个supplier产生三个数字,这些都能并行地执行,当它们完成每个数字以后将乘以100,这也是作为一个并行的单独任务执行(由ForkJoinPool 或可配置的任务执行器),Simple React将立即返回Future对象集合列表,这些任务也将异步执行,不会有任何堵塞。
new SimpleReact() .<Integer> react(() -> 1, () -> 2, () -> 3) .then(it -> it * 100) .then(it -> "*" + it)
React then允许事件reactor能够被串联,不像"React with",只返回一个Future集合,React then是一个fluent接口,能够返回React builder,允许以后的reactor能够被加入串联链条中,React then不会堵塞,React with能够在React then以后调用,只要React then提供访问完整的CompleteableFuture API,CompleteableFuture 能通过 SimpleReact.react(streamOfCompleteableFutures)被传递回SimpleReact。
更多复杂应用案例可见