0

我正在使用 Play 2.1.2，我遇到了一些麻烦，Enumerator我正在寻找如何调试它的想法。

我正在尝试通过我的服务器流式传输一些 S3 数据。我可以InputStream从 Amazon SDK 中为我的 S3 文件 ( getObject(bucket, key).getObjectContent()) 获取一个。然后我把它InputStream变成一个Enumerator[Array[Byte]]using Enumerator.fromStream。

所有这些类型的检查和在我的本地开发机器上都可以完美运行。当我制定我Result的游戏时，我只是返回Ok.stream(enum)。

当我将它部署到生产服务器时，问题就来了。我第一次请求文件时，它工作得很好，我得到了整个文件。但是随后的时间它经常会通过（每次不同的数量）然后“卡住”。我包装Enumerator如下，以便能够记录枚举是否完成：

val wrapped = enum.onDoneEnumerating { println("Contents fully enumerated"); }
Ok.stream(wrapped);

正如预期的那样，在我的开发机器上（以及第一次在生产机器上），我收到消息“内容完全枚举”。但在那之后，生产机器将开始下载文件，但并没有完成（在 HTTP 意义上和Enumerator意义上）。

我不确定如何调试它。显然，fromStream有一些魔法，我不知道如何弄清楚块之间发生了什么。我认为这可能是线程池问题，所以我将整个响应包装在一个future { blocking { ... } }块中，但它似乎没有任何区别。

我试图避免从 S3 创建本地临时文件然后从中构建我的麻烦Enumerator。使用fromStream来创建Enumerator似乎是一种优雅的方式......如果它有效的话。

建议？

4

1 回答 1

0

好的，所以我想我想通了。事实证明，在 Play 方面，事情似乎正在发挥作用。我尝试了各种变体（构建枚举器、创建临时文件等的不同方式）。这并不重要。

重要的是我使用的代理。我正在使用node-http-proxy，如果我在代理后面的服务器上发出请求，我会得到正确的响应（直接来自 Play）。如果我在代理之外的服务器上发出请求，我会得到一个不正确的（空的）响应。所以看起来代理正在“丢弃”响应。

看来问题是响应被stream调用分块，这导致代理出现问题。如果我将我的回应重新表述为：

SimpleResult( header = ResponseHeader(200), body = enum)

然后 play 使用Enumerator来构建一个完整的响应（不是流式传输的）并且事情再次起作用。当然，在这种情况下必须形成完整的响应是愚蠢的，但它确实有效。希望从长远来看，我能找到比这更好的解决方案，但这似乎目前可行。

于 2013-09-06T16:06:53.940 回答