akka 相关问题

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

在Akka Sharding上启动时初始化实体

如何在集群启动时预启动实体？我已经找到了一种方法，但是我认为这不是正确的方法。它包括将StartEntity（entityId）消息发送到...

scala akka sharding akka-cluster

回答 1 投票 0

Scala和Akka HTTP：读取具有多个字段的有效负载

我正在尝试在Akka HTTP中创建一个HTTP请求，该请求将能够通过HTTP请求发送两个字符串“ string1”和“ string2”。我目前有以下代码可以处理简单的...

scala akka akka-http

回答 1 投票 0

Akka中调度程序与路由器之间的差异

我正在浏览Akka文档和其他Wiki。谁能告诉我Akka框架中的Dispatcher＆Routers有什么区别？

akka

回答 1 投票 3

Actor消息分配给调度程序线程

已知分派器线程负责执行参与者消息。使用吞吐量参数，我们可以定义no。由调度程序线程处理的消息，然后再移至另一个...

akka akka-actor akka-dispatcher

回答 1 投票 0

如何在运行时使用application.conf更改akka Actors日志级别

如何设置application.conf使其能够在运行时更改akka logLevel？我可以设置任何属性吗？我正在使用slf4j和logback作为后端。我刚刚设置了logback.xml：

logging akka logback slf4j application.conf

回答 1 投票 0

Akka流：使用OverflowStrategy.fail（）模拟失败的流

我是Akka和Akka流的新手。我创建了一个虚拟流，并希望它以异常结束，因为我的map（）函数非常慢，并且我将缓冲区设置为1。所以我的问题分为两部分：为什么...

java akka akka-stream

回答 1 投票 0

akka ActorSystem进程如何从actor接收

我如何使进程使用ActorOf创建Actor，并允许Actor ping父进程。我的目的是允许参与者将信号发送到其父进程（ActorSystem主线程）以调用...

scala akka actor actorsystem

回答 1 投票 0

为什么AKKA TypedActor类具有两个具有相同签名的方法？

在使用TypedActor.get（system）intellij拼写错误“歧义方法调用”时，此处系统的类型为ActorSystem。我在TypedActor类文件的反编译源代码中发现有两个...

java akka

回答 1 投票 0

将Akka流传递到上游服务以进行填充

我需要调用上游服务（Azure Blob服务）以将数据推送到OutputStream，然后需要通过akka转过来并将其推送回客户端。没有akka（只有servlet代码）...

java stream akka akka-stream

回答 1 投票 6

在Akka类型演员中创建调度程序/计时器

我正在尝试在我的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 相关问题

最新问题