akka-http 相关问题

Apache pekko ( akka http ) - 从请求中提取的字符串正文没有引号

我正在为我的下一个项目POCing pekko http ( akka http )。 我从请求正文实体中提取了 json 字符串，但它没有字符串值的引号。 路线 dsl 上的代码片段： 邮政 { 路径(&q...

基于URL或本地文件限制流

我有一个 akka http API，用户可以将 S3 URL 发送到服务器。然后，服务器从 AWS 服务器启动流并对源执行后续操作。不过我想验证

在 Scala 中解组 protobuf

我之前已经使用 ScalaPB 和以下编组器在 Scala 中进行了解组工作： 隐式 def 编组器[T <: GeneratedMessage]: ToEntityMarshaller[T] = PredefinedToEntityMarsha...

无法连接到 EC2 上运行的 Akka HTTP

我正在将 Akka HTTP 应用程序迁移到 AWS，但对这个问题感到困惑。 Akka HTTP 服务器的启动方式如下： Http().bindAndHandle(路由, "0.0.0.0", 5377) EC2 实例已启动

使用Scala在HttpsRequest中设置Json请求的contentType

尝试将httpRequest发送到远程服务器，但服务器似乎没有收到它，像这样的curl命令工作正常： curl -X POST -H“内容类型：application/json”-d @payload.jso...

将 Sangria 与 Scala 3 一起使用

是否有任何在 Scala 3 程序中使用 Sangria 的示例，或者这是不可能的？在 SBT 中使用交叉编译构建正常，但在 Executor.execute 中出现 NoSuchMethodError 异常...

使用 Akka-http 解析 CONNECT 请求

有没有办法在akka中发出HTTP CONNECT请求？ 我正在尝试在 akka 中编写一个代理应用程序，并且我发出的每个请求都会收到此错误： 16:10:19.179 [默认-akka.actor.de...

如何捕获 withSizeLimit 指令抛出的 EntityStreamSizeException

我在akka http中创建了一个post请求来上传文件 这是我的代码 最终值 MEDIA_FILE_UPLOAD_MAX_SIZE = 30 * 1024 * 1024 def uploadMediaObjectForASite(): Route = path("某个路径&qu...

akka-http elasticsearch {“错误”：“没有找到 uri [https://localhost:9200/myindex/_bulk] 和方法 [POST] 的处理程序”}

所以，我正在使用 elasticsearch 8.7.0。 我创建索引“我的索引”： curl --insecure --user "elastic:password" -X PUT "https://localhost:9200/myindex" 我可以手动添加 JSON 文档...

Akka HTTP in android studio import error - Execution failed for task ':app:mergeDebugJavaResource'

我正在尝试使用 Akka-HTTP-client 库而不是 Retrofit。但我无法导入依赖项并出现构建错误 任务“:app:mergeDebugJavaResource”执行失败。 > 发生故障

Android Studio 中的 Akka-Http-client [关闭]

如何在 android kotlin 中使用 Akka HTTP 库...？ 我正在 Kotlin 的 Android Studio 上开发 Akka HTTP 库...但我不知道如何在 android studio 上使用 Akka HTTP 库。我哈...

Akka HTTP 服务启动时需要打印本地地址和端口号

我有一个带有路由和指令的 Akka-HTTP 项目，我想打印本地地址和端口号 Http().newServerAt("localhost", 8080).bind(myRoutes) 我想打印像

Pod 不使用 PersistentVolume(PV) 和 PersistentVolumeClaim(PVC) 存储数据

我创建了两个 pods 一个正在运行一个简单的 scala 应用程序，它使用 akkaHttp 将用户数据添加到 Elasticsearch 中，另一个 Pod 运行一个 elasticsearch:8.4.5。还创建了一个外部环境...

我无法使用Postman通过k8的外部服务向elasticserach插入数据

我创建了一个简单的 scala 应用程序，它使用 akkaHttp 将用户数据添加到 Elasticsearch 中，akkaHttp 在“0.0.0.0”上运行并且具有端口“8083”。 Http().newServerAt("0.0....

Java Akka http post 方法无法解组嵌套请求 json

我正在尝试在 Post 请求正文中发送嵌套 json 以调用 akkhttp 路由，但出现异常， 无法将 JSON 解组为营销活动 有人请帮我解决这个问题。 下面是代码 ...

Java Akka http 路由发布方法无法解组嵌套实体对象

我正在尝试在 Post 请求正文中发送嵌套 json 以调用 akkhttp 路由，但出现异常， 无法将 JSON 解组为营销活动 有人请帮我解决这个问题。 下面是代码 ...

为什么persist方法从来不工作？

我使用persistenceActor工作，但当我调用persist()方法时，回调从未到达，我在终端actor中找不到任何错误代码 class MajorEventActor extends Timers with ...

Akka HTTP：如何让流Http().superPool()在遇到坏的URL时不抛出异常？

我有很多URL，我想用Akka HTTP，用流来获取。这些URLs可能是错误的，或者DNS可能无法解析主机名。在这些情况下，我希望 ...

如何将apache poi xls工作簿直接流到akka-http响应？

是否有办法避免将Apache POI工作簿写到字节数组或临时文件，而只是将其流式传输到akka-http响应中？ val wb = new SXSSFWorkbook(new XSSFWorkbook()) ...建立工作簿...val ...。

akka http使用路由之外的指令

我使用Scala v2.13.1和AKKA HTTP v10.1.11。我有一个路由，结构如下： def foo(a: String): Directive1[String] = { provide(a) } def bar(a: String): Directive1[String] = { ...