scala akka actor akka-cluster

scala - Los nodos semilla del cluster akka dan error: mensaje de descarte para un destinatario no local



actor akka-cluster (1)

Parece que sus nodos semilla están usando ClusterSystem como el nombre del sistema del actor, pero de acuerdo con sus registros están usando AdriansClusterSystem como el nombre del sistema de su actor. Intenta cambiar los nodos de semilla a:

seed-nodes = [ "akka.tcp://AdriansClusterSystem@127.0.0.1:2551", "akka.tcp://AdriansClusterSystem@127.0.0.1:2552"]

Estoy tratando de crear un clúster akka básico en una máquina con Win 7 a partir de esta documentación:
http://doc.akka.io/docs/akka/snapshot/scala/cluster-usage.html

y me aparece un error cuando ejecuto los nodos semilla (más sobre ellos más adelante)

AdriansClusterSystem-akka.actor.default-dispa tcher-16] [akka: // AdriansClusterSystem / system / endpointManager / reliableEndpointWr iter-akka.tcp% 3A% 2F% 2FAdriansClusterSystem% 40127.0.0.1% 3A2552-3 / endpointritererer] class akka.actor.SelectChildName] para el destinatario no local [Act o [akka.tcp: //ClusterSystem@127.0.0.1: 2552 /]] que llega a [akka.tcp: // ClusterSys tem@127.0.0.1: 2552] las direcciones de entrada son [akka.tcp: //AdriansClusterSystem@127.0 .0.1: 2552]

Pregunta: ¿Por qué estoy recibiendo este error? ¿Me perdí algo de la documentación de akka?

Mi archivo .conf:
Agregué esta línea adicional * Al archivo listado en la URL anterior * enabled-transports = ["akka.remote.netty.tcp"]

akka { actor { provider = "akka.cluster.ClusterActorRefProvider" } remote { enabled-transports = ["akka.remote.netty.tcp"] <--added this from remoting log-remote-lifecycle-events = off netty.tcp { hostname = "127.0.0.1" port = 0 } } cluster { seed-nodes = [ "akka.tcp://ClusterSystem@127.0.0.1:2551", "akka.tcp://ClusterSystem@127.0.0.1:2552"] auto-down = on } }

Comienzo los 2 nodos, cada uno en diferentes ventanas sbt

run-main sample.cluster.simple.SimpleClusterApp 2551 run-main sample.cluster.simple.SimpleClusterApp 2552

Ambos comienzan bien y luego muestran repetidamente un mensaje de ERROR :

mybuild:-:0.0.1-SNAPSHOT>`run-main sample.cluster.simple.SimpleClusterApp 2552` [warn] Credentials file C:/Users/amocanu/.ivy2/.credentials does not exist <-- ? [info] Running sample.cluster.simple.SimpleClusterApp 2552 args[0]= 2552 [INFO] [07/31/2013 10:50:00.397] [run-main] [Remoting] Starting remoting [INFO] [07/31/2013 10:50:00.661] [run-main] [Remoting] Remoting started; listeni ng on addresses :[akka.tcp://AdriansClusterSystem@127.0.0.1:2552] [INFO] [07/31/2013 10:50:00.710] [run-main] [Cluster(akka://AdriansClusterSystem )] Cluster Node [akka.tcp://AdriansClusterSystem@127.0.0.1:2552] - Starting up.. . [INFO] [07/31/2013 10:50:00.823] [run-main] [Cluster(akka://AdriansClusterSystem )] Cluster Node [akka.tcp://AdriansClusterSystem@127.0.0.1:2552] - Registered cl uster JMX MBean [akka:type=Cluster] [INFO] [07/31/2013 10:50:00.823] [run-main] [Cluster(akka://AdriansClusterSystem )] Cluster Node [akka.tcp://AdriansClusterSystem@127.0.0.1:2552] - Started up su ccessfully [INFO] [07/31/2013 10:50:00.868] [AdriansClusterSystem-akka.actor.default-dispat cher-2] [Cluster(akka://AdriansClusterSystem)] Cluster Node [akka.tcp://AdriansC lusterSystem@127.0.0.1:2552] - Metrics will be retreived from MBeans, and may be incorrect on some platforms. To increase metric accuracy add the ''sigar.jar'' to the classpath and the appropriate platform-specific native libary to ''java.libr ary.path''. Reason: java.lang.ClassNotFoundException: org.hyperic.sigar.Sigar [INFO] [07/31/2013 10:50:00.874] [AdriansClusterSystem-akka.actor.default-dispat cher-2] [Cluster(akka://AdriansClusterSystem)] Cluster Node [akka.tcp://AdriansC lusterSystem@127.0.0.1:2552] - Metrics collection has started successfully [INFO] [07/31/2013 10:50:00.883] [AdriansClusterSystem-akka.actor.default-dispat cher-13] [akka://AdriansClusterSystem/user/clusterListener] Current members: [ERROR] [07/31/2013 10:50:01.003] [AdriansClusterSystem-akka.actor.default-dispa tcher-3] [akka://AdriansClusterSystem/system/endpointManager/reliableEndpointWri ter-akka.tcp%3A%2F%2FAdriansClusterSystem%40127.0.0.1%3A2551-0/endpointWriter] d ropping message [class akka.actor.SelectChildName] for non-local recipient [Acto r[akka.tcp://ClusterSystem@127.0.0.1:2552/]] arriving at [akka.tcp://ClusterSyst em@127.0.0.1:2552] inbound addresses are [akka.tcp://AdriansClusterSystem@127.0. 0.1:2552] [ERROR] [07/31/2013 10:50:01.009] [AdriansClusterSystem-akka.actor.default-dispa tcher-16] [akka://AdriansClusterSystem/system/endpointManager/reliableEndpointWr iter-akka.tcp%3A%2F%2FAdriansClusterSystem%40127.0.0.1%3A2552-3/endpointWriter] dropping message [class akka.actor.SelectChildName] for non-local recipient [Act or[akka.tcp://ClusterSystem@127.0.0.1:2552/]] arriving at [akka.tcp://ClusterSys tem@127.0.0.1:2552] inbound addresses are [akka.tcp://AdriansClusterSystem@127.0 .0.1:2552]

Si ahora lo hago

run-main sample.cluster.simple.SimpleClusterApp

que se supone que elige un puerto aleatorio y ejecuta un nodo semilla, se inicia bien así como los otros 2 nodos semilla, luego muestra una excepción de clase no encontrada como INFO y no hay miembros actuales

[INFO] [07/31/2013 11:19:36.612] [AdriansClusterSystem-akka.actor.default-dispat cher-3] [Cluster(akka://AdriansClusterSystem)] Cluster Node [akka.tcp://AdriansC lusterSystem@127.0.0.1:54824] - Metrics will be retreived from MBeans, and may b e incorrect on some platforms. To increase metric accuracy add the ''sigar.jar'' t o the classpath and the appropriate platform-specific native libary to ''java.lib rary.path''. Reason: java.lang.ClassNotFoundException: org.hyperic.sigar.Sigar [INFO] [07/31/2013 11:19:36.619] [AdriansClusterSystem-akka.actor.default-dispat cher-3] [Cluster(akka://AdriansClusterSystem)] Cluster Node [akka.tcp://AdriansC lusterSystem@127.0.0.1:54824] - Metrics collection has started successfully [INFO] [07/31/2013 11:19:36.633] [AdriansClusterSystem-akka.actor.default-dispat cher-12] [akka://AdriansClusterSystem/user/clusterListener] Current members:

Sí, simplemente cuelga allí y tengo que cerrar la ventana sbt para terminarla.