Akka Flow 在通过连接池发出 http 请求时挂起
我正在使用 Akka 2.4.4 并尝试从 Apache HttpAsyncClient 迁移(未成功). 以下是我在项目中使用的代码的简化版本. 问题是，如果我向流发送超过 1-3 个请求，它就会挂起.到目前为止，经过 6 个小时的调试，我什至无法找到问题所在.我在 Decider 中没有看到异常、错误日志、事件.什么都没有:) 我尝试将 connection-timeout
..
akka相关内容
如何使用 Akka HTTP 从多个参与者/网络处理程序正确调用单个服务器?
我有一个服务(我们称之为服务 A)，它使用 Akka Server HTTP 来处理传入的请求.此外，我还有提供多种 Web 服务的第 3 方应用程序(服务 B).服务 A 的目的是转换客户端请求，调用服务 B 的一个或多个 Web 服务，合并/转换结果并将其返回给客户端. 我在某些部分使用 Actors，而在其他部分使用 Future.为了调用服务 B，我使用 Akka HTTP 客户端.
..
Spray、Akka-http 和 Play，这是新 HTTP/REST 项目的最佳选择
我将使用 Scala 和 Akka Actors 开发新的 HTTP/REST 服务. 我有使用 Play 的经验，但我并不真正需要一个完整的 Web 框架.根据我的阅读，我认为喷雾是一个合适的选择.我的问题来自新的 AKKA-HTTP 之后 Spray 的未来. Spray 项目会独立于 Akka-HTTP 项目发展，还是两个项目会合并为一个 Akka-HTTTP? 如果我开始
..
如何使用 akka-http 对自认证服务器进行 POST 调用
我有一个 akka-streams 拓扑，我使用 akka-http 进行 POST 调用. 在向不安全的服务器(具有自签名证书)发送发布请求时出现以下错误.它是一个内部服务器，所以从安全的角度来看我很好. javax.net.ssl.SSLHandshakeException: 一般 SSLEngine 问题在 sun.security.ssl.Handshaker.checkThrow
..
如何使用 Akka HTTP 表示表单数据请求?
我想创建一个表单数据 http 请求到 Facebook API 使用 Akka HTTP.在 curl 中，请求示例如下所示: curl \-X POST \“https://graph-video.facebook.com/v2.3/1533641336884006/videos"\-F "access_token=XXXXXXX" \-F "upload_phase=transfer" \
..
如何使用 akka http 发送文件作为响应?
我对 akka 世界有点陌生，所以我的知识领域有点小.我正在创建一个 https 服务器并使用 akka 流和 http 处理它，对于特定的 url，我需要将文件发送回客户端.我如何使用 akka 流并避免使用 akka 路由来实现这一点. def handleCall(request:HttpRequest):HttpResponse = {logger.info("请求是{}",reques
..
Scala Akka HTTP 转换参数为 java.time.ZonedDateTime
我正在使用 Akka HTTP(在 Scala 中)开发 REST 服务.我希望将传递给 http get 请求的参数转换为 ZonedDateTime 类型.如果我尝试使用 String 或 Int 但由于 ZonedDateTime 类型失败，则代码工作正常.代码如下所示: parameters('testparam.as[ZonedDateTime]) 这是我看到的错误: 错误:(23
..
akka-http 发送连续分块的 http 响应(流)
我有这个带有 akka-http 客户端和服务器的粗略测试示例. Server.scala: import akka.actor.ActorSystem导入 akka.stream.ActorMaterializer导入 akka.stream.scaladsl.Sink导入 akka.http.scaladsl.Http导入 akka.http.scaladsl.model.HttpMe
..
使用 Play 2.6 和 akka 流的 Websocket 代理
我正在尝试使用 Play 和 akka 流为 Websocket 连接创建一个简单的代理.流量是这样的: (客户端)请求 ->->请求(服务器)代理(客户端)响应 在遵循一些示例之后，我想出了以下代码: def socket = WebSocket.accept[String, String] { request =>val uuid = UUID.randomUUID().toStrin
..
akka HttpResponse 将正文读取为字符串 scala
所以我有一个带有这个签名的函数(akka.http.model.HttpResponse): def apply(query: Seq[(String, String)], accept: String): HttpResponse 我只是在测试中得到一个值，例如: val resp = TagAPI(Seq.empty[(String, String)], api.acceptHeader
..
如何记录 Akka HTTP 客户端请求
我需要记录 akka http 客户端请求及其响应.虽然似乎有一些 API 可以记录这些请求，但没有明确的文档说明应该如何完成.我的方法是创建一个记录的请求，它透明地包装 Http().singleRequest(req) 如下: def loggingRequest(req: HttpRequest)(隐式系统:ActorSystem，ctx:ExecutionContext，m:Materi
..
将框架用作 WebSocket 客户端
我使用的是 Play 2.3，正在查看使用 Akka 作为 WebSocket 服务器的文档.但是在文档中他们没有说明 Play 是否可以连接到现有的 WebSocket 服务器.基本上我有兴趣成为一个 WebSocket 客户端，他将从 WebSocket 服务器接收消息.我的 Play 应用程序将使用此 WebSocket 服务器进行双向请求/响应，然后最后我将启动终止. Play wi
..
如何限制 Akka Stream 每秒仅执行和发送一条消息一次?
我有一个 Akka Stream，我希望该流大约每秒向下游发送消息. 我尝试了两种方法来解决这个问题，第一种方法是让流开始的生产者只在有 Continue 消息进入这个 actor 时每秒发送一次消息. //当在 ActorPublisher 中收到 Continue 消息时//做工作然后...如果(总需求 > 0){导入 scala.concurrent.duration._cont
..
如何使用 Akka 2.3.x 运行 Play 2.2.x?
有没有办法结合akka 2.3和玩2.2?现在，我在运行此类应用程序时遇到 AbstractMethodError.我需要在一个应用程序中同时使用它们，因为 Akka 2.3 带有非常有用的 akka 持久性模块，该模块非常可靠(与其前身相反)，而且这种可靠性对我来说非常重要.我已经尝试从源代码编译 play 2.2.2 并将那里的 akka 依赖项更改为 2.3，但我仍然遇到相同的错误: [E
..
奇怪的错误信息:错误的符号引用.package.class 中的签名指的是 package org 中不可用的术语 apache
当我尝试编译简单类型安全的 akka 程序(scala 2.10、akka、2.1.0)时: scalac -cp "akka-actor_2.10-2.1.0.jar:akka-camel_2.10-2.1.0.jar" write2.scala错误:错误的符号引用.package.class 中的签名是指术语 apache在包 org 中不可用.当前的类路径或版本中可能完全缺少它类路径可能
..
Spray.routing.HttpService 如何调度请求?
免责声明:我目前没有 Scala 经验，所以我的问题与非常基础有关. 考虑以下示例(可能不完整): import akka.actor.{ActorSystem, Props}导入 akka.io.IO导入spray.can.Http导入 akka.pattern.ask导入 akka.util.Timeout导入 scala.concurrent.duration._导入 akka.ac
..
关闭 Slick 登录
Slick 用大量日志消息填满了控制台.我想，就像文档建议的那样，使用 slf4j-nop，所以日志记录被关闭，但 Akka 需要它自己的 slf4j 库. 所以我留下了 Slick 也使用的 akka-slf4j_2.10.我尝试了很多东西.包含在我的 application.conf 中的是这个(尝试使用和不使用 "): logger=“OFF"logger.scala.slick=“
..
在Spray中完成请求处理后是否可以安装回调?
我正在尝试从 Spray 提供大型临时文件.一旦 HTTP 请求完成，我需要删除这些文件.到目前为止我找不到办法做到这一点...... 我使用的代码类似于 this 或 this: respondWithMediaType(`text/csv`) {路径(“somepath"/CsvObjectIdSegment){id =>CsvExporter.export(id) {//为这个请求
..
使用 SLF4J MDC 进行 Scala Akka 日志记录
我正在配置我的 Akka 应用程序以使用此处指定的 SLF4J 记录器: http://doc.akka.io/docs/akka/2.3.4/scala/logging.html 在幕后，我依靠 Logback 进行日志记录.我正在开发一个用于日志记录的通用模块，用户可以在他们的演员系统中使用它.主要是，我正在创建一个他们可以混合的特征. 我有一个特点: 我有这样的东西:
..
Akka:actor 当前邮箱大小或等待处理的消息数
我正在尝试找出等待参与者处理的待处理队列项目的数量. 我相信一定有一种方法可以从actor上下文或context.system.mailboxes等中引用 这是代码示例: class SomeActor 扩展 Actor {覆盖定义接收 = {case ScanExisting =>{val queueSize = context.system.mailboxes... size ?
..