2019独角兽企业重金招聘Python工程师标准>>>

原文:Streaming HTTP responses

标准的应答和Content-Length头

由于HTTP 1.1遵守一个连接为多个HTTP请求和应答服务开放的规则,因此服务器在应答时必须发送相应的Content-Length HTTP头。

默认情况下,当你发送一个简单的结果,如:

public Result index() {
return ok("Hello World");
}

你没有指定 Content-Length头。是因为你发送的内容很有名,因此Play可以为你计算内容的长度并生产相应的头。

注意:对于基于文本的内容,这不像看起来那样简单,由于Content-Length头必须用根据把字符转换为字节的编码计算。

为了可以正确的计算Content-Length头,Play必须解析整个应答数据并把它的内容加载到内存。

文件服务

如果对于简单内容来说,可以把整个内容加载进内容,那么对于大数据集怎么办呢?比如我们想给客户端发送一个大文件。

Play提供了易于使用的助手来提供本地文件服务这样的普通任务:

public Result index() {
return ok(new java.io.File("/tmp/fileToServe.pdf"));
}

此外,这个助手也会根据文件名计算 Content-Type头。并且他也添加Content-Disposition头指定Web浏览器应该怎样处理这个应答。默认是使用Content-Disposition: attachment; filename=fileToServe.pdf.让Web浏览器下载这个文件。

分块应答

现在,流文件内容的处理还行,由于我们在流之前可以计算内容长度。但是动态计算没有可用的内容长度的内容会如何?

对于这种类型的应答,我们不得不使用分块传输编码

分块传输编码是HTTP 1.1版在Web服务器的一系列块的服务内容的数据传输机制。这使用了Transfer-Encoding HTTP 应答头替代 Content-Length头,该协议将需要另外的需求。由于不使用 Content-Length 头,服务器在开始传送应答到客户端(通常是Web浏览器)之前不需要知道内容的长度。 Web服务器可以在知道内容的所有长度之前开始动态的生成传送应答内容。

每一个块的大小都是在块本身发送之前发送,因此当客户端完成对块数据的接受时可以告知服务端,数据传输是由最后一块长度是0的块终止。 https://en.wikipedia.org/wiki/Chunked_transfer_encoding

好处是我们可以实时提供数据,意味着我们按照它们的接受能力尽可能快的发送数据块。缺点是由于Web浏览器不知道内容的长度,因此就不能正确的显示下载进度条。

比如,我们有一个服务器,这个服务器提供了一个计算一些数据的动态InputStream 。我们可以让Paly直接用分块相应把这个内容转为流:

public Result index() {
InputStream is = getDynamicStreamSomewhere();
return ok(is);
}

你也可以设置你自己的分块响应构建器:

public Result index() {
// Prepare a chunked text stream
Source<ByteString, ?> source = Source.<ByteString>actorRef(256, OverflowStrategy.dropNew())
.mapMaterializedValue(sourceActor -> {
sourceActor.tell(ByteString.fromString("kiki"), null);
sourceActor.tell(ByteString.fromString("foo"), null);
sourceActor.tell(ByteString.fromString("bar"), null);
sourceActor.tell(new Status.Success(NotUsed.getInstance()), null);
return null;
});
// Serves this stream with 200 OK
return ok().chunked(source);
}

Source.actorRef 方法创建一个实现了Akka Streams Source 的ActorRef。然后你可以通过发送信息到Actor的方式发布内容到流。另一种可选的反射是创建一个ActorPublisher 的Actor并使用Stream.actorPublisher创建它。 我们可以检查服务器发送的HTTP响应:

HTTP/1.1 200 OK
Content-Type: text/plain; charset=utf-8
Transfer-Encoding: chunked4
kiki
3
foo
3
bar
0

我们获得了三个块和一个最终关闭响应的空块。 关于更多使用 Akka Streams的信息,你可以参考Akka Streams文档.

转载于:https://my.oschina.net/u/587323/blog/889455

Streaming HTTP responses【翻译】相关推荐

  1. python每秒20个请求_使用Python每秒百万个请求

    python每秒20个请求 by Paweł Piotr Przeradowski 通过PawełPiotr Przeradowski 使用Python每秒百万个请求 (A million reque ...

  2. GPU-CUDA-图形渲染分析

    GPU-CUDA-图形渲染分析 参考文献链接 https://mp.weixin.qq.com/s/dnoqPxEt_XEhVaW_aAfrnQ https://mp.weixin.qq.com/s/ ...

  3. 【性能测试】轻量级压测工具Hey

    点击蓝字关注这个神奇的公众号- 一.Hey介绍 这是个简单的命令行工具,向Web应用程序发送一些负载,同时返回统计结果 项目地址: 二.性能测试 性能测试是通过自动化的测试工具模拟多种正常.峰值以及异 ...

  4. 【性能测试】轻量级性能测试工具Hey

    Hey 一.Hey介绍 二.性能测试 三.下载Linux 64位二进制文件(举例) 1.打开步骤一链接,选择linux64位 2.打开步骤一链接,选择linux安装包 五.[举例并发50,1000个请 ...

  5. 考研英语 - word-list-34

    每天十个单词,本博客收集整理自<考研英语词汇>,仅供学习和个人积累. 新东方单词在线阅读地址 ,希望这个链接一直都有效 :) 2017年08月09日 23:02:47 circus 词义: ...

  6. SIP Via header

    SIP ADVENTURES 作者原文发布在:https://andrewjprokop.wordpress.com/2014/03/06/understanding-the-sip-via-head ...

  7. CUDA编程学习3——并行计算初窥CUDA的软硬件架构

    目录 并行计算概述 查看GPU相关信息 软硬件架构基础 物理层(物理结构) 逻辑层(kernel组织) 物理层和逻辑层的总结 参考 并行计算概述 所谓并行计算的概念定义 同时多个计算资源一起工作(逻辑 ...

  8. Fiddler ——4、工具栏

    Fiddler 工具栏 一.工具栏 1.` WinConfig`:配置应用程序使其可以被Fiddler抓包 2.`备注comment` :给选中的会话加comment备注 3.`Replay` :重新 ...

  9. 网络视频流媒体技术大全

    随着Internet的发展,多媒体信息在网上的传输越来越重要,流式技术以其边下载边播放的特性深受教育.娱乐等行业的喜爱,本文主要描述流媒体系统及主要的流式技术,提出了流式技术的主要解决方案. 1.前言 ...

最新文章

  1. android ui布局开发,Android UI设计初步(基本布局)
  2. 解决pip install keras报错问题
  3. LeetCode题组:第169题-多数元素
  4. 集成 AquaLogic BPM Suite 6.0 和 AquaLogic Service Bus
  5. 基于前后端分离实现阿里云对象存储小案例
  6. 不能在DropDownList 中选择多个项
  7. 吴恩达深度学习 —— 3.6 激活函数
  8. 树莓派 docker homeassistant_树莓派raspberry4B入坑指南 part-4 安装docker-ce 19.03
  9. A*寻路算法基于C#实现
  10. 8数据提供什么掩膜产品_英特尔推出多款数据中心产品:继续提供差异化选项...
  11. 5.4.1. Check Constraints
  12. 「Python量化基础」时间序列的自相关性与平稳性
  13. 从零开始,学习web前端之HTML5
  14. Oracle ERP 模块
  15. 中科矿业带你走进SWARM/BZZ,选择去或留?
  16. 毫米波雷达,超声波雷达,激光雷达,摄像雷达比较
  17. C语言根号下ln怎么表示,用C语言怎么编y=sin(根号下ax)+ln(a+X)
  18. OpenLayers使用高德导航接口实现动画animate
  19. 计算机网络与通信课程感想3000字,计算机网络与通信技术课程学习心得.doc
  20. goland工具的使用

热门文章

  1. 【转】win7与ubuntu双系统,删除ubuntu后,启动错误error:no such partition grub rescue的修复--不错...
  2. Unity3d Awake、OnEnable、Start生命周期
  3. Delphi更高效率的编程方式的思考【一】
  4. C++中的布局new操作符
  5. volatile 用处
  6. windows消息检测函数
  7. operator* operator- 操作符的使用
  8. STM32工作笔记0055---认识pcbdoc文件Schdoc文件
  9. Ubuntu系统安装vmwaretools时the path is not a valid path to the 3.13
  10. 小技巧之nvidia-smi