首页 文章
  • 72 votes
     answers
     views

    什么's the difference of the Akka'的演员与Scala的演员模型

    我发现还有一个Akka演员模型,所以我想知道Akka的演员和Scala的演员模特之间有什么区别?
  • 12 votes
     answers
     views

    Akka演员,期货和关闭

    我在Akka docs中读到,关闭封闭演员的变量是危险的 . 警告在这种情况下,您需要小心避免关闭包含actor的引用,即不要在匿名Actor类中调用封闭actor上的方法 . 这会打破actor封装,并可能引入同步错误和竞争条件,因为其他actor的代码将同时调度到封闭的actor . 现在,我有两个演员,其中一个从第二个请求某些东西,并对结果做了一些事情 . 在下面的这个例子中,我放在一起...
  • 0 votes
     answers
     views

    Scala期货在演员中创造无限线索

    我在actor中使用future和timeout来避免系统等待多长时间执行命令: val _output = future { "myCommand.sh" !! } output = try { Await.result(_output, 3 minutes) } catch { case e: TimeoutException => { ...
  • 0 votes
     answers
     views

    为什么这个Scala actor代码需要阻塞才能工作?

    对于练习面试,我的朋友让我在规定的时间内与Scala演员实施合并排序 . 代码最终看起来像这样: https://dl.dropboxusercontent.com/u/214507961/MergeActor.scala 基本上,应用程序将这样开始: import akka.pattern.ask import akka.util.Timeout import scala.concurrent....
  • 1 votes
     answers
     views

    斯卡拉懒惰的问题

    我有一个场景,我有一些对象需要互相参考 . 我可以编译的唯一方法是使用 lazy class A(b:B) class B(a:A) lazy val a:A = new A(b) lazy val b:B = new B(a) 我可以使用一些演员做同样的事情,并让它也编译 abstract class Message case class Message1 extends Messag...
  • 7 votes
     answers
     views

    Akka 2.1最小远程演员的例子

    EDIT 注意,我需要对此https://github.com/akka/akka/commit/ce014ece3568938b2036c4ccfd21b92faba69607#L13L6进行相反的更改,以使接受的答案与AKKA 2.1一起使用,这是在akkas主页上找到的稳定分布! 我已经阅读了所有可以在AKKA上找到的教程,但我发现的任何内容都没有“开箱即用” . 使用eclipse,我想...
  • 1 votes
     answers
     views

    在 生产环境 中运行Lagom

    我正在制作一个 生产环境 中的Lagom应用程序 . 我曾尝试联系Lightbend获取ConductR许可,但多年没有收到回复 . 所以,现在我正在寻找另一种方法 . 我有很多问题 . 由于现在应用程序的规模非常小,我认为现在使用静态服务定位器对我有用(对其他替代方案开放) . 此外,我使用MySQL作为我的事件存储而不是Cassandra的默认配置(与此线程无关的原因) . 为了压制Cassa...
  • 13 votes
     answers
     views

    在Akka演员中使用Futures

    我刚刚开始学习Scala中的Akka Actors . 我的理解是,Actor接收的消息在Actor的邮箱中排队,并且一次处理一个 . 通过一次处理一个消息,可以减轻并发问题(竞争条件,死锁) . 但是如果Actor创建了一个与消息相关的工作的未来会发生什么?由于未来是异步的,因此Actor可以开始处理接下来的几条消息,而与先前消息相关联的未来仍然在运行 . 这不会产生竞争条件吗?如何在Actor...
  • 0 votes
     answers
     views

    期货与阿卡的演员一起使用

    我想使用akka远程处理创建服务器/客户端系统 . 首先,我创建一个简单的远程服务器 . (我为了测试目的编写了下面的代码,并澄清了我的概念,所以它确实没有做太多 . ) 我希望我的客户端向服务器发送用户名和密码,服务器可以验证并回复 . 起初我创建了一个客户端角色 . 从我的客户端对象,我发送此演员的用户名和密码(我在这里使用未来) . 然后,客户端actor使用另一个未来将此用户名和密码发送...
  • 0 votes
     answers
     views

    Akka:演员沟通的未来?

    我有一个系统可以产生一个会产生许多未来的演员 . 其中一些未来会遇到需要产生更多期货的情景(但请告诉演员) . 在完成未来的操作后,如何将未来的消息发送给演员? 我查看了 pipeTo 文档但是我在将来的课程中引用系统中的actor时遇到了问题 . 这是我的Future类的样子: class crawler(string: String) { val status: Future[Boole...
  • 15 votes
     answers
     views

    睡觉的演员?

    让演员入睡最好的方法是什么?我将演员设置为代理,希望维护数据库的不同部分(包括从外部源获取数据) . 由于多种原因(包括没有超载数据库或通信和一般负载问题),我希望演员在每个操作之间休眠 . 我正在看10个演员对象 . 演员将无限运行,因为总会有新数据进入,或者坐在表中等待传播到数据库的其他部分等 . 想法是让数据库在任何时候都尽可能完整及时 . 我可以通过无限循环执行此操作,并在每个循环结束时进...
  • 3 votes
     answers
     views

    Scala actor:receiveWithin()不接收消息

    我正在Scala中构建一个基于actor的服务,消费者可以在其中查询客户端是否已获得授权并且还可以授权客户端 . 如果消费者查询客户端的授权状态并且该客户端尚未被授权,则该actor应该在指定的超时内等待传入的消息,然后发送回复 . IsAuthorized 应该能够在消费者代码中同步执行,以便阻止并等待回复 . 就像是 service !? IsAuthorized(client) =&gt...
  • 1 votes
     answers
     views

    Scala actor,期货和系统调用导致Thread泄漏

    我正在运行一个复杂的软件与不同的演员(scala演员) . 其中一些执行使用scala future来避免锁定并继续处理新收到的消息(简化代码): def act { while (true) { receive { case (code: String) => val codeMatch = future { match_code(c...
  • 14 votes
     answers
     views

    在处理Akka中的下一条消息之前等待异步Future调用

    接收事件时,Akka Actors将一次处理一条消息,阻塞直到请求完成,然后再转到下一条消息 . 这适用于同步/阻塞任务,但是如果我想执行异步/非阻塞请求,Akka将继续处理而无需等待任务完成 . 例如: def doThing():Future[Unit] = /* Non blocking request here */ def receive = { case DoThing ...
  • 0 votes
     answers
     views

    在Scala中实现没有Akka的Actor模型

    我正在做我的小型研究,实现没有Akka的Actor我在Scala中找到了一个Actor的实现 . (How to implement actor model without Akka?) 这很简单 . 因为我没有足够的声誉来添加评论,所以我创建了这个问题 . 我想知道我是否使用如下的Actor . 1 /如何从主线程中关闭该actor? 2 /如何添加类似于Akka的功能,如父演员,杀戮请求,并...
  • 2 votes
     answers
     views

    无法使用akka java api的UnTypedActorFactory创建actor

    我试图用无类型的演员工厂创建一个演员,编译很好 . 但是在运行应用程序时,我收到以下错误 . 我在配置中遗漏了什么吗? Java代码: MyActor myactor = new MyActor(); //MyActor extends UnTypedActor ActorSystem system = ActorSystem.create("mynamespace"); A...
  • 2 votes
     answers
     views

    Akka邮箱配置异常

    当我按照Akka文档在Akka actor中配置优先级邮箱时,它会抛出一个异常,说明没有配置邮箱 . 困难的部分是这个有时有效,但是一旦我改变了与此无关的东西(只是注释和日志),然后重新打包它,它可能会抛出异常 . 这可能是由另一个重新打包和部署修复的 . 这是我的application.conf: akka { prio-mailbox { mailbox-type = "com...
  • 4 votes
     answers
     views

    将简单的Scala远程actor示例移植到Akka actor

    我尝试将从Scala演员发送"Ping"和"Pong"的this simple actor example移植到Akka演员,但我不断收到错误,我想知道这只是一个简单的错误还是一些基本错误 . 考虑以下代码: import akka.actor.Actor._ import akka.actor.Actor case class Message(text:...
  • 3 votes
     answers
     views

    Akka 2.1 Remote:跨系统共享actor

    我正在学习Akka 2.1中的远程演员,我试图改编counter example provided by Typesafe . 我从控制台实现了一个快速的'n'脏UI来发送滴答声 . 并且询问(并显示结果)当前计数 . 我们的想法是启动一个主节点,它将运行Counter actor和一些客户端节点,它将通过远程处理向它发送消息 . 但是,我想通过配置和对代码的最小更改来实现这一点 . 因此,通过更...
  • 2 votes
     answers
     views

    在没有新的ActorSystem的情况下远程创建一个Akka actor

    我现在已经多次阅读文档(http://doc.akka.io/docs/akka/2.1.4/scala/remoting.html)并通过这里的示例(https://github.com/akka/akka/tree/master/akka-samples/akka-sample-remote)和其他人,我仍然可以发现这是:how to start remote actors in scala,...
  • 6 votes
     answers
     views

    Akka远程actor,超类没有默认构造函数

    我正在尝试使用akka远程actor发送消息,其中case类是在其构造函数中获取参数的超类的子类 . 以下是重现问题的最小示例: package com.tuvistavie.testremote import akka.actor.{ Actor, ActorSystem, Props, ActorLogging } import com.typesafe.config.ConfigFacto...
  • 0 votes
     answers
     views

    Dart远程隔离像远程akka演员

    飞镖中是否存在像akka remote actors类似的远程隔离物? 我不是在谈论从spawnUri那里产生来自远程位置的* .dart文件的隔离 . 我试图找出远程计算机中是否可以运行隔离,您可以通过网络传递消息并从中获取响应 .
  • 1 votes
     answers
     views

    Scala远程演员示例 - Eclipse

    我使用此链接中给出的示例代码来实现scala远程应用程序:https://stackoverflow.com/a/15367735/1932985 我得到以下输出:服务器输出: akka://GreetingSystem/user/joe Server ready joe received local msg! from Actor[akka://GreetingSystem/deadLetter...
  • 9 votes
     answers
     views

    阿卡的分布式演员

    我是Akka的新手,也是分布式编程的新手 . 使用Akka的Mist组件,我创建了受监督的actor来异步处理HTTP请求 . 目前一切都在当地演员的一台物理机器上运行 . 我不明白的是如何构建一个具有多个盒子的真正容错系统 . 正如Akka文档中所述: 此外,您(通常)需要知道一个盒子是否关闭和/或您在另一个盒子上正在与之通话的服务是否已关闭 . 这里的actor监督/链接是一个关键工具,不仅...
  • 91 votes
     answers
     views

    Node.js如何使系统与Akka的演员模式不同?

    我和_521191一起工作了一段时间,认为自己对Java非常好 . 但我刚刚发现 Akka 并立即对其演员模式感兴趣(据我所知) . 现在,假设我的JavaScript技能与我的Scala / Java技能相当,我想专注于任一系统的实用性 . 特别是在Web服务方面 . 据我所知,Node非常适合处理许多并发操作 . 我认为,资产管理系统的一个好的Node Web服务可以很好地处理许多同时提交更改...
  • 62 votes
     answers
     views

    构建基于Actor的系统的设计模式/最佳实践

    我正在努力寻找任何适当的链接来设计模式,最佳实践或良好的基本架构原则,这些原则应该用于构建基于Actor的应用程序 . 我知道的那几个是: 博客文章,文章,WIKI,指南 OTP Design Principles User's Guide Patterns and Best Practices for Enterprise Integration(一般情况下,可以应用于任何消息驱动架构)...
  • 3 votes
     answers
     views

    Akka路由:回复发送到路由器最终为死信

    我正在玩Actor Routing并且我无法将回复发送回路由器,以便路由列表中的另一个演员可以选择这个,我在这里看不到什么;) 我正在使用: sender.tell([Message], context.parent) 根据akka docs回复路由器,路由的actor将发送者设置为自己,父母是实际的路由器 回复时,它会在控制台中给出以下消息: [INFO] [12/13/2013 11:19...
  • 0 votes
     answers
     views

    如何在Play Framework 2中从外部向演员发送消息?

    我是Akka的新手,并尝试在Java中使用Play Framework 2编写一些代码并使用Akka . 要创建一个actor并向其发送测试消息,我有: public class Global extends GlobalSettings { @Override public void onStart(Application app) { final ActorR...
  • 2 votes
     answers
     views

    喷洒死信

    我正在尝试执行以下代码 trait CustomHttpService extends HttpService { import MyJsonProtocol._ import spray.httpx.SprayJsonSupport._ implicit def executionContext = actorRefFactory.dispatcher implicit va...
  • 7 votes
     answers
     views

    什么基于actor的Web框架可用于Scala?

    我需要构建非常并发的Web服务,它将为JavaScript(前端)和Rails(后端)公开基于REST的API . Web服务将适合MongoDB的数据访问API . 我已经使用NodeJS编写了一个初始实现,并希望尝试基于Scala的解决方案 . 我也在考虑Erlang,每个Web框架都是基于actor的 . 所以我正在寻找使用Actors显式构建的Web框架,以支持大量的请求,我对Scala...

热门问题