如何记录Akka HTTP客户端请求
我需要记录akka http客户端的请求以及它们的响应。虽然似乎有一些API可以记录这些请求，但没有清晰的文档说明应该如何实现。我的方法是创建一个已记录的请求，它透明地包装了Http().singleRequest(req)，如下所示：def loggedRequest(req: HttpRe...
如何修复Spray中SSL连接已关闭但仍出现“Dropping Close”错误
我正在调用一个API，但大部分时间都会出现错误：“Dropping Close since the SSL connection is already closing”和“Premature connection close (the server doesn't appear to supp...
跨微服务的数据一致性
虽然每个微服务通常都有自己的数据，但某些实体需要在多个服务之间保持一致。 在微服务架构这样高度分布式的环境中，针对这种数据一致性需求，设计上有哪些选择？当然，我不想要共享数据库架构，即单个数据库管理所有服务的状态。这违反了隔离和“共享无事”的原则。 我理解，一个微服务可以在创建、更新或删除...
Java响应式框架比较
我看到许多声称可以帮助使用Java构建响应式应用程序的框架/库，例如: Akka、Vert.x、RxJava、Reactor、QBit等。 它们似乎有不同的方法、功能、优缺点等。我找不到详细的比较。每个框架都有文档，但这对我来说不足以理解差异。 主要的Java响应式框架有什么区别？ 什么...
如何将Source[ByteString, Any]转换为InputStream
akka-http将使用multipart/form-data编码上传的文件表示为Source[ByteString, Any]。我需要使用Java库对其进行解组，该库需要一个InputStream。 如何将Source[ByteString, Any]转换为InputStream？
Akka默认调度程序配置值是什么？
在Akka文档中指出，如果未配置调度程序，则将使用默认的调度程序。默认调度程序的属性是什么，例如并行性最小值、并行性因子、并行性最大值等？
如何将不同类型的Futures组合成单个Future，而不使用zip()函数
我想从下面的代码创建一个类型为Future[(Class1,Class2,Class3)]的Future。然而，我发现唯一的方法是使用zip()。我认为这个解决方案很丑陋，可能不够优化。有谁能给我指点迷津。val v = for ( a <- { val f0:F...
如何在Java中从Java List创建一个scala.collection.immutable.Seq？
我正在尝试在我的Java项目中使用Akka，并且遇到了一个关于Scala Seq类型的小问题。我能够将Java的ActorRef List转换为scala.collection.Seq，但是我正在尝试使用的Akka API需要一个scala.collection.immutable.Seq。我...
找不到与键"akka"相关的配置设置。
我在一个项目中使用Scala、Spray和Akka。在Intellij中，一切正常。但是当我尝试在命令行中构建并运行该项目时，出现以下错误： Caused by: com.typesafe.config.ConfigException$Missing: 没有找到key为'akka'的配置设置 ...
基于CPU核心数量的线程配置
场景：我有一个示例应用程序，有3种不同的系统配置-- 2 core processor, 2 GB RAM, 60 GB HHD, - 4 core processor, 4 GB RAM, 80 GB HHD, - 8 core processor, 8 GB RAM, 120 GB HHD...