高性能 Java 异步应用基础库:Reactor

jopen 11年前

Reactor 是一个基于 JVM 之上的异步应用基础库。为 Java 、Groovy 和其他 JVM 语言提供了构建基于事件和数据驱动应用的抽象库。Reactor 性能相当高,在最新的硬件平台上,使用无堵塞分发器每秒钟可处理 1500 万事件。

示例代码:

// This helper method is like jQuery’s.  // It creates a Selector instance so you don’t have  // to construct one using 'new Selector("parse")'  import static reactor.Fn.$;     Reactor reactor = R.create();     // Register interest in events published to key "parse"  reactor.on($("parse"), new Consumer<Event<String>>() {    public void call(Event<String> ev) {      service.handleEvent(ev);    }  });     // Send an event to this Reactor and trigger all actions  // that match the given Selector  reactor.notify("parse", Fn.event("Hello World!"));

项目主页:http://www.open-open.com/lib/view/home/1368522559953