java - 用于创建异步流 API 的框架

Question

我们应用程序的架构由几个模块组成。这些模块可以作为单个进程运行，也可以在不同的服务器上单独运行。当模块在不同的服务器上时，我们使用 REST 进行模块之间的交互。现在我们需要处理模块之间的流数据。一个模块发送请求——另一个模块异步发回数据 block (对象)。我们尝试使用 KryoNet 和 Apache Mina。我们选择了最后一个，总的来说一切正常。但是解决方案有几个问题，有一种我们重新发明轮子的感觉。

也许有现成的框架可以创建异步 API 来传输流数据，并支持多种传输和内置序列化:

本地 -- 当模块/服务在单个进程中交互时

netty 或模拟 -- 当模块在不同机器上相互交互时

REST -- 通过 HTTP 与模块交互

像 elasticsearch Java API 之类的东西——所有操作都可以通过网络、本地或通过 REST 异步执行。
是否有现成的框架来创建这样的 API？

我们正在使用 Scala 2.10 和 Java。

Answer 1

菲格勒呢？
https://github.com/twitter/finagle

它并不能满足您开箱即用的所有需求，但它是一个非常好的和可扩展的框架，并且可以提供一个良好的基础。

你可以看到一个使用 finagle 做流媒体服务器的例子:
https://github.com/twitter/finagle/blob/master/finagle-example/src/main/scala/com/twitter/finagle/example/stream/StreamServer.scala