Akka是一个开源工具包和运行时，简化了JVM上并发和分布式应用程序的构建。它实现了Erlang中已知的actor模型。
在我们的 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 的消息限制为特定的静态类型？ 我可以使用消息传递吗
我有akka微服务，对于数据库我使用如下配置： 公司名称.db { 配置文件=“slick.jdbc.MySQLProfile$” D b { 驱动程序=“org.mariadb.jdbc.Driver” url = "jdbc:我的...
我有多个 akka-http 服务器实例作为同一 jvm 进程的一部分在不同端口上运行。服务器实例有不同的性能要求，需要进行不同的配置...
该应用程序假装是一个简单的控制台聊天，但它不起作用，我不知道为什么。请告诉我哪里错了 房间演员： 包聊天 导入 Chat.UserActor.{JoinRoomNotification，
Akka 集群客户端通过服务集群 IP Kubernetes 进行通信
我已经在EKS中部署了akka集群，并且它正在形成一个集群。我正在端口 27520 上对集群进行几次休息调用，并且我正在使用集群客户端将其发送到另一个 akka 集群...
为什么 Scala + Akka Typed App 没有日志输出？
我有一个问题，我的程序中没有任何日志输出。请帮我解决问题并告诉我哪里出错了。 该应用程序是一个聊天应用程序。它由 UserActor、Main、
Akka：currentEventsByPersistenceId 始终为“eventEnvelope.timestamp”返回零
我正在尝试使用 akka-persistence-query 中的 currentEventsByPersistenceId 查询来检索和处理消息表中存储的事件。但是，我遇到了一个问题，