在Spring中使用哪种“ EventBus”？内置反应堆，Akka？

我不确定在这个狭小的空间中我能否充分回答您的问题。但我会试一试！:)

就功能而言，Spring的ApplicationEvent系统和Reactor确实非常不同。ApplicationEvent路由基于所处理的类型ApplicationListener。除此之外，您还必须自己实现逻辑（但这不一定是一件坏事）。但是，Reactor提供了一个全面的路由层，该路由层也非常轻巧且完全可扩展。两端之间在订阅和发布事件的能力上在功能上有任何相似之处，这实际上是任何事件驱动系统的功能。另外，别忘了spring-messagingSpring 4附带的新模块。它是Spring Integration中可用工具的子集，还提供了围绕事件驱动架构进行构建的抽象方法。

Reactor将帮助您解决一些其他关键问题，否则您将不得不自行管理：

选择器匹配：Reactor进行Selector匹配，包括从简单.equals(Object other)调用到更复杂的URI模板匹配（允许占位符提取）的一系列匹配。您还可以使用自己的自定义逻辑扩展内置选择器，以便可以将丰富对象用作通知键（例如，域对象）。

Stream和Promise API：您Promise已经提到了该.await()方法的API ，这实际上是针对期望阻塞行为的现有代码。当使用Reactor编写新代码时，使用组合和回调通过不阻塞线程来有效利用系统资源的压力不会太大。在依赖少量线程来执行大量任务的体系结构中，阻塞调用者几乎从来不是一个好主意。期货根本无法实现云扩展，这就是现代应用程序利用替代解决方案的原因。

您的应用程序可以使用Streams或Promises来构建，尽管说实话，我认为您会发现它Stream更灵活。API的主要优点是可组合性，它使您可以将动作链接到依赖链中而不会阻塞。作为基于电子邮件用例的现成示例，您描述：

@Autowired
Environment env;
@Autowired
SmtpClient client;

// Using a ThreadPoolDispatcher
Deferred<DomainObject, Stream<DomainObject>> input = Streams.defer(env, THREAD_POOL);

input.compose()
  .map(new Function<DomainObject, EmailTemplate>() {
    public EmailTemplate apply(DomainObject in) {
      // generate the email
      return new EmailTemplate(in);
    }
  })
  .consume(new Consumer<EmailTemplate>() {
    public void accept(EmailTemplate email) {
      // send the email
      client.send(email);
    }
  });

// Publish input into Deferred
DomainObject obj = reader.readNext();
if(null != obj) {
  input.accept(obj);
}

Reactor还提供了Boundary，它基本上是一个CountDownLatch用于阻止任意使用者的Boundary（因此，Promise如果您想要做的只是为Consumer完成而被阻止，则不必构造a ）。Reactor在这种情况下，您可以使用原始格式，然后使用on()和notify()方法来触发服务状态检查。

但是，对于某些事情，您似乎想要的是从Future返回的ExecutorService，不是吗？为什么不简单地简化事情呢？只有在吞吐量性能和开销效率很重要的情况下，Reactor才会真正受益。如果您阻塞了调用线程，那么您可能会抹去Reactor会给您带来的效率提升，因此在这种情况下，使用更传统的工具集可能会更好。

关于Reactor开放性的好处是，没有什么可以阻止两者进行交互。您可以自由组合Futures与Consumers不带静电。在这种情况下，请记住，您的速度只会与最慢的组件一样快。