当我的节点加入群集时，Akka.net群集中是否有事件? [英] Is there an event in Akka.net cluster for when my node has joined a cluster?

问题描述

在我的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是处理程序的附加筛选器，这意味着，仅当该actor所在的当前节点加入群集时，才会对其进行处理.从其他节点发送的Up事件将被忽略.

In my Akka.Net cluster I have several nodes. There is communication that I'd like to initiate when I've successfully joined the cluster. I can see in the log that I'm welcome to the cluster:

Welcome from [akka.tcp://Animatroller@hakan-el:8899]

but I can't see any events I can subscribe to that are raised for this.

解决方案

Usually what you want in that case is to subscribe to ClusterEvent.MemberUp, which current actor will receive, once new node will become part of the cluster.

Example of actor handling this kind of event:

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();
    }
}

In this case memberUp => memberUp.Member.Address == cluster.SelfAddress is additional filter for the handler which means, that it will be handled only, when current node, this actor resides on, will join the cluster. Up events send from other nodes will be ignored.

这篇关于当我的节点加入群集时，Akka.net群集中是否有事件?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！