akka-http 相关问题

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

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

使用akka http的Web套接字的单元测试用例

我使用Akka HTTP实现了Web套接字。我正在使用Kafka的数据并使用Web套接字发送通知。功能正常,但我陷入了测试用例。 `私人定义...

回答 1 投票 0

提高lagom服务的可扩展性

我是拉格姆的新手。使用Lagom创建了一个hello world微服务。 service-impl对任何类型的db或逻辑没有任何依赖性,只返回一个硬编码字符串。但是当我在尝试的时候......

回答 1 投票 1

协议切换成功与否

我有以下代码片段,不能编译:import akka.actor.ActorSystem import akka.Done import akka.http.scaladsl.Http import akka.stream.ActorMaterializer import akka.stream ....

回答 1 投票 1

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