В моем кластере Akka.Net у меня есть несколько узлов. Есть связь, которую я хотел бы инициировать после успешного присоединения к кластеру. Я вижу в журнале, что я добро пожаловать в кластер:
Welcome from [akka.tcp://Animatroller@hakan-el:8899]
но я не вижу каких-либо событий, на которые я могу подписаться и которые вызываются для этого.
Обычно в этом случае вам нужно подписаться на ClusterEvent.MemberUp, который текущий актор получит, как только новый узел станет частью кластера.
Пример актора, обрабатывающего такое событие:
class MyActor : ReceiveActor
{
private readonly Cluster cluster = Cluster.Get(Context.System);
public MyActor()
{
Receive<ClusterEvent.MemberUp>(memberUp => memberUp.Member.Address == cluster.SelfAddress, memberUp =>
{
// handle current node up
});
}
protected override void PreStart()
{
cluster.Subscribe(Self, new []{ typeof(ClusterEvent.MemberUp)});
}
protected override void PostStop()
{
cluster.Unsubscribe(Self);
base.PostStop();
}
}
В этом случае memberUp => memberUp.Member.Address == cluster.SelfAddress является дополнительным фильтром для обработчика, что означает, что он будет обработан только тогда, когда текущий узел, на котором находится этот актор, присоединится к кластеру. События Up, отправленные с других узлов, будут игнорироваться.
