我有一个使用akka定义的Route，它使用内部的一个参与者发送消息。AnyWordSpecLike { // my tests here ...编译测试失败，因为存在冲突的参与者系统：[error] implicit def system: akka.actor.
浏览 0提问于2020-03-29得票数 3
我使用的是java akka框架。我的一些演员也会在接收方式上做同样的事情。有没有办法避免这种情况并把他们带到一个共同的地方。(可能正在使用继承)
这在几个类中是重复的。
浏览 2提问于2017-08-31得票数 1
回答已采纳
1回答
对于Spray，我们使用一个自定义初始化类，该类继承自spray.servlet.Initializer，它配置并启动每个参与者。这些行动的一部分是号召大约7或8个其他web服务。因此，我们在主参与者中做了一堆逻辑，它将通信委托给其他参与者，最后它处理所有返回的数据，以及它自己的工作。我想使用Scala和Akka作为一个整体来测试系统，使用Testkit代替通信参与者返回合适的测试数据。
问题分为两
浏览 1提问于2016-04-12得票数 1
1回答
currentOffset)) buffer(data)
这意味着传入和传出消息由同一个参与者处理在“经典”世界中，我可以创建一个线程从套接字中读取，另一个线程用于书写，并同时进行通信。
浏览 2提问于2015-05-05得票数 0
回答已采纳
2回答
我想使用akka的调度器，例子是：但是，没有真正的信息来源于“系统”。文档有点肤浅，有很多变化(akka移出核心scala)。如果我写我将拥有一个ActorSystem，但它将是一个新的独立ActorSystem，大约有8个新线程。我如何才能重复使用现有的游戏框架2系统？谢谢
浏览 1提问于2015-05-08得票数 9
回答已采纳
在我的一个演员里，我创造了一个路由器演员的孩子，就像这样：
一旦创建了BroadcastGroup，就可以操纵它了吗？
浏览 4提问于2017-05-10得票数 0
1回答
我正在使用Scala/Akka编写一个TCP客户端服务器程序。服务器端的一些参与者需要处理来自客户端的TCP消息。我使用(复制的)代码解析收到的TCP消息，并在收到分隔符字符时将消息发送给其他人。由于不止一个actor使用此逻辑，因此我在baseTCP actor中对其进行了抽象，并从中继承了其他actor。我想在这个基础actor中添加通用代码，例如绑定/连接/CommandFailed等的处理。这种处
浏览 4提问于2016-09-13得票数 0
回答已采纳
1回答
在Akka中，除了akka://之外，参与者路径还会有其他前缀吗？如果参与者是远程的，该怎么办？此协议的任何变体，如果是，它们是什么，参与者系统何时使用它们？
浏览 13提问于2019-03-12得票数 1
回答已采纳
2回答
对于scala中当前版本的Actors是否需要Akka，我感到困惑。当我查看：时，我从"Akka是用scala编写的，并且，从Scala 2.10开始，Akka的参与者实现被作为Scala标准库的一部分“这一行中得到了Akka包含在Scala库中的想法。无法访问package中的类型错误项，因为缺少它(或它的依赖项)。检查生成定义中缺少或冲突的依赖项。(使用-Ylog-classpath重
浏览 3提问于2016-09-23得票数 0
回答已采纳
1回答
Akka调度员继承
、、、、
我的场景是:我为主管(父)角色选择了一个非默认的调度程序，其角色是管理(监督)和创建子参与者来完成工作。 /my-parent-actor { }
dispatche
浏览 1提问于2014-11-03得票数 11
回答已采纳
1回答
在一个播放项目中，我启动了一个新演员来处理每个传入的请求： case ex: AskTimeoutException => Ok("timeout expired")} }在myAct
浏览 1提问于2013-11-14得票数 2
回答已采纳
2回答
我正在编写一个Akka应用程序，我想使用Typsafe提供的Akka集群功能。我试图理解Akka集群、Akka集群Singleton和Akka集群切分之间的主要区别。在我的场景中，我希望有一个集群，其中包含：
可以存在于任何机器中的有状态参与者
浏览 2提问于2014-07-29得票数 2
回答已采纳
有人做过akka-camel和scalaz-camel-akka的比较吗？我喜欢scalaz带来的函数式方法，并使用了一些scalaz-camel-akka，但还没有真正使用akka-camel。
浏览 1提问于2012-02-06得票数 2
回答已采纳
我正在用Akka v2.5.23编写一个应用程序。该应用程序涉及以下行为者：
我已经在创建计算器参与者时配置了一个PinnedDispatcher，并将log.info放在了这个参与者类的接收方法中。我在日志文件中搜索，发现与这个log.info相关的所有线程名都是default-dispatcher。我的密码有什么问题吗？在<
浏览 2提问于2020-03-03得票数 0
回答已采纳
我在遵循RockTheJVM (Daniel Rlan)的一个应用程序示例：发布请求-> Akka Http端点-> Actor (询问/管道模式) -> Doobie -> Cassandra
我的
浏览 8提问于2022-06-13得票数 2
回答已采纳
1回答
我正在为akka集群中两个单独的akka微服务/有界上下文之间的通信进行适当的设计。这两种微型服务都以akka为基础。显然，在特定的有限制的上下文中的通信将通过从参与者发送消息到参与者或者从node1上的参与者发送到node2上的参与者(如果有必要的话)来处理。Q:，但是在单独的akka应用程序之间使用类似的通信可以吗？例如有界mes
浏览 0提问于2018-05-11得票数 1
2回答
我正在试着找出最好的方法来触发一个分片集群中特定类型的所有参与者，基于一个时间表(例如，在早上8点，9点，等等-以类似cron的方式)。我的计划是在集群中有一个单独的“计时器”参与者，它将按计划向其他集群的参与者发送广播消息。然而，我不确定这是否可行和最佳。不提供类似cron的配置。似乎不适合Akka集群。有没有可能从分片的Akka集群内部触发基于调度的操作，也许使用其他框架的功能，比如Spring scheduling？或者
浏览 6提问于2020-08-20得票数 1
1回答
就我所理解的Akka文档而言，Akka ActorSystem包含自己的线程池来执行参与者。我在一个也使用Java8期货的Java应用程序中使用Akka；后者由ForkJoinPool.commonPool()执行。因此，参与者和期货使用不同的池，这可能会击败隐藏在两个调度器中的某些假设(例如，Akka调度器可能假定期货在Akka池上运行)。这会造成任何性能问题吗
浏览 3提问于2015-04-08得票数 4
回答已采纳
loop = true } }但是，在这个doesn#t工作中，当我开始轮询器时，参与者只被调用了一次
pollingActor！
浏览 0提问于2013-06-25得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
