Finagle-Friendly REPL

我们将要讨论的不是标准 Scala 的代码。如果你喜欢使用 REPL 学习，你可能想知道如何获得一个加入 Finagle 及其依赖的 Scala REPL。

你可以在这里获取 Finagle 源代码。

如果你在 finagle 目录下有 Finagle 的源代码，你可以通过下面的命令得到一个控制台

Futures

Finagle 使用 com.twitter.util.Future [1]编码延迟操作。Future 是尚未生成的值的一个句柄。Finagle 使用 Future 作为其异步 API 的返回值。同步 API 会在返回前等待结果；但是异步 API 则不会等待。例如，个对互联网上一些服务的HTTP请求可能半秒都不会返回。你不希望你的程序阻塞等待半秒。“慢”的 API 可以立即返回一个 Future，然后在需要解析其值时“填充”。

在实践中，你不会发送一个请求，然后在几行代码后调用 myFuture.get。Future 提供了注册回调的方法，在值变得可用时会调用注册的回调函数。

如果你用过其他异步 API，当看到“回调”你也许会畏缩。你可能会联想到他们难以辨认的代码流，被调用的函数藏在离调用处远远的地方。但是，Future 可以利用 Scala 中“函数是一等公民”的特性编写出更可读的代码流。你可以在调用它的地方简单地定义一个处理函数。

例如，写代码调度请求，然后“处理”回应，你可以保持代码在一起：

顺序组合

Future 有类似集合 API 中的组合子（如 map, flatMap） 。回顾一下集合组合子，它让你可以表达如 “我有一个整数 List 和一个 square 函数：map 那个列表获得整数平方的列表”这样的操作。这种表达方式很灵巧；你可以把组合子函数和另一个函数放在一起有效地组成一个新函数。面向 Future 的组合子可以让你这样表达：“我有一个期望整数的 Future 和一个 square 函数：map 那个 Future 获得一个期望整数平方的 Future”。

如果你在定义一个异步 API，传入一个请求值，你的 API 应该返回一个包装在 Future 中的响应。因此，这些把输入和函数加入 Future 的组合子是相当有用的：它们帮助你根据其它异步 API 定义你自己的异步 API。

最重要的 Future 的组合子是 flatMap[2]：

flatMap 序列化两个 Future。即，它接受一个Future和一个异步函数，并返回另一个 Future。方法签名中是这样写的：给定一个 Future 成功的值，函数f提供下一个 Future。如果/当输入的 Future 成功完成，flatMap 自动调用f。只有当这两个 Future 都已完成，此操作所代表的 Future才算完成。如果任何一个 Future 失败，则操作确定的 Future 也将失败。这种隐交织的错误让我们只需要在必要时来处理错误，所以语法意义很大。flatMap 是这些语义组合子的标准名称。

如果你有一个 Future 并且想在异步 API 使用其值，使用 flatMap。例如，假设你有一个 Future[User]，需要一个 Future[Boolean]表示用户是否已被禁止。有一个 isBanned 的异步 API 来判断一个用户是否已被禁止。此时可以使用 flatMap ：

并发组合

你可能想一次获取来自多个服务的数据。例如，如果你正在编写一个 Web 服务来显示内容和广告，它可能会从两个服务中分别获取内容和广告。但是，你怎么告诉代码来等待两份答复呢？如果必须自己实现可能会非常棘手，幸运的是你可以使用并发组合子。

Future 提供了一些并发组合子。一般来说，他们都是将 Future 的一个序列转换成包含一个序列的 Future，只是方式略微不同。这是很好的，因为它（本质上）可以让你把几个 Future 封装成一个单一的 Future。

这些组合子表达了典型的网络服务操作。这段假设的代码在对速率进行限制（为了保持本地速率限制缓存）的同时，将用户的请求调度到后台服务：

这个例子结合了顺序和并发组合。请注意，除了给转化速率限制回应一个异常以外，没有明确的错误处理。如果任何 Future 在这里失败，它会自动传播到返回的 Future 中。

组合例子：网络爬虫

你已经看到了怎样使用 Future 组合子的例子，不过也许意犹未尽。假设你有一个简单的互联网模型。该互联网中只有 HTML 网页和图片，其中页面可以链接到图像和其他网页。你可以获取一个页面或图像，但 API 是异步的。这个假设的 API 成这些“可获取”的数据为资源：

顺序组合

假设给定一个页面 URL，而你希望获取该页面的第一个图。也许你正在做一个网站，在上面用户可以发布有趣的网页链接。为了帮助其他用户决定某个链接是否值得追踪，你打算显示那个链接中第一张图像的缩略图。

即使你不知道组合子，你仍然可以写一个缩略图获取函数：

这个版本的函数能工作。它的大部分内容用来解析 Future，然后把他们的内容传给另一个 Future。

我们希望得到一个页面，然后从该页面获得一个图像。如果你想获得 A，然后再获得 B 的，这通常意味着顺序组合。由于 B 是异步的，所以需要使用 flatMap：

抓取页面的第一个图片是好的，但也许我们应该获取所有图片，并让用户自己进行选择。我们可以使用for循环一个个地抓取，但这需要很长时间；所以我们想并行获取它们。如果你想的事情“并行”发生，这通常意味着并发组合。所以我们使用 Future.collect 的提取所有的图像：

如果这对你有意义，那太好了。你可能会看不懂这行代码 page.imageLinks map { u => fetch(u) }：它使用 map 和 map 后的函数返回一个 Future。当接下来的事情是返回一个Future时，我们不是应该使用flatMap吗？但是请注意，在 map 前的不是一个 Future；它是一个集合。collection map function 返回一个集合；我们使用 Future.collect 收集 Future 的集合到一个 Future 中。

并发 + 递归

除了页面中的图片以外，我们可能会想获取它链接的其他页面。通过递归我们可以构建一个简单的网络爬虫。

在实践中，这个网络爬虫不是很有用：首先我们没有告诉它何时停止爬行；其次即使资源刚刚被获取过，它仍然会不厌其烦地重新获取。

服务

一个 Finagle 服务用来处理 RPC，读取请求并给予回复的。服务是针对请求和回应的一个函数Req => Future[Rep]。

在服务中，我们要同时定义客户端和服务器。

一个 Finagle 客户端“引入”一个网络服务。从概念上讲，Finagle 客户端由两部分组成

• 一个使用服务的函数：分发一个 Req 并处理 Future[Rep]
• 配置怎样分发这些请求；例如，作为 HTTP 请求发送到 api.twitter.com 的 80 端口

同样，Finagle 服务端“输出”网络服务。一个服务端由两个部分组成：

• 一个实现服务的函数：传入一个 Req 并返回一个 Future[Rep]
• 配置如何“监听”输入的 Reqs；例如，在 80 端口的 HTTP 请求。

这种设计分离了服务的“业务逻辑”和数据如何在网络中流动的配置。

我们也谈论 Finagle “过滤器”。过滤器在服务之间，修改流经它的数据。过滤器可以很好地和服务组合在一起。例如，如果你有一个速率限制过滤器和一个 tweet 服务，你可以把它们组合在一起形成有速率限制的 tweet 服务。

客户端

一个 Finagle 客户端“引入”一个网络服务。它有一些配置来设定如何在网络上发送数据。一个简单的 HTTP 客户端可能看起来像这样：

一个服务端按服务进行定义，并配置如何“监听”网络上的请求。一个简单的 HTTP 服务端可能看起来像这样：

这个name是我们强加的，虽然没有在例子中使用它，但这个字段对分析和调试是很有用的。

过滤器

过滤器改造服务，它们可以提供通用的服务功能。例如你有几个服务需要支持速率限制，这时可以写一个限速过滤器并将其应用于所有的服务就解决问题了。过滤器也可以将服务分解成不同的阶段。

一个简单的代理可能看起来像这样：

((ReqIn, Service[ReqOut, RepIn])
         => Future[RepOut])

          (*   Service   *)
[ReqIn -> (ReqOut -> RepIn) -> RepOut]

下面的例子展示了怎样通过过滤器来提供服务超时机制。