我想要两个演员交流。我在本地机器上有一个本地系统(客户机),在EC2上有一个远程参与者(服务器)。但是我无法从客户端系统向远程参与者发送消息。 testClient.fs #if INTERACTIVE
#time "on"
#r "nuget: Akka.FSharp"
#r "nuget: Akka.TestKit"
#endif
open System
open Akka.Actor
open Akka.Configuration
open Akka.FSharp
open System.Collections.Generic
l
我尝试移植从Scala角色向Akka角色发送"Ping“和"Pong”的,但我一直收到错误,我想知道这只是一个简单的错误还是一些根本的错误。
考虑下面的代码:
import akka.actor.Actor._
import akka.actor.Actor
case class Message(text: String)
class PingPongActor(name: String) extends Actor {
def receive = {
case Message(msg) =>
println("receive
我面临着向集群提交作业的问题,无论是通过星星之交还是从java代码。作业不断失败,stderr日志(在SPARK_HOME/work/app_id下)始终显示相同的错误:
15/10/08 23:04:39 WARN ReliableDeliverySupervisor: Association with remote system [akka.tcp://sparkDriver@masternode:53411] has failed, address is now gated for [5000] ms. Reason: [Association failed with [akka.tcp
我正在尝试在我正在做的纱线上安装火花作业服务器。
./bin/server_package.sh ec2
当我尝试使用/tmp/jobserver时,这会在./sever_start.sh中形成一个文件夹
我收到这个错误
Uncaught error from thread [JobServer-akka.actor.default-dispatcher-2] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for ActorSystem[JobServer]
Uncaught error fr
我在我的项目中使用akka 2.4-M2。我想把我的项目部署到码头。但是,当我使用boot2docker测试这两个节点时,会出现一个问题。我的节点无法连接到种子节点。
build.sbt中的配置如下:
lazy val `topGatewayFrontend` = (project in file("topGatewayFrontend"))
.enablePlugins(PlayScala)
.enablePlugins(DockerPlugin)
.settings(
name := "topGatewayFrontend",
l
我正在组织一个小的SBT项目,并学习如何使用akka演员。我能够得到一个简单的示例,只使用akka,但是一旦我使用外部库,就会停止工作。我得到了一个非常大的堆栈跟踪
objc[15196]: Class JavaLaunchHelper is implemented in both
/Library/Java/JavaVirtualMachines/jdk1.8.0_131.jdk/Contents/Home/bin/java (0x10cc6c4c0) and /Library/Java/JavaVirtualMachines/jdk1.8.0_131.jdk/Contents/Home
我正在做这样的事情:
...lots of surrounding context...
val actor = context.actorOf(Props(new Actor(...))
(actor ? message) onComplete {
case Done => {
println("done")
Do stuff with the surrounding context of this actor
}
case _ => {
println("got wildcard") // try to handl
我制定了以下代码:
package com.star.wars
import akka.actor._
import akka.actor.SupervisorStrategy._
import akka.util.duration._
object Test extends App {
case object Kill
case object Create
class Luke extends Actor {
var x: Int = 0
println("Luke here")
Thread.sleep(1000)
p
我想要开始使用演员的沉重费率信息。actor的最后一个状态非常重要--我遵循这里显示的持久性示例 --我尝试发送大量消息
for (i <-0 to 100000){
persistentActor ! Cmd("foo"+i)
}
然后像这样使用persistAsync
val receiveCommand: Receive = {
case Cmd(data) =>
persistAsync(Evt(s"${data}-${numEvents}"))(updateState)
case "snap"
我有一个由15个节点/框组成的集群。我大致同时启动节点。其中一个节点的行为古怪且不断地记录“忽略接收到的为他人准备的流言”。但是,在从集群中删除之前,节点似乎工作了一段时间。基本上,这一个节点似乎认为它是其他人,同时也作为自己的行为。代码和配置在所有15个节点上完全相同,所以我不明白为什么只在一个节点上出现这个问题。也许这是硬件问题?
一些伐木:
11:27:45.412 INFO [main] Remoting - Starting remoting
11:27:45.638 INFO [main] Remoting - Remoting started; listening on ad
嗨,我是akka的新手,我试着开发样例akka应用程序,但是当我在shell上执行运行命令时,它会给我未解决的依赖项警告,然后显示错误。
这是我的Main.scala文件
import akka.actor.Actor
import akka.actor.ActorSystem
import akka.actor.Props
class HelloActor extends Actor {
def receive = {
case "hello" => println("hello back at you")
case _
我有以下演员:
val actor1 = context.actorOf(SorterActor.build
.withDispatcher("akka.actor.custom-dispatcher"), name = "actor_child1")
val actor2 = context.actorOf(SorterActor.build
.withDispatcher("akka.actor.custom-dispatcher"), name = "actor_child2")
和执行上下文
implici