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 “,......
我有一个测试服务器,它在运行时获得期望,并在调用期望时做出相应的响应。期望存储在州。这是路线:val路线:路线= ctx => {...
Akka HTTP:Spray-JSON:找不到关键'spray'的配置设置
我试图在akka-http服务器中使用spray-json,我收到此错误:线程“main”中的异常com.typesafe.config.ConfigException $ Missing:找不到关键字的配置设置'...
Akka-http-json“不支持的内容类型,支持:application / json”
我在使用自定义JSON marshaller / unmarshaller时遇到了麻烦。这很好用:trait EWorksJsonSupport使用DefaultJsonProtocol扩展SprayJsonSupport {隐含对象...
我是Scala的新手,并尝试实现一个库,我将获得数千个URL。我的工作是从这些URL下载内容。我会选择简单的scalaj-http库,但确实...
当使用指令getFromFile时(在此处记录:https://doc.akka.io/docs/akka-http/current/routing-dsl/directives/file-and-resource-directives/getFromFile.html#description)如何处理完成...
在我们的应用程序中,我们有流式JSON文档的路由。这是一个例子:/ ** GET api / 1 / tenant /(tenantId)/ ads / * / def getAllAdsByOwner(advertiserId:AdvertiserId):Route = get {...
我正在使用Akka HTTP缓存来缓存我的结果。但我面临着测试它的问题。 class GoogleAnalyticsController @Inject()(cache:Cache [String,HttpResponse],...
我有一个现有的Akka HTTP HttpRequest,我想添加两个标头。 val req:HttpRequest = ??? val hs:Seq [HttpHeader] = Seq(RawHeader(“a”,“b”))req.addHeaders(hs)预期:一个新...
无法使用Jackson解组LocalDate和LocalTime类
我正在使用akka制作一个POST路由,我将我的Json数据反序列化为Video对象,但是下面的curl请求:curl -H“Content-Type:application / json”-X POST -d'{“title” : “视频 ...
我正在尝试在我的Akka应用程序中实现HTTP客户端以使用第三方API。我想要配置的是超时和发生故障时的重试次数。以下是......
我对akka世界有点新意,所以我的知识领域有点小。我正在创建一个https服务器并使用akka流和http处理它,对于特定的URL,我需要将文件发送回...
Akka Streams - 用于Source.unfoldAsync的Backpressure
我目前正在尝试读取分页的HTTP资源。每个页面都是一个多部分文档,如果页面包含更多内容,页面的响应将包含标题中的下一个链接。一个......
如何优化akka-stream中REST API调用的吞吐量
我目前正在学习akka流,我正在尝试实现一个简单的流,它从源获取项目并为每个项目调用REST api。我的代码的简化版本看起来像......
如何在akka-Http中返回JSON而不是Case Class
我创建了一个路由来流式传输JSON中的案例类列表。但是如果我使用ByteString,则打印case类而不是JSON def streamRoute:Route = pathEndOrSingleSlash {val byteString = ...
我想发送一个文件以响应客户的请求。我需要路由的代码来发送响应的文件。我想在java中使用akka构建路由。 public Route createRoute(){...
akka-http错误:无法找到参数um的隐式值:akka.http.scaladsl.unmarshalling.FromRequestUnmarshaller
我知道已经有人问过,但我似乎无法找到答案。这是我的代码:import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport import spray.json.DefaultJsonProtocol final ...
我需要使用Akka的HTTP客户端(v2.0.2)来使用REST服务。逻辑方法是通过主机连接池执行此操作,因为我们期望大量的同时连接。流......
如何使用akka-http创建自定义unmarshallers来处理参数列表?
我正在尝试从发送到我的路由的输入中解组参数,以便路由能够处理参数并在参数未正确格式化时发回BadRequest。 ......
如何将收到的消息广播到两个不同的流我正在使用akka流websocket客户端来请求和接收数据websocket服务器。通过websocket收到的数据,我......