事件聚合器：需要帮助修改解决方案

Question

我正在尝试为我的应用程序设计一个事件聚合器。 （我是设计模式的新手，所以我可能还没有完全理解它）。

首先，我已经创建了一个解决方案，它在某种程度上是一个聚合器，但需要改进和重构以实现更高的效率并减少依赖性。

1) 在事件聚合器设计模式中，我的.NET 数据源是否会被视为发布者？ （我不确定出版商的角色是什么）。

2）我将如何设计我的解决方案来不仅处理特定数据源的订阅，还处理特定数据事件的订阅，同时忽略其他数据事件？我希望看到一个解决方案，不再保留列表并不知疲倦地循环它们......但不确定我是否可以一起避免这一切。

Answer 1

我认为你必须在这里实现一个好的发布者/订阅者。我的建议是这样的：

您的发布者：EventAggregator 应该具有如下方法：

public void Register(IEventObserver observer, EventFilter filter)
public void Unregister(IEventObserver observer)

您的 IEventObserver 应该看起来像

public interface IEventObserver
{
    void Notify(object eventSource, DetailedEventArgs e);
}

您的订阅者应该实现此接口。

您的 EventFilter 类应该具有您打算使用的所有过滤属性。
这个类可以有这样的方法：

public bool IsSatisfiedBy(DetailedEventArgs e)

创建一个名为 DetailedEventArgs 的类，并从 EventArgs 继承它，将您想要的有关事件的所有详细信息放在该类上。

在 Register 方法中，您应该存储过滤器和观察者。现在，当您的 EventAggregator 捕获事件时，它应该首先从接收到的事件创建 DetailedEventArgs 对象，然后循环观察者及其过滤器以查看过滤器是否满足对象，如果是，则使用原始发送者和 DetailedEventArgs 对象调用观察者的 Notify 方法。

我强烈建议您检查发布者端而不是订阅者端的过滤器。因为在订阅者端进行检查会导致大量代码重复和不一致。

编辑：示例 EventFilter 和 DetailedEventArgs 类：

public class EventFilter
{
    private List<Type> SourceTypes;
    private List<EventType> EventTypes;
    public EventFilter() : this(new Type[] { }, new EventType[] { }) { }
    public EventFilter(IEnumerable<Type> sourceTypes, IEnumerable<EventType> eventTypes)
    {
        SourceTypes = new List<Type>(sourceTypes);
        EventTypes = new List<EventType>(eventTypes);
    }
    public void AddSourceType(Type type)
    {
        AddItemToList(SourceTypes, type);
    }
    public void AddEventType(EventType type)
    {
        AddItemToList(EventTypes, type);
    }
    private void AddItemToList<T>(List<T> list, T item)
    {
        lock (list)
        {
            if (!list.Contains(item))
                list.Add(item);
        }
    }
    public bool IsSatisfiedBy(DetailedEventArgs args)
    {
        return SourceTypes.Contains(args.Source.GetType()) && EventTypes.Contains(args.EventType);
    }
}
public class DetailedEventArgs : EventArgs
{
    public EventArgs SourceArgs { get; private set; }
    public object Source { get; private set; }
    public EventType EventType { get; private set; }
    public DetailedEventArgs(object source, EventArgs sourceArgs, EventType eventType)
    {
        Source = source;
        SourceArgs = sourceArgs;
        EventType = eventType;
    }
}
public enum EventType
{
    EventType1,
    EventType2,
    EventType3
}

希望我有所帮助:)

Answer 2

查看 MVVM Light Messenger 类。我的实施基于此。但是，它使用列表和循环，但我没有看到解决方法。

我看到了一些关于内存泄漏的投诉，但这并没有影响我，并且可能会被修复。