Akka HTTP层的目的是通过HTTP将Actors暴露给Web,并使它们能够将HTTP服务作为客户端使用。它不是HTTP框架,它是一个基于Actor的工具包,用于与Web服务和客户端进行交互。
Akka Http - 如何将ResponseEntity解组为CustomClass?
我正在使用Akka Http向第三方API发出请求。响应是“application / json”,我想使用Akka Http将它们转换为自定义案例类。我想做点什么......
假设我在s3中有很多文件,并且根据用户请求我想要开始流式传输从其他s3文件流构建的存档。是否可以像下面那样实现流量流? ...
Play Framework测试助手需要隐式`Materializer`
我正在使用Play 2.6.x并且状态(结果)的测试助手具有以下方法:def status(of:Accumulator [ByteString,Result])(隐式超时:Timeout,mat:Materializer):Int = status(of。跑()) ...
Akka http -ERROR:如果Payload大小增加,则子流源不能多次实现
我正在使用Akka Http,我在那里定义了一条路由为val route =(path(HttpConstants.CreateJob)&post){(entity(as [JobDetailsEntity])&entity(as [JobEntity])){(...
我一直在使用akka-http一段时间了,到目前为止,我主要通过扩展StrictLogging或LazyLogging然后调用:log.info log.debug来使用scala-logging记录事物....
Websocket单元测试:来自ScalaTestRouteTest的WS不会执行websocket请求
我正在尝试为websocket进行单元测试。从doc,我应该可以使用WS参见下面的sscce包com.streamingout import akka.http.scaladsl.model.ws.TextMessage import akka ....
如何在Scala中创建多部分/混合HTTPRequest(JSON +文件)
我们如何在客户端的akka 中创建多部分/混合请求? multipart / form-data与multipart / mixed相似99%,但是akka-http只为前者提供了方便的方法,而不是...
我是Akka HTTP和Scala的新手。我试图使用Akka actor处理HTTP请求。遇到HTTP请求时,会激活相应的子actor。目前这......
我有一个正在运行的Akka HTTP应用程序,我想关闭它。在SBT中按Ctrl + C对我不起作用(我的shell目前是用于Windows的Git Bash)。什么是推荐的关闭方式...
Akka-http:连接到localhost上的websocket
我试图通过localhost上的websocket连接到某个服务器。当我尝试在JS中使用ws = new WebSocket('ws:// localhost:8137');它成功了。但是,当我使用akka-http和akka -...
使用GenericHttpCredentials从http请求标头中提取令牌
我试图从我的HTTP请求的授权标头中提取令牌。授权标头的格式为Authorization:Token token = abcdefg123。我想要以下......
Akka http-client无法使用来自服务器的所有数据流
我正在尝试编写一个简单的akka 流休息端点和客户端来使用此流。但后来我尝试运行服务器和客户端,客户端只能消耗部分流。我看不到任何......
如何使用基于请求参数的Flows在akka-http中引入非阻塞延迟
我正在启动服务器并使用akka stream connection.handleWith(handleRequest())处理它,其中handleRequest():Flow [HttpRequest,HttpRespnse,_]我需要在发送时创建延迟...
在Redis pub / sub和Akka Streams中使用SSE的最简单方法是什么?
我想为以下场景流式传输分块服务器发送事件:订阅Redis密钥,如果密钥更改,则使用Akka Streams流式传输新值。如果有......它应该只流
对于像/ temp / $ a这样的演员使用actorSelection和ask模式
我有一个ActorSystem(例如A),它产生其他ActorSystem(例如B)。当B出现时,它知道A的地址并执行cluster.join()。一旦,集群加入,演员可以沟通......
我使用Akka HTTP实现了Web套接字。我正在使用Kafka的数据并使用Web套接字发送通知。功能正常,但我陷入了测试用例。 `私人定义...
我是拉格姆的新手。使用Lagom创建了一个hello world微服务。 service-impl对任何类型的db或逻辑没有任何依赖性,只返回一个硬编码字符串。但是当我在尝试的时候......
我有以下代码片段,不能编译:import akka.actor.ActorSystem import akka.Done import akka.http.scaladsl.Http import akka.stream.ActorMaterializer import akka.stream ....