akka 相关问题

Akka是一个开源工具包和运行时，简化了JVM上并发和分布式应用程序的构建。它实现了Erlang中已知的actor模型。

我正在尝试在我的Akka中创建一个计划程序，键入它只是为了对其进行测试，就像每x秒运行一次。 def start（）：Behavior [ClientMsg] = Behaviors.setup {ctx => ctx.log.info（“ start（）named”）...

scala akka akka-typed

回答 2 投票 0

我如何将the回路线列表添加到汽车当前的路线列表之前？

我想知道如何在Car类中访问方向状态，以便可以在Detour案例类（List [Direction]）中添加消息。所以我目前所拥有的是一个交叉点...

scala akka actor event-based-programming

回答 1 投票 0

Akka classic vs Akka typed

现在我正在学习Akka。但是我发现Akka有两个版本：Classic和Typed。它和我应该学习什么有什么区别？打字版本具有更强大的类型控制吗？如果...

scala akka

回答 1 投票 0

使用Spray json对地图进行分组的最佳情况

我有以下案例类行，我想进一步过滤并将它们表示为json案例类Row（id：UUID，ownerId：UUID，typeId：UUID，name：字符串，值：String）我想要的json格式。 ..

scala akka spray spray-json

回答 1 投票 0

从S3下载文件时引发Akka流异常

[我正在尝试使用以下代码从S3下载文件：wsClient .url（url）.withMethod（“ GET”）.withHttpHeaders（my_headers：_ *）.withRequestTimeout（timeout）...

scala playframework akka

回答 1 投票 0

从Akka型演员访问应用程序配置的最佳实践

我想对这个愚蠢的问题表示歉意。我试图在Google和Stack Overflow中寻找答案，但似乎找不到我想要的东西。我今天晚上已经度过...

akka

回答 1 投票 0

无法在外部使用自定义用户监护人的ActorSystem上创建顶级actor [clusterSingletonManager]

我正在使用Akka Persistence进行事件来源的服务。到目前为止，我们已经成功地将事件存储在Cassandra日志中。现在我们要通过利用Akka来实现CQRS ...

java akka

回答 1 投票 0

使用流vs角色执行定期任务

我正在使用akka / scala / play堆栈。通常，即时消息使用流来执行某些任务。例如，我有一个流，它每分钟都会醒来，从数据库中拾取某些东西，然后调用另一个...

scala playframework akka actor akka-stream

回答 1 投票 0

Alpakka Consumer不使用通过Docker编写的Kafka发送的消息

我已经通过Docker compose运行了Kafka和Zookeeper。我可以使用Kafka终端向主题发送/使用消息，并且可以通过Conduktor监视所有内容。但不幸的是，我不是...

scala apache-kafka docker-compose akka alpakka

回答 1 投票 2

Alpakka Consumer不使用通过Docker编写的Kafka发送的消息

我已经通过Docker compose运行了Kafka和Zookeeper。我可以使用Kafka终端向主题发送/使用消息，并且可以通过Conduktor监视所有内容。但不幸的是，我不是...

scala apache-kafka akka akka-stream alpakka

回答 1 投票 2

Spring Boot Controller返回一个scala.concurrent.Future的Mono

我正在Spring Boot应用程序中运行Akka actor系统。我有一组演员在跑步。从我的Controller类中，我调用我的服务类，该类使用Actor询问模式，发送一个...

java spring scala akka reactor

回答 1 投票 0

akka http handleNotFound拒绝仅适用于POST方法

我有以下来自https://doc.akka.io/docs/akka-http/current/routing-dsl/rejections.html的akka http拒绝处理代码val message =“找不到所请求的资源。 ” ...

scala akka akka-http

回答 1 投票 0

如何用reactmongo 0.20.3修复akka的兼容性警告

我已将反应性mongo从0.17.1升级到0.20.3。之后，我面对这些警告。 [WARN] [03/17/2020 12：20：43.782] [main] [ManifestInfo（akka：// reactivemongo）]检测到可能的...

scala akka reactivemongo

回答 1 投票 -1

在生命周期示例中未执行Akka postStop

我是akka的新手，我一直在关注文档示例。我已经运行了有关停止actor的生命周期示例，但是输出不包含清理消息。看来这个例子是错误的...

akka actor

回答 1 投票 0

如何观看Akka群集中某个远程演员的死亡？

我正在使用Akka分片群集在多个节点上分配工作负载，并使用context.watchWith（worker）检测子actor的意外终止。看来如果孩子演员...

akka akka-cluster

回答 1 投票 0

Akka Dispatcher线程创建

我一直在研究Akka Actor模型。我有一个用例，其中有1000多个参与者处于活动状态，并且我必须处理这些参与者。我想到了通过...

akka akka-actor akka-dispatcher

回答 1 投票 0

Alpakka和S3截断下载的文件

我有一个简单的代码，基于alpakka的示例，应该从S3下载一些文件以进行进一步处理：S3.download（bucket，file）.runWith（Sink.head）.flatMap {case Some（（。。

scala amazon-s3 akka alpakka

回答 1 投票 0

如何从Akka Streams Sink抛出的异常中恢复？

我如何从Akka Streams接收器引发的异常中恢复？简单示例：Source integerSource = Source.from（Arrays.asList（1、2、3、4、5、6、7、8、9））; ...

java scala akka akka-stream

回答 1 投票 0

Scala akka类型：如何从其实例获取ActorRef到Actor并发送消息本身？

我想从Actor实例（案例类/行为所创建的类）向其Actor发送消息。我通过保存实例来获取它，然后在其中保存ActorRef：val（实例，行为）= ...

scala reference akka actor self

回答 1 投票 1

与elasticmq版本不兼容的Akka-http版本

im试图使用elasticmq-rest-sqs运行sqs服务器：“ org.elasticmq” %%“ elasticmq-rest-sqs”％“ 0.14.7”，我的akka 依赖项是：val akka = Seq（“ com.lightbend .akka“ %%” akka-stream -...

scala playframework akka akka-stream akka-http

回答 1 投票 0

akka 相关问题

最新问题