kimbyungeun
commented
4 years ago The reasons why the results are in different orders each time is because the actor hierarchy scan is done recursively in parallel down in the actor hierarchy using wildcard ActorSelections and the completion order of those parallel tasks is arbitrary. We're able to guarantee that a parent doesn't complete its scan until its children have completed theirs and so on, all the way until we reach the specified level of depth. But we don't guarantee the completion order of siblings - i.e. the order in which two children of the
/useractor complete their scans.
Using akka 1.3.16 will print all actors.
pbm api log
[127.0.0.1:9111] pbm> actor hierarchy -d 10
/user
/user/ApiMasterActor
/user/ApiMasterActor/$a
/user/ApiMasterActor/ClusterSingleton
/user/ApiMasterActor/ClusterSingleton/TestClusterRole1HelloActor
/user/ApiMasterActor/ClusterSingleton/TestClusterRole1HelloActor/c1
/user/ApiMasterActor/ClusterSingleton/TestClusterRole2HelloActor
/user/ApiMasterActor/ClusterSingleton/TestClusterRole2HelloActor/c3
/user/ApiMasterActor/ClusterSingleton/TestClusterRole3HelloActor
/user/ApiMasterActor/ClusterSingleton/TestClusterRole3HelloActor/c2
/user/pbm-uptime
/user/petabridge.cmd
/user/petabridge.cmd/127.0.0.1%3A3064
/user/petabridge.cmd/127.0.0.1%3A3064/actor
/user/petabridge.cmd/127.0.0.1%3A3064/actor/handler
/user/petabridge.cmd/127.0.0.1%3A3064/actor/handler/$h
/user/petabridge.cmd/127.0.0.1%3A3064/actor/handler/$h/$a
/user/petabridge.cmd-log-memorizerUsing akka 1.4.10 will print some actors.
pbm lighthouse log
[127.0.0.1:9115] pbm> cluster show
akka.tcp://mls-cluster-system@127.0.0.1:3507 | [api] | up |
akka.tcp://mls-cluster-system@127.0.0.1:3511 | [role1] | up |
akka.tcp://mls-cluster-system@127.0.0.1:4062 | [lighthouse] | up |
akka.tcp://mls-cluster-system@127.0.0.1:8112 | [role2] | up |
akka.tcp://mls-cluster-system@127.0.0.1:8113 | [role3] | up |
Count: 5 nodes
[127.0.0.1:9115] pbm>pbm api log
- print some actors.
____ _ _ _ _ | _ \ ___| |_ __ _| |__ _ __(_) __| | __ _ ___ | |_) / _ | __/ _` | '_ \| '__| |/ _` |/ _` |/ _ \ | __| __| || (_| | |_) | | | | (_| | (_| | __/ |_| \___|\__\__,_|_.__/|_| |_|\__,_|\__, |\___| |___/
petabridge.cmd (0.8.0.0) Copyright 2017 - 2020, Petabridge®.
successfully connected to [::ffff:127.0.0.1]:9111
Commands downloaded from server. type help to see what's available
[127.0.0.1:9111] pbm> actor hierarchy -d 10
/user
/user/ApiMasterActor
/user/ApiMasterActor/$a
/user/ApiMasterActor/ClusterSingleton
/user/ApiMasterActor/ClusterSingleton/TestClusterRole1HelloActor
/user/ApiMasterActor/ClusterSingleton/TestClusterRole2HelloActor
/user/ApiMasterActor/ClusterSingleton/TestClusterRole3HelloActor
/user/pbm-uptime
/user/petabridge.cmd
/user/petabridge.cmd/127.0.0.1%3A3943
/user/petabridge.cmd/127.0.0.1%3A3943/actor
/user/petabridge.cmd/127.0.0.1%3A3943/actor/handler
/user/petabridge.cmd/127.0.0.1%3A3943/actor/handler/$a
/user/petabridge.cmd/127.0.0.1%3A3943/actor/handler/$a/$b
/user/petabridge.cmd-log-memorizer
[127.0.0.1:9111] pbm> actor hierarchy -d 10
/user
/user/ApiMasterActor
/user/ApiMasterActor/$a
/user/ApiMasterActor/ClusterSingleton
/user/ApiMasterActor/ClusterSingleton/TestClusterRole1HelloActor
/user/ApiMasterActor/ClusterSingleton/TestClusterRole1HelloActor/c1
/user/ApiMasterActor/ClusterSingleton/TestClusterRole2HelloActor
/user/ApiMasterActor/ClusterSingleton/TestClusterRole3HelloActor
/user/pbm-uptime
/user/petabridge.cmd
/user/petabridge.cmd/127.0.0.1%3A3943
/user/petabridge.cmd/127.0.0.1%3A3943/actor
/user/petabridge.cmd/127.0.0.1%3A3943/actor/handler
/user/petabridge.cmd/127.0.0.1%3A3943/actor/handler/$b
/user/petabridge.cmd/127.0.0.1%3A3943/actor/handler/$b/$b
/user/petabridge.cmd-log-memorizer
[127.0.0.1:9111] pbm> actor hierarchy -d 10
/user
/user/ApiMasterActor
/user/ApiMasterActor/$a
/user/ApiMasterActor/ClusterSingleton
/user/ApiMasterActor/ClusterSingleton/TestClusterRole1HelloActor
/user/ApiMasterActor/ClusterSingleton/TestClusterRole1HelloActor/c1
/user/ApiMasterActor/ClusterSingleton/TestClusterRole2HelloActor
/user/ApiMasterActor/ClusterSingleton/TestClusterRole3HelloActor
/user/pbm-uptime
/user/petabridge.cmd
/user/petabridge.cmd/127.0.0.1%3A3943
/user/petabridge.cmd/127.0.0.1%3A3943/actor
/user/petabridge.cmd/127.0.0.1%3A3943/actor/handler
/user/petabridge.cmd/127.0.0.1%3A3943/actor/handler/$c
/user/petabridge.cmd/127.0.0.1%3A3943/actor/handler/$c/$b
/user/petabridge.cmd-log-memorizer
[127.0.0.1:9111] pbm> actor hierarchy -d 10
/user
/user/ApiMasterActor
/user/ApiMasterActor/$a
/user/ApiMasterActor/ClusterSingleton
/user/ApiMasterActor/ClusterSingleton/TestClusterRole1HelloActor
/user/ApiMasterActor/ClusterSingleton/TestClusterRole2HelloActor
/user/ApiMasterActor/ClusterSingleton/TestClusterRole3HelloActor
/user/pbm-uptime
/user/petabridge.cmd
/user/petabridge.cmd/127.0.0.1%3A3943
/user/petabridge.cmd/127.0.0.1%3A3943/actor
/user/petabridge.cmd/127.0.0.1%3A3943/actor/handler
/user/petabridge.cmd/127.0.0.1%3A3943/actor/handler/$d
/user/petabridge.cmd/127.0.0.1%3A3943/actor/handler/$d/$b
/user/petabridge.cmd-log-memorizer
[127.0.0.1:9111] pbm>
* The following `Received unexpected ActorIdentity` warning log is displayed in the [api] role.[2020/10/22 19:50:48.525][ 27][ INFO]akka.tcp://mls-cluster-system@127.0.0.1:3925/user/petabridge.cmd[Petabridge.Cmd.Host.AkkaCmdListener] Received petabridge.cmd connection from client [127.0.0.1:3943]
[2020/10/22 19:50:48.525][ 27][DEBUG]akka.tcp://mls-cluster-system@127.0.0.1:3925/user/petabridge.cmd/127.0.0.1%3A3943[Petabridge.Cmd.Host.AkkaCmdController] Sending palettes to client...
[2020/10/22 19:50:57.714][ 7][ WARN]akka.tcp://mls-cluster-system@127.0.0.1:3925/user/petabridge.cmd/127.0.0.1%3A3943/actor/handler/$a/$b[Petabridge.Cmd.Host.Default.Actor.ActorTracer] Received unexpected ActorIdentity: [Id=akka://mls-cluster-system/user/ApiMasterActor/ClusterSingleton/TestClusterRole2HelloActor, Subject=[akka.tcp://mls-cluster-system@127.0.0.1:8112/remote/akka.tcp/mls-cluster-system@127.0.0.1:3925/user/ApiMasterActor/ClusterSingleton/TestClusterRole2HelloActor/c1#565633793]]
[2020/10/22 19:50:57.776][ 32][DEBUG]akka://mls-cluster-system/user/petabridge.cmd/127.0.0.1%3A3943/actor/handler/$a/$b[Akka.Actor.LocalActorRef] Unhandled message from akka.tcp://mls-cluster-system@127.0.0.1:3927/remote/akka.tcp/mls-cluster-system@127.0.0.1:3925/user/ApiMasterActor/ClusterSingleton/TestClusterRole1HelloActor/c1 :
### [api] role hoconpetabridge.cmd { host = "0.0.0.0" port = 9111 log-palettes-on-startup = on }
akka { service.name = "TestClusterApi" service.description = "TestClusterApi" system.name = "mls-cluster-system"
stdout-loglevel = DEBUG
loglevel = DEBUG
log-config-on-start = on
loggers = ["Akka.Logger.NLog.NLogLogger, Akka.Logger.NLog"]
actor
{
provider = cluster
guardian-supervisor-strategy = "TestClusterApi.ActorService.UserSupervisorStrategy, TestClusterApi"
debug
{
receive = off
autoreceive = off
lifecycle = off
event-stream = off
unhandled = on
}
deployment
{
/ApiMasterActor
{
}
"/ApiMasterActor/*/TestClusterRole1HelloActor"
{
router = round-robin-pool
nr-of-instances = 100
cluster
{
enabled = on
max-nr-of-instances-per-node = 1
allow-local-routees = off
use-role = role1
}
}
"/ApiMasterActor/*/TestClusterRole2HelloActor"
{
router = round-robin-pool
nr-of-instances = 100
cluster
{
enabled = on
max-nr-of-instances-per-node = 1
allow-local-routees = off
use-role = role2
}
}
"/ApiMasterActor/*/TestClusterRole3HelloActor"
{
router = round-robin-pool
nr-of-instances = 100
cluster
{
enabled = on
max-nr-of-instances-per-node = 1
allow-local-routees = off
use-role = role3
}
}
}
}
remote
{
dot-netty.tcp
{
public-hostname = 127.0.0.1
port = 0
send-buffer-size = 2097152b # 2MB
receive-buffer-size = 2097152b # 2MB
maximum-frame-size = 1048576b # 1MB
}
transport-failure-detector
{
heartbeat-interval = 5s
acceptable-heartbeat-pause = 50s
}
}
extensions = ["Akka.Cluster.Tools.Client.ClusterClientReceptionistExtensionProvider, Akka.Cluster.Tools"]
cluster
{
seed-nodes = ["akka.tcp://mls-cluster-system@127.0.0.1:4062"]
roles = [api]
auto-down-unreachable-after = 10s
gossip-interval = 5s
gossip-time-to-live = 30s
failure-detector
{
heartbeat-interval = 5s
acceptable-heartbeat-pause = 50s
}
singleton
{
singleton-name = "ClusterSingleton"
role = "role1"
hand-over-retry-interval = 1s
min-number-of-hand-over-retries = 10
}
}}
Aaronontheweb
IgorFedchenko
seungyongshim
https://github.com/akkadotnet/akka.net/issues/4585
Environment
ClusterSingletonManager.Question
actor hierarchyprints different results each time.our service
actor hierarchy -d 81st runReceived unexpected ActorIdentityWarning messageactor hierarchy -d 82nd runReceived unexpected ActorIdentityWarning message