执行上下文和调度程序-最佳实践，有用的配置和文档
Scala执行上下文和调度程序-列出和比较:为什么? 关于什么/如何/什么是执行Scala中的期货的最佳执行上下文还有很多问题，以及如何配置调度程序.仍然我无法找到包含优缺点和配置示例的更长列表. 我能找到的最好的方法是在Akka文档中: http://doc.akka.io/docs/akka/snapshot/scala/dispatchers.html 和Play文档 https
..
akka相关内容
在Akka actor中使用将来的回调
我在Akka文档中找到了 在使用将来的回调(例如onComplete，onSuccess和onFailure)时，在actor内部，您需要小心避免关闭包含的actor的引用，即，不要从回调内部调用方法或访问封闭actor上的可变状态. 那么这是否意味着我应该始终使用 future pipeTo self 然后调用一些函数?还是我仍然可以将回调函数与方法一起使用，那我应该如何避免并发错误
..
Scala期货和Java 8 CompletableFuture
Java 8中CompletableFutures的引入带来了scala.concurrent.Future中可用的语言功能，例如单数转换. 有什么区别，为什么Scala开发人员应该优先使用Scala Futures而不是Java 8 CompletableFuture? 在Java中通过akka.dispatch网桥使用scala.concurrent.Future还是有充分的理由吗
..
将Scala Future转换为Java Future
我有一个包含方法的生成的Java接口: public Future getCustomersAsync(AsyncHandler asyncHandler); 我想使用Akka来实现它.我写了以下内容: override def getCustomerAsync(asyncHandler: AsyncHandler[Customer]): Future[_
..
将来的并发阻塞在某些情况下无法按预期工作
帮助解释scala未来的两种现象(代码4和代码5中的粗体)，谢谢. 代码1 package com.tst import akka.actor.{Actor, ActorSystem, Props} import scala.concurrent.ExecutionContext.Implicits.global import scala.concurrent.Future clas
..
为什么我的sender()DeadLetters来自计划的邮件?
我正在尝试安排一段时间后要发送的消息-简单的重试. override def receive = { case Worked => ??? case DidNotWork => val target = sender() // Avoid closing over sender(). import context._ context.system.sched
..
使用DeathWatch杀死Akka演员时未发送消息
我正试图在演员被杀后发送消息. 这是基于Akka DeathWatch文档: http://doc.akka.io/docs/akka/2.3.6/java/untyped-actors.html#deathwatch-java 在serviceActor中，我正在等待"kill"消息，但实际上从未发送过此消息.因此，为了在ServiceActor中接收消息，我使用: else
..
Akka升级监督策略制止儿童
我正在尝试OneForOneStrategy策略，该策略升级失败.我的Actor结构是:Supervisor -> Slave，其中Slave是Supervisor的子代. 从站响应2条消息-"失败"(引发异常)和"工作"(进行一些记录) 我的第一个问题是，如果Slave失败，则Supervisor将重新启动(由于升级策略，"Guardian"已将其重新启动)，但是Slave已停止且未
..
Akka Stream的“保持左/右/两者"如何产生不同的输出?
我正在努力解决Keep在Akka流中的工作方式.在保持akka流意味着什么中阅读答案，我了解到它有助于控制我们从实现器的左侧/右侧/两侧获取结果.但是，如果可以更改left/right的值并获得不同的结果，我仍然无法构建示例. 例如， implicit val system: ActorSystem = ActorSystem("Playground") implicit val ma
..
为什么我不能加载org.slf4j.impl.StaticLoggerBinder类
我正在Akka上一个视频课程，但无法正常运行日志记录.我使用IntelliJ.我已经尝试了不同版本的slf4j ...，我有pom.xml
..
TPL数据流和Akka.net有什么区别?
我曾经使用过TPL数据流.真的很喜欢.我从Java/scala朋友那里多次听到过Akka一词，因此我尝试阅读它，并发现akka也具有.net端口.伟大的.当我继续阅读什么是akka时，我惊讶地发现它听起来完全像TPL数据流. 因此，我的问题是，TPL数据流和Akka.net有什么区别? 何时选择什么? 解决方案 Akka是基于参与者的模型，TPL Dataflow也是如此.由于
..
Akka框架的最佳用例是什么
我听说过许多关于 Akka 框架(Java/Scala服务平台)的热衷，但是到目前为止，还没有看到许多用例的实际示例将是有益的.因此，我想听听有关开发人员成功使用它的事情. 只有一个限制:请不要包括编写聊天服务器的情况. (为什么?因为这已被过度用作许多类似事物的示例) 解决方案 到目前为止，我已经非常成功地在两个实际项目中使用了它.两者都位于近实时交通信息领域(交通流量就像高速公路
..
Akka流滑动窗口通过SourceQueue控制减少发射到下沉
更新：我将问题放在测试中项目详细解释我的意思 ======================= ========================================== 我有Akka源代码，可以从数据库表中连续读取数据，并按某个键进行分组，然后减少它。但是，在我应用reduce函数后，数据似乎永远不会发送到接收器，因为上游总是有数据传入，所以它将连续减少。 我阅读了一些
..
使用案例类和参与者键入不匹配（字符串）
当我尝试引用代码时出现某些格式问题，因此，图片如下：（ 此处的图片描述 导入akka。 {actor，ActorSystem，Props} case class Number（n：Int） case class String（s：String） class DoublingActor扩展Actor { def接收：Receive = { case number（n
..
通过演员选择向所有孩子转发消息是否比遍历子ActorRefs更有效？
我有一种情况，当演员收到一条特定的消息时，它必须将该消息转发给当时存在的所有孩子。 我想我有有2个解决方案。 getContext（）。actorSelection（“ *”）。forward（message，getContext（））; 或 getContext（）。getChildren（）。forEach（child-> child.forward（
..
关闭scala.concurrent.Future的onFailure继续未按预期工作
我遇到一个有两个方法的问题，第一个方法在循环中调用第二个方法，第二个方法创建 Future 如下： public class WorkersCoordinator { private static Logger LOGGER = LoggerFactory.getLogger（WorkersCoordinator.class）; 私人最终超时超时； 私人最终ActorSy
..
Scala actor的java.lang.NoSuchMethodError
我有一个简单的Scala应用程序（从此处获取），我想测试一下。 整个项目已使用SBT成功编译。但是，当我使用 sbt测试启动测试时，收到以下错误消息： 无法运行测试ConnectionTest：java.lang.NoSuchMethodError：akka.actor.Props $ .apply（Lscala / Function0;）Lakka / actor / Props;
..
使用JMX控制台进行akka集群的信息和管理
我正在基于akka群集的项目上工作，在该项目中，我必须实现 JMX控制台来管理akka群集。 当我查看 akka文档我得到的信息很少。 然后我尝试查看Java VisualVM，找到了添加如下所示的新jmx连接的选项，那么那里的连接网址应该是什么？我尝试了localhost：8080，但未成功。 解决方案 在应用程序中，还应该配置什么以使JMX控制台到达我的akka群集？
..
SourceQueueWithComplete的Akka流协方差
我有一个从SupervisorActor内部创建的Actor，该Actor负责将其获取的消息推送到流中。这是演员： class KafkaPublisher [T< ;: KafkaMessage：ClassTag]扩展了演员{ 隐式val系统= context.system val日志= Logging（系统，this.getClass.getName） 覆盖最终def接
..
在Akka的两个项目之间共享消息类型
我正在开发一个反应式库，该库在内部使用Akka actor实现。我们将此库称为服务器。该库公开一种类型的Actor作为其API。该Actor接受不同类型的消息，这些消息定义了其公共接口。假设这些消息定义如下。 密封特征请求 案例类Creation（name：String）扩展请求 密封特征响应 案例类CreationAck（name：String）扩展响应 client 。该
..