Apache Ignite RemoteListen .Net

Question

我通过BAT文件启动了一个Server，然后通过代码启动了一个Client写入数据，并设置了过期时间。然后我想通过订阅EVT_CACHE_OBJECT_EXPIRED 来跟踪客户端的过期条目，但我查看https://issues.apache.org/jira/browse/IGNITE-1682 - RemoteListen 已从Ignite.NET 中删除，替代方案是什么？或者有什么例子可以看。

Answer 1

您可以在服务器节点上使用LocalListen，然后使用Ignite Messaging 通知客户端该事件。

服务器

server.GetEvents().LocalListen(new EventListener(server.GetMessaging()), EventType.CacheObjectExpired);

...

public class EventListener  : IEventListener<CacheEvent>
{
    private readonly IMessaging _messaging;

    public EventListener(IMessaging messaging)
    {
        _messaging = messaging;
    }

    public bool Invoke(CacheEvent evt)
    {
        _messaging.Send(evt.Key, "Expired");

        return true;
    }
}

客户

client.GetMessaging().LocalListen(new MessageListener(), "Expired");

...

public class MessageListener : IMessageListener<object>
{
    public bool Invoke(Guid nodeId, object message)
    {
        Console.WriteLine("Expired: " + message);

        return true;
    }
}