如何在Scala中连接并读取连续(分块)的HTTP流?例如,如果我用python / bottle编写了这个简单的服务:
from gevent import monkey; monkey.patch_all()
import gevent
from bottle import route, run
@route('/stream')
def stream():
while True:
yield 'blah\n'
gevent.sleep(1)
run(host='0.0.0.0', port=8100, server='gevent')
我打算使用akka-stream处理数据,我只需要一种检索数据的方法.
解决方法:
这应该工作.基本上,您对会产生分块响应的uri发出单个请求.响应实体包含一个dataBytes流.在分块响应的情况下,这将是分块流.在非分块响应(httpentity.Strict)的情况下,这将是仅具有单个块的流.
显然,您也可以在实体上进行显式匹配,以查看其是否为httpentity.Chunked,但通常您也希望保留处理非分块响应的功能.
在实际的应用程序中,您不会使用runForeach来执行副作用,而是对dataBytes流进行一些处理.
import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.model.{Uri, HttpRequest}
import akka.stream.ActorMaterializer
object ChunkTestClient extends App {
implicit val system = ActorSystem("test")
import system.dispatcher
implicit val materializer = ActorMaterializer()
val source = Uri("https://jigsaw.w3.org/HTTP/ChunkedScript")
val finished = Http().singleRequest(HttpRequest(uri = source)).flatMap { response =>
response.entity.dataBytes.runForeach { chunk =>
println(chunk.utf8String)
}
}
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。