akka 相关问题

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

使用akka-typed，我试图创建一个事件来源的应用程序，在这个应用程序中，对一个actor的命令可以对另一个actor造成影响。具体来说，我有以下情况。RootActor BranchActor...

akka cqrs event-sourcing akka-typed

回答 1 投票 0

我使用Scala v2.13.1和AKKA HTTP v10.1.11。我有一个路由，结构如下： def foo(a: String): Directive1[String] = { provide(a) } def bar(a: String): Directive1[String] = { ...

scala rest akka akka-http

回答 1 投票 1

Alpakka Kafka流永远不会被终止。

我们使用Alpakka Kafka流来消费Kafka的事件。下面是流的定义。ConsumerSettings consumerSettings = ...

apache-kafka akka akka-stream alpakka

回答 1 投票 0

如何放大或缩小持久性角色，以提高吞吐量？

是否可以将持久性行为体与路由器一起使用，如扩大规模？如果你有弹性的持久性行为体，你的事件来源就会出现问题。因此，我想知道如何扩展或 ...

akka

回答 1 投票 1

模拟角色及其在单元测试中的响应。

我有一个actor，在actor内部被启动，我想模拟actorB，使消息actorB? GetDataForProcessing(value)不会被发送到actorB，我可以测试单元功能。

scala mocking akka scalatest akka-testkit

回答 1 投票 1

如何在未来的scalatest中拦截异常？

我试图在我的测试中拦截异常(带异常信息). 我的测试代码： class Test4 extends WordSpec with Matchers with ScalaFutures with ScalatestRouteTest { "should fail if no valid"...。

scala playframework akka scalatest

回答 1 投票 0

AKKA型SLF4J NOP警告。

我使用AKKA Typed 2.6.5和AKKA HTTP......得到以下错误SLF4J: No SLF4J providers were found. SLF4J: Defaulting to no-operation (NOP) logger implementation SLF4J: See http:/www.slf4j...。

akka slf4j akka-http

回答 1 投票 0

intellijscalaplay应用程序未建立 - 端口绑定错误

我无法构建我的scalaplay应用程序。[错误]a.i.TcpListener - Bind failed for TCP channel on endpoint [0.0.0.0:9000] java.net.BindException: 地址已经在使用中：bind at sun.nio...。

scala intellij-idea akka playframework-2.6

回答 1 投票 1

对象testkit不是包akka的成员。

我试图运行Akka FSM的示例代码，但我遇到了一些错误 [info] Loading project definition from homeakkafsmproject [info] Loading settings for project root from build.sbt .... [...

scala akka akka-fsm

回答 1 投票 1

Akka HTTP错误响应实体在1秒后未被订阅。

我使用Akka HTTP cachedHostConnectionPoolHttps池发送请求作为Akka Streams Flow的一部分： private val requestFlow: Flow[(HttpRequest, HelperClass), Either[Error, String], _] = Http()......

http request akka subscribe

回答 1 投票 0

从Cassandra返回有效的JSON数据（Akka HTTP）[重复]

尽管在SELECT语句中使用了JSON标志，但来自Cassandra数据库的数据却以无效的JSON返回。这是我收到的情况。当我的前端接收到这个信息时，它当然会被认为是... ...

json scala cassandra akka akka-http

回答 1 投票 0

如何修改Scala actor返回List[String]？

按照Akka教程https:/doc.akka.iodocsakkacurrenttypedguidetutorial_1.html，我修改了示例代码，每隔3秒发送一条消息给一个akka actor：调度器......。

scala akka

回答 1 投票 0

当使用akka流从S3消耗文件时出现超时异常。

我想用akka流的方式从S3中消耗一堆文件。S3.listBucket(" "，Some(" ")) .flatMapConcat { r => S3.download("

scala akka akka-stream akka-http alpakka

回答 1 投票 0

在actor receive block case中使用符号常数来匹配条件。

我想在actor接收块的情况下使用符号常量来匹配条件。 val str1 = "这只是一个要匹配的演示字符串" val date = OffsetDateTime.parse("some date") def ...

scala akka

回答 1 投票 0

如果一个Actor在一段时间内没有收到消息，如何关闭它？

当前代码如下： case object LatestMessageSignal class MessageCheckpoint(implicit ec: ExecutionContext) extends Actor with ActorLogging with Timers { override def receive: Receive = { ...

scala akka actor

回答 1 投票 0

如果一个Actor在一段时间内没有收到消息，如何关闭它？

当前代码如下： case object LatestMessageSignal class MessageCheckpoint(implicit ec: ExecutionContext) extends Actor with ActorLogging with Timers { override def receive: Receive = { ...

scala akka actor

回答 2 投票 0

如何在Akka Typed中传递来自ActorSystem的自引用？

我想从AKKA的actor中获得回复，但我可以通过Ask方法的帮助获得回复，对象mainTest { val TestTypedSystem.TypedFuncTest]= ActorSystem(...)。ActorSystem[FuncTest.TypedFuncTest] = ActorSystem(...)

scala akka

回答 1 投票 0

单元测试AKKA演员方法

我有一个形式的actor： class TestActor(repo: Repo) extends Actor { implicit val executionContext: ExecutionContext = context.dispatcher def receive: Receive = { ... } def ...

scala akka akka-testkit

回答 1 投票 0

无法打开从akka http服务器下载的octet-stream文件。

我创建了一个Akka服务器，当用户发布一些json结构到sever时，服务器会发送文件，但我无法打开服务器发送的文件https:/imgur.comaIZ7JYhV Akka http服务器(POST METHOD) => ...

javascript reactjs scala akka akka-http

回答 1 投票 0

将JSON作为Akka流中的单个实体处理，而不是对其进行迭代

我正在尝试使用Akka流将消费者与生产者联系起来。 while（true）{JsonNode msg = producer.getNextDataEnvelope（）; if（msg == null）{中断; ...

java akka akka-stream

回答 1 投票 -1

akka 相关问题

最新问题