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

actor akka-cluster

Question

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: //[email protected]: 2552 /]] que llega a [akka.tcp: // ClusterSys [email protected]: 2552] las direcciones de entrada son [akka.tcp: //[email protected] .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://[email protected]:2551",
"akka.tcp://[email protected]: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://[email protected]:2552]
[INFO] [07/31/2013 10:50:00.710] [run-main] [Cluster(akka://AdriansClusterSystem
)] Cluster Node [akka.tcp://[email protected]:2552] - Starting up..
.
[INFO] [07/31/2013 10:50:00.823] [run-main] [Cluster(akka://AdriansClusterSystem
)] Cluster Node [akka.tcp://[email protected]: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://[email protected]: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
[email protected]: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
[email protected]: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://[email protected]:2552/]] arriving at [akka.tcp://ClusterSyst
[email protected]:2552] inbound addresses are [akka.tcp://[email protected].
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://[email protected]:2552/]] arriving at [akka.tcp://ClusterSys
[email protected]:2552] inbound addresses are [akka.tcp://[email protected]
.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
[email protected]: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
[email protected]: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.

Answer 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://[email protected]:2551",
"akka.tcp://[email protected]:2552"]