Akka是一个开源工具包和运行时，简化了JVM上并发和分布式应用程序的构建。它实现了Erlang中已知的actor模型。
我是akka的新手，我一直在关注文档示例。我已经运行了有关停止actor的生命周期示例，但是输出不包含清理消息。看来这个例子是错误的...
我正在使用Akka分片群集在多个节点上分配工作负载，并使用context.watchWith（worker）检测子actor的意外终止。看来如果孩子演员...
我一直在研究Akka Actor模型。我有一个用例，其中有1000多个参与者处于活动状态，并且我必须处理这些参与者。我想到了通过...
我有一个简单的代码，基于alpakka的示例，应该从S3下载一些文件以进行进一步处理：S3.download（bucket，file）.runWith（Sink.head）.flatMap {case Some（（。 。
我如何从Akka Streams接收器引发的异常中恢复？简单示例：Source integerSource = Source.from（Arrays.asList（1、2、3、4、5、6、7、8、9））; ...
Scala akka类型：如何从其实例获取ActorRef到Actor并发送消息本身？
我想从Actor实例（案例类/行为所创建的类）向其Actor发送消息。我通过保存实例来获取它，然后在其中保存ActorRef：val（实例，行为）= ...
im试图使用elasticmq-rest-sqs运行sqs服务器：“ org.elasticmq” %%“ elasticmq-rest-sqs”％“ 0.14.7”，我的akka 依赖项是：val akka = Seq（“ com.lightbend .akka“ %%” akka-stream -...
我发现自己努力为我们的akka -http java应用程序启用https支持。文档页面（https://doc.akka.io/docs/akka-http/current/server-side/server-https-support.html）应该是...
Kafka在Intellij中意外退出，但在bash中意外退出
[当我尝试从Intellij中在Lagom中运行“ runAll”时，启动Cassandra之后，Kafka服务器意外关闭。当我到达显示“服务已启动，请按Enter停止...]的行时，按Enter键即可。...>
我对Akka还是很陌生，并通过了Akka文档的请求-响应示例。我了解此模式的工作方式如下：Dave通过发送Hal的消息来询问Hal ...
我在我的游戏应用中有一个演员，每隔2秒便会发送一条消息到某种方法：onSomething（）：Future [Unit] = {for {a
我开始与Akka一起玩，发现我的大多数演员都具有部分不变的状态和部分可变的状态。两者都可以合并为州案例类，然后可以仅复制到...
Akka Streams中的WebSocket用于推送实时更新
是否可以使用websocket在Akka流中将实时更新从服务器推送到客户端。任何人都可以指向一些相关的Scala代码，以了解如何使用...
我当前正在运行类似于以下内容的Akka流设置：┌─────────────┐┐───────────┐│┌ ──────────────┐││REST端点│──▶│队列...
akka.streams。您可以发出值的源（类似于monix.BehaviorSubject）
我正在寻找akka.stream.scaladsl.Source构造方法，该方法可让我简单地从不同代码位置发出下一个值（例如，监视系统事件）。我需要类似于...
akka.UnsupportedAkkaVersion：Akka的当前版本是[2.5.14]，但是akka-http需要版本[2.5.26]
这里是课程：import akka.Done;导入akka.NotUsed;导入akka.actor.ActorSystem;导入akka.http.javadsl.ConnectHttp;导入akka.http.javadsl.Http;导入akka.http.javadsl.model ....
当尝试通过身份验证访问Rest API时，我的登录名未尝试。我正在Lagom中使用WS Play。登录请求类似于：val reqLogin = ws.url（loginURL）.withAuth（...
项目从Play版本2.3.0-> 2.7.4和Akka版本2.3.3-> 2.5.27迁移，除了在端口9000上运行Web应用程序之外，旧项目还具有以下设置：project_name {akka { ...
我尝试根据页面（https://doc.akka.io/docs/akka-management/current/cluster-http-management.html#api-definition）通过http端点关闭无法访问的节点，但是我尝试了原为...