我正在使用Play和Akka开发一个微服务原型系统。我的计划是使用Play提供一个公共API，然后将所有工作分派给Akka。在大多数情况下，我希望得到一个对Play API的请求，该请求将被分派到一个远程角色池(在集群中)。我读过一些关于池策略的文章，其中一些看起来很合适，但是我基本上需要在actor处理前一个请求消息(并等待响应)时，将其从接收
浏览 3提问于2018-02-15得票数 0
1回答
我刚刚开始，Akka和我试着理解演员池和团体之间的区别，以及什么时候使用哪一个。在中，它简短地指出，一个组不是由路由器创建的，所以这意味着它们没有主服务器？在下面的情况下，您可以直接从一个员工组(或池)路由消息吗？却不通过师父寄给另一个人？
浏览 5提问于2015-03-12得票数 5
回答已采纳
3回答
Akka参与者消息需要内存池
、、、、
我是新来的爪哇人。我是c++程序员，现在学习java已经2个月了。抱歉，我的泳池英语。
我有一个问题，如果它需要内存池或对象池的Akka演员模型。我认为，如果我从一个参与者发送一些消息给另一个参与者，我必须分配一些堆内存(就像新的一些字符串，或者一些新的BigInteger等等)。随着时间的推移，垃圾收集器将被启动(我不确定它是否会启动)，这会使我的</e
浏览 10提问于2017-05-18得票数 0
回答已采纳
1回答
在“我的主管参与者”中，子参与者发送一条消息以指示其已完成。然后在onReceive方法中停止这个参与者：public void onReceive(Object msg) {
if (msg == Messages.SUCCESS-6] [akka://Main/user/app/$l] Message [akka.dispatch.sysmsg.Terminate] from Actor[akka:&#x
浏览 4提问于2014-10-24得票数 2
回答已采纳
2回答
我有一个第三方API，利用线程。我正在使用Play框架进行编码，并希望使用Akka来实现ASYC功能并实现实时结果。但我不确定将Akka与使用线程的API集成是否有意义。第三方接收消息，使用线程执行命令，并做任何需要做的事情。我不是真的担心它是怎么做的。只是指出它使用线程。
请您分享Akka在这个用例中可以创造价
浏览 2提问于2012-10-19得票数 0
2回答
我有一个由两个参与者组成的系统，它们共享相同的配置。所需的配置是：“邮箱的最大容量应为1邮件，任何溢出的消息都应被丢弃”。akka.actor.default-mailbox {
mailbox-type = "akka.dispatch.BoundedMailbox&quo
浏览 2提问于2013-11-06得票数 1
回答已采纳
从我从“Actors in Scala”文本中读到的关于Actors的内容来看，我有一个问题，这个问题在文本中似乎没有被很清楚地解决。我目前正在一台具有多核处理器的单机上对我的程序进行建模，并在Master-Workers模型中使用基于事件的参与者。现在，在以下两种设计选择中，哪一种可以使所有处理器核心都得到最佳利用？1)将演员的数量限制在一个小的固定数量，而不管
浏览 1提问于2012-09-04得票数 3
回答已采纳
我是scala演员编程的新手。我在学习的时候遇到了一些问题。请帮帮我。Q2。akka演员适合在线服务系统吗？据我所知，在参与
浏览 1提问于2014-08-07得票数 2
1回答
我知道这是一个非常不准确的问题，可能被认为不适合堆叠溢出。不幸的是，较小的应用程序(就参与者的数量而言)和“类似教程”的应用程序不能帮助我开发关于消息分派开销的直觉，以及“scala对象”和“CORBA对象”之间的快速粒度点。虽然几乎可以肯定地保持与客户端的对话状态(例如，应该有一个参与者)，但在大多数实际用例中，它将涉及由许多类建模的条件/并行/替代交互。这使
浏览 2提问于2016-02-05得票数 12
回答已采纳
这种组成部分的一个例子可以是席位分配部分。
我的导师让我看看OSGi。松散耦合的捆绑的想法当然是有吸引力的。在寻找替代品的时候，我发现了阿克卡。这个框架承诺了很多事情，比如可伸缩性和高性能。我想知道Akka的演员概念是否适合我的可修改性要求。Akka似乎比OSGi更有效率，所以开发速度会更快。Akka似乎也更适
浏览 7提问于2013-11-21得票数 2
回答已采纳
我希望使用一个参与者来同步对对象池的访问。参与者将管理池中的对象，包括它们的状态(繁忙的vs..s.免费分配)。当ask由非参与者代码编辑时，一旦可用，它就会从池中返回一个对象.因此，调用代码具有用于获取要处理的对象的抽象。要获得这种抽象，我需要参与者能够用参与者分配给他们的对象来响应其消息发送者的ask消息。这能实现吗?通过消息传递整个对象是否需要大量的资源？
浏览 2提问于2014-12-06得票数 2
回答已采纳
1回答
参与者初始化连接到websocket的Akka流。这是通过使用可以发送消息的Source.actorRef来完成的，然后由webSocketClientFlow处理这些消息并由Sink.foreach使用。在以下代码(从派生)中可以看到这一点：
class TestActor @Inject()(implicit ec: ExecutionContext) extends Actor with ActorLogging这是否意味着我需要手动关闭流，例如，将用Source
浏览 1提问于2017-09-30得票数 1
回答已采纳
我在我的play框架(带有akka)应用程序中使用了rxjava可观察性(v1.1.8)。我想知道是否有一种方法可以将MDC信息传播到rxjava观察点。我在我的日志语句中看不到MDC信息，这些语句在Observable/Subscriber中打印。我知道rxJava使用单独的线程池，并且需要有一种机制将MDC信息从akka线程复制到rxjava线程中。对此有解决方案吗？仅供参考，
浏览 3提问于2017-07-25得票数 3
1回答
我正在使用Akka Actors，我正在尝试更新我的代码以使用最新的2.0里程碑。API发生了一些变化，例如，Actors的创建现在通过一个名为ActorSystem的工具工作。启动和停止参与者也发生了变化-后者可以通过ActorSystems方法.stop(..)和.shutdown()获得。但我一辈子都想不出怎么开始.文档很好，但似乎遗漏了一些要点。我觉得问这个问题有点愚蠢，但是你是如何在Akka 2.0环境中开始演员</
浏览 3提问于2011-12-29得票数 14
回答已采纳
1回答
Akka持久性-力量重播
、、、
我的应用程序需要记录由一个参与者处理的所有消息，有时还需要在minSequenceNr和maxSequenceNr之间重播消息。
对于这个用例，akka持久化是一个好的选择吗？如果是，我如何才能强制重播日记中的信息？我可以使用Persistence(actorSystem).journalFor("x")获取日记的ActorRef，但是我不能将JournalProtocol.ReplayMessa
浏览 3提问于2014-07-17得票数 3
回答已采纳
2回答
我正在创建一个RESTful API，其中包含了Spin1.2.0和Akka2.2.3。Scala版本为2.10 (如果有必要，所有这些版本都可以更改)。在我的业务层中，我必须通过SSH连接与遗留系统进行通信。这些连接需要很长时间(1-3分钟)才能建立起来，如果它们空闲时间太长，就会过期。我在一个测试应用程序上分别编写了SSH代码，现在我已经将它封装在了一个演员中。
我如何指定一个SSH参与者池，该
浏览 2提问于2014-09-23得票数 1
回答已采纳
据我所知，线程池是一个在等待模式下重用已创建的线程并为其分配任务的进程。此类线程的数量是在池创建期间指定的。那么，EventQueue是一种在AWT中完成的</
浏览 16提问于2017-06-21得票数 0
回答已采纳
1回答
阿克卡的演员被阻止了
、、、、
我使用akka演员来实现一些http请求的并行处理。Sendernull发送"com.data.model.Request“类型的消息。
public void postStop() {}
现在，我可以从日志中看到演员们被阻止了。一旦池中的所有演员</e
浏览 0提问于2018-07-25得票数 1
1回答
我有相当多的Apache Camel (路由/中介/orchestation引擎；轻量级ESB)的经验，并且绞尽脑汁试图理解Akka之间的区别：
调度程序是：
...is是什么使阿克卡演员“滴答”，它是机器的发动机可以说。但这并不能真正解释调度
浏览 3提问于2015-06-04得票数 11
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
