Akka是一个开源工具包和运行时，简化了JVM上并发和分布式应用程序的构建。它实现了Erlang中已知的actor模型。
为什么Classic Akka在创建actor时无法使用Java的类型转换？
我在 Java 中使用 Classic Akka 时遇到问题。看来 Akka 在创建 actor 和使用 .tell() 时无法使用 Java 的内置类型转换。 下面是一个简化版本...
Scala Akka Http：com.typesafe.config.ConfigException$Missing：找不到键“调度程序”的配置设置
使用scala Akka创建API，代码在IDE中运行，但是创建jar时无法运行代码： 使用 scala 2.11.12，下面是 build.sbt 此构建/版本：=“0.1.0-SNAPSHOT”
考虑以下代码： GraphDSL.create() { 隐式构建器 => 导入 GraphDSL.Implicits._ val in = 源（0 到 10） val fanOut = builder.add(广播[Int](2)) val toString = 构建...
我一直在尝试使用推荐的rollingUpdate 加上集群应用程序版本在kubernetes 中部署akka 集群，以便以最短的停机时间实现顺利部署。然而移交过程是
AnnotationConfigServletWebServerApplicationContext - 上下文初始化期间遇到异常 - 取消刷新尝试
如果我在 LocalCosmosDBConfig.java 中取消注释 cosmosAsyncClient 方法，则会收到以下警告。如果我在同一文件中取消注释 cosmosConfig 方法，则会收到类似的警告。应用程序已开发...
我创建了一个 sbt 项目来学习使用 akka-http 进行简单的增删改查操作。首先，我添加了简单的路线来检查它是否正常工作。 通过运行 sbt run 命令，我发现它在本地运行
在我们的 Java Spring 应用程序中，我们使用 Scala Akka 消息传递库来发送和接收消息。 在消息中，我们将对象传递给进程。 将对象发送给接收者
我使用以下 akka 配置启动了 ODL(opendaylight) 集群： 在此输入图像描述 这样，节点(11.128.83.43, 11.128.83.33, 11.128.83.32)组成了一个集群，11.128.83.43是member-1,...
Await.result 总是挂起/超时并且从不返回结果（Scala - Akka 演员）
简而言之，我正在尝试制作一个计算斐波那契数的 Scala actor 系统。但是，Await.result() 行总是超时，我不确定问题是什么。 ...
我想了解以下代码是如何工作的。 @豆 公共 StateHandlerDef 处理程序（）{ return() -> StateOne.class; } @命名 @Scope(“原型”) 公共类 StateOne 扩展
我们可以从shard actor的上下文中创建akka actor吗？
我想了解我们是否可以从分片参与者的上下文（从分片参与者内部）创建一个参与者并将一些工作委托给它？ 如果我从分片演员创建演员，有什么限制吗？...
优化 HTTP 上 Akka / Pekko 流的 CPU 利用率和吞吐量
考虑以下代码： def getFlow()(隐式 appConfig: AppConfig, actorSystem: ActorSystem): Flow[BrandSafetyServiceRequest, HttpResponse, NotUsed] = { 隐式值
akka.presistance.postgresql 客户端已经太多了
我正在使用 akka.presistance.postgresql 库，由于大量参与者并行运行，我面临着“抱歉，客户端太多”异常。 我想知道什么是最好的...
Akka Streams：如何使用 GraphDSL 构建源中源？
这是一个简单的场景。 让我们从单个 Akka 源开始：比方说，从数据库检索的行。基于分区函数，不同的行需要被转移到不同的...
我不想在不丢失发生故障时发送的数据的情况下跳过流程。但我找不到办法做到这一点。这是我用来测试的示例代码。 val 决策者：Supervision.Dec...
我需要合并多个慢速源但保持顺序。 如果代码执行两次，顺序必须相同。 非常简单的解决方案如下： 来源 .来自（分区（）...
当一个序列中有三个actor时——actor1 -> actor2 -> actor3 - 并且actor3的处理速度明显较慢，会导致actor1快速发送消息，从而导致积压
无法执行 HTTP 请求：获取操作花费的时间超过配置的最大时间
我正在 AWS 中运行一个批处理作业，它使用来自 SQS 队列的消息并使用 akka 将它们写入 Kafka 主题。我创建了一个具有以下参数的 Sqs 异步客户端： 私人静态
是否可以使用 Akka Patterns.ask() 来让经典 actor 询问类型化 actor？
使用Akka（Java）我尝试使用询问模式（akka.pattern.Patterns.ask），其中询问者是经典演员，被询问者是类型演员。我正在 cl 中尝试类似的事情...
在 Akka 中，除了使用 RPC 风格编程模型的“Typed Actor”API 之外，是否有其他方法可以将发送给 Actor 的消息限制为特定的静态类型？ 我可以使用消息传递吗