akka-http 相关问题

Akka HTTP层的目的是通过HTTP将Actors暴露给Web,并使它们能够将HTTP服务作为客户端使用。它不是HTTP框架,它是一个基于Actor的工具包,用于与Web服务和客户端进行交互。

使用akka-http执行OAuth2身份验证的最佳方法是什么?

Akka HTTP和Spray提供了authenticateOAuth2指令,但他们的文档声明该指令不实现完整的OAuth2协议,而是实现它,...

回答 1 投票 16

任何重用Source [ByteString,Any]的方法(不将其保留在内存中)

有没有办法使Source可重用?我有一个接收大文件上传的akka -http服务器,然后通过HTTP将(分块)数据流式传输到用户的websockets和其他HTTP服务器......

回答 1 投票 1

Akka http流式传输响应标头

根据定义,http响应分为3个部分,status-code - > headers - > body,当执行akka客户端http请求时,在前2个部分之后收到http响应...

回答 1 投票 0

与Akka Http Spray Json一起使用SprayJsonSupport时,类路径中缺少“term akka.stream”

我在我的项目中使用akka-http和reactivemongo以及使用akka-http-spray-json编组/解组案例类。这是他们的依赖 - “com.typesafe.akka”%%“akka-http”%“10.1.3”“......

回答 1 投票 1

如何使用Scala / Akka Http处理多个HTTP头

我是Scala和Akka Http的新手。请原谅这个新手问题。我有以下代码处理传入的HTTP GET请求:def clickRoute():Route = func1(requestData => ...

回答 1 投票 0

Akka Http - 如何将ResponseEntity解组为CustomClass?

我正在使用Akka Http向第三方API发出请求。响应是“application / json”,我想使用Akka Http将它们转换为自定义案例类。我想做点什么......

回答 2 投票 4

流式传输由其他流组成的存档

假设我在s3中有很多文件,并且根据用户请求我想要开始流式传输从其他s3文件流构建的存档。是否可以像下面那样实现流量流? ...

回答 1 投票 3

Play Framework测试助手需要隐式`Materializer`

我正在使用Play 2.6.x并且状态(结果)的测试助手具有以下方法:def status(of:Accumulator [ByteString,Result])(隐式超时:Timeout,mat:Materializer):Int = status(of。跑()) ...

回答 3 投票 2

Akka http -ERROR:如果Payload大小增加,则子流源不能多次实现

我正在使用Akka Http,我在那里定义了一条路由为val route =(path(HttpConstants.CreateJob)&post){(entity(as [JobDetailsEntity])&entity(as [JobEntity])){(...

回答 2 投票 0

Akka-http记录请求标识符

我一直在使用akka-http一段时间了,到目前为止,我主要通过扩展StrictLogging或LazyLogging然后调用:log.info log.debug来使用scala-logging记录事物....

回答 1 投票 1

Websocket单元测试:来自ScalaTestRouteTest的WS不会执行websocket请求

我正在尝试为websocket进行单元测试。从doc,我应该可以使用WS参见下面的sscce包com.streamingout import akka.http.scaladsl.model.ws.TextMessage import akka ....

回答 1 投票 2

如何在Scala中创建多部分/混合HTTPRequest(JSON +文件)

我们如何在客户端的akka 中创建多部分/混合请求? multipart / form-data与multipart / mixed相似99%,但是akka-http只为前者提供了方便的方法,而不是...

回答 1 投票 0

如何使用Akka actor来处理Akka中的HTTP请求

我是Akka HTTP和Scala的新手。我试图使用Akka actor处理HTTP请求。遇到HTTP请求时,会激活相应的子actor。目前这......

回答 1 投票 0

关闭Akka HTTP应用程序

我有一个正在运行的Akka HTTP应用程序,我想关闭它。在SBT中按Ctrl + C对我不起作用(我的shell目前是用于Windows的Git Bash)。什么是推荐的关闭方式...

回答 1 投票 9

Akka-http:连接到localhost上的websocket

我试图通过localhost上的websocket连接到某个服务器。当我尝试在JS中使用ws = new WebSocket('ws:// localhost:8137');它成功了。但是,当我使用akka-http和akka -...

回答 2 投票 0

使用GenericHttpCredentials从http请求标头中提取令牌

我试图从我的HTTP请求的授权标头中提取令牌。授权标头的格式为Authorization:Token token = abcdefg123。我想要以下......

回答 1 投票 0

Akka http-client无法使用来自服务器的所有数据流

我正在尝试编写一个简单的akka 流休息端点和客户端来使用此流。但后来我尝试运行服务器和客户端,客户端只能消耗部分流。我看不到任何......

回答 1 投票 2

如何使用基于请求参数的Flows在akka-http中引入非阻塞延迟

我正在启动服务器并使用akka stream connection.handleWith(handleRequest())处理它,其中handleRequest():Flow [HttpRequest,HttpRespnse,_]我需要在发送时创建延迟...

回答 2 投票 0

在Redis pub / sub和Akka Streams中使用SSE的最简单方法是什么?

我想为以下场景流式传输分块服务器发送事件:订阅Redis密钥,如果密钥更改,则使用Akka Streams流式传输新值。如果有......它应该只流

回答 2 投票 1

对于像/ temp / $ a这样的演员使用actorSelection和ask模式

我有一个ActorSystem(例如A),它产生其他ActorSystem(例如B)。当B出现时,它知道A的地址并执行cluster.join()。一旦,集群加入,演员可以沟通......

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.