Akka是一个开源工具包和运行时，简化了JVM上并发和分布式应用程序的构建。它实现了Erlang中已知的actor模型。
是否可以将持久性行为体与路由器一起使用，如扩大规模？如果你有弹性的持久性行为体，你的事件来源就会出现问题。因此，我想知道如何扩展或 ...
我有一个actor，在actor内部被启动，我想模拟actorB，使消息actorB? GetDataForProcessing(value)不会被发送到actorB，我可以测试单元功能。
我试图在我的测试中拦截异常(带异常信息). 我的测试代码： class Test4 extends WordSpec with Matchers with ScalaFutures with ScalatestRouteTest { "should fail if no valid"...。
我使用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...。
intellijscalaplay应用程序未建立 - 端口绑定错误
我无法构建我的scalaplay应用程序。[错误]a.i.TcpListener - Bind failed for TCP channel on endpoint [0.0.0.0:9000] java.net.BindException: 地址已经在使用中：bind at sun.nio...。
我试图运行Akka FSM的示例代码，但我遇到了一些错误 [info] Loading project definition from homeakkafsmproject [info] Loading settings for project root from build.sbt .... [...
我使用Akka HTTP cachedHostConnectionPoolHttps池发送请求作为Akka Streams Flow的一部分： private val requestFlow: Flow[(HttpRequest, HelperClass), Either[Error, String], _] = Http()......
从Cassandra返回有效的JSON数据（Akka HTTP）[重复]
尽管在SELECT语句中使用了JSON标志，但来自Cassandra数据库的数据却以无效的JSON返回。这是我收到的情况。当我的前端接收到这个信息时，它当然会被认为是... ...
如何修改Scala actor返回List[String]？
按照Akka教程https:/doc.akka.iodocsakkacurrenttypedguidetutorial_1.html，我修改了示例代码，每隔3秒发送一条消息给一个akka actor：调度器......。
我想用akka流的方式从S3中消耗一堆文件。S3.listBucket(" "，Some(" ")) .flatMapConcat { r => S3.download("
在actor receive block case中使用符号常数来匹配条件。
我想在actor接收块的情况下使用符号常量来匹配条件。 val str1 = "这只是一个要匹配的演示字符串" val date = OffsetDateTime.parse("some date") def ...
当前代码如下： case object LatestMessageSignal class MessageCheckpoint(implicit ec: ExecutionContext) extends Actor with ActorLogging with Timers { override def receive: Receive = { ...
当前代码如下： case object LatestMessageSignal class MessageCheckpoint(implicit ec: ExecutionContext) extends Actor with ActorLogging with Timers { override def receive: Receive = { ...
如何在Akka Typed中传递来自ActorSystem的自引用？
我想从AKKA的actor中获得回复，但我可以通过Ask方法的帮助获得回复，对象mainTest { val TestTypedSystem.TypedFuncTest]= ActorSystem(...)。ActorSystem[FuncTest.TypedFuncTest] = ActorSystem(...)
我有一个形式的actor： class TestActor(repo: Repo) extends Actor { implicit val executionContext: ExecutionContext = context.dispatcher def receive: Receive = { ... } def ...
无法打开从akka http服务器下载的octet-stream文件。
我创建了一个Akka服务器，当用户发布一些json结构到sever时，服务器会发送文件，但我无法打开服务器发送的文件https:/imgur.comaIZ7JYhV Akka http服务器(POST METHOD) => ...
将JSON作为Akka流中的单个实体处理，而不是对其进行迭代
我正在尝试使用Akka流将消费者与生产者联系起来。 while（true）{JsonNode msg = producer.getNextDataEnvelope（）; if（msg == null）{中断; ...
我有Scala Play应用程序，并且正在像这样的类中调用Scala Akka Scheduler：@Singleton类Foo @Inject（）（actorSystem：ActorSystem，）（隐式executeContext：...
我正在使用具有以下技术的Scala 2.13堆栈：播放！框架2.8 akka输入2.6.3 alpakka kafka 2.0.3 Akka流作业从Kafka读取事件，要求演员计算...
我有一个函数，它将使用CoordinationShutdown流执行一些清理代码。 def shutdown（cs：CoordinatedShutdown，makePhase：CoordinatedShutdown.type =>字符串，名称：String）（f：（...