akka-http 相关问题

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

如何设置内容类型?

我使用akka http客户端2.4.6将json发布到服务器(服务器要求消息的内容类型为applicaton / json来处理):val request = HttpRequest(uri =“http:// localhost:9000 / auth / add-user “,......

回答 1 投票 3

来自String的动态PathMatcher

我有一个测试服务器,它在运行时获得期望,并在调用期望时做出相应的响应。期望存储在州。这是路线:val路线:路线= ctx => {...

回答 1 投票 2

Akka HTTP:Spray-JSON:找不到关键'spray'的配置设置

我试图在akka-http服务器中使用spray-json,我收到此错误:线程“main”中的异常com.typesafe.config.ConfigException $ Missing:找不到关键字的配置设置'...

回答 1 投票 0

Akka-http-json“不支持的内容类型,支持:application / json”

我在使用自定义JSON marshaller / unmarshaller时遇到了麻烦。这很好用:trait EWorksJsonSupport使用DefaultJsonProtocol扩展SprayJsonSupport {隐含对象...

回答 3 投票 2

如何使用Akka-Http进行并行Http请求?

我是Scala的新手,并尝试实现一个库,我将获得数千个URL。我的工作是从这些URL下载内容。我会选择简单的scalaj-http库,但确实...

回答 1 投票 1

Akka HTTP - 下载后如何删除文件?

当使用指令getFromFile时(在此处记录:https://doc.akka.io/docs/akka-http/current/routing-dsl/directives/file-and-resource-directives/getFromFile.html#description)如何处理完成...

回答 1 投票 2

响应流有时会导致“按对等方重置连接”错误

在我们的应用程序中,我们有流式JSON文档的路由。这是一个例子:/ ** GET api / 1 / tenant /(tenantId)/ ads / * / def getAllAdsByOwner(advertiserId:AdvertiserId):Route = get {...

回答 1 投票 1

面对问题测试akka http缓存

我正在使用Akka HTTP缓存来缓存我的结果。但我面临着测试它的问题。 class GoogleAnalyticsController @Inject()(cache:Cache [String,HttpResponse],...

回答 1 投票 0

将标头添加到Akka HTTP HttpRequest

我有一个现有的Akka HTTP HttpRequest,我想添加两个标头。 val req:HttpRequest = ??? val hs:Seq [HttpHeader] = Seq(RawHeader(“a”,“b”))req.addHeaders(hs)预期:一个新...

回答 2 投票 0

无法使用Jackson解组LocalDate和LocalTime类

我正在使用akka制作一个POST路由,我将我的Json数据反序列化为Video对象,但是下面的curl请求:curl -H“Content-Type:application / json”-X POST -d'{“title” : “视频 ...

回答 1 投票 1

HttpClient Akka超时设置

我正在尝试在我的Akka应用程序中实现HTTP客户端以使用第三方API。我想要配置的是超时和发生故障时的重试次数。以下是......

回答 1 投票 0

如何使用akka http发送文件作为响应?

我对akka世界有点新意,所以我的知识领域有点小。我正在创建一个https服务器并使用akka流和http处理它,对于特定的URL,我需要将文件发送回...

回答 3 投票 2

Akka Streams - 用于Source.unfoldAsync的Backpressure

我目前正在尝试读取分页的HTTP资源。每个页面都是一个多部分文档,如果页面包含更多内容,页面的响应将包含标题中的下一个链接。一个......

回答 2 投票 3

如何优化akka-stream中REST API调用的吞吐量

我目前正在学习akka流,我正在尝试实现一个简单的流,它从源获取项目并为每个项目调用REST api。我的代码的简化版本看起来像......

回答 3 投票 0

如何在akka-Http中返回JSON而不是Case Class

我创建了一个路由来流式传输JSON中的案例类列表。但是如果我使用ByteString,则打印case类而不是JSON def streamRoute:Route = pathEndOrSingleSlash {val byteString = ...

回答 2 投票 0

如何从java中的akka get路由返回文件

我想发送一个文件以响应客户的请求。我需要路由的代码来发送响应的文件。我想在java中使用akka构建路由。 public Route createRoute(){...

回答 1 投票 0

akka-http错误:无法找到参数um的隐式值:akka.http.scaladsl.unmarshalling.FromRequestUnmarshaller

我知道已经有人问过,但我似乎无法找到答案。这是我的代码:import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport import spray.json.DefaultJsonProtocol final ...

回答 3 投票 2

正确使用Akka http客户端连接池

我需要使用Akka的HTTP客户端(v2.0.2)来使用REST服务。逻辑方法是通过主机连接池执行此操作,因为我们期望大量的同时连接。流......

回答 3 投票 14

如何使用akka-http创建自定义unmarshallers来处理参数列表?

我正在尝试从发送到我的路由的输入中解组参数,以便路由能够处理参数并在参数未正确格式化时发回BadRequest。 ......

回答 2 投票 0

如何将收到的消息广播到两个不同的流

如何将收到的消息广播到两个不同的流我正在使用akka流websocket客户端来请求和接收数据websocket服务器。通过websocket收到的数据,我......

回答 1 投票 1

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