.NET 的简单事件总线

Question

Closed. This question is seeking recommendations for software libraries, tutorials, tools, books, or other off-site resources. It does not meet Stack Overflow guidelines. It is not currently accepting answers.

---

我们不允许提出寻求软件库、教程、工具、书籍或其他场外资源推荐的问题。 您可以编辑问题，以便用事实和引文来回答。

8 年前已关闭。

Answer 1

Tiny Messenger 是一个不错的选择，我已经在现场项目中使用它 2.5 年了。 来自 Wiki 的一些代码示例（链接如下）：

发布

messageHub.Publish(new MyMessage());

订阅

messageHub.Subscribe<MyMessage>((m) => { MessageBox.Show("Message Received!"); });
messageHub.Subscribe<MyMessageAgain>((m) => { MessageBox.Show("Message Received!"); }, (m) => m.Content == "Testing");

代码位于 GitHub 上：https://github.com/grumpydev/TinyMessenger

Wiki 位于： https://github.com/grumpydev/TinyMessenger/wiki

它还有一个 Nuget 包

Install-Package TinyMessenger

Answer 2

另一种，受 Android 的 EventBus 启发，但简单得多：

public class EventBus
{
    public static EventBus Instance { get { return instance ?? (instance = new EventBus()); } }

    public void Register(object listener)
    {
        if (!listeners.Any(l => l.Listener == listener))
            listeners.Add(new EventListenerWrapper(listener));
    }

    public void Unregister(object listener)
    {
        listeners.RemoveAll(l => l.Listener == listener);
    }

    public void PostEvent(object e)
    {
        listeners.Where(l => l.EventType == e.GetType()).ToList().ForEach(l => l.PostEvent(e));
    }

    private static EventBus instance;

    private EventBus() { }

    private List<EventListenerWrapper> listeners = new List<EventListenerWrapper>();

    private class EventListenerWrapper
    {
        public object Listener { get; private set; }
        public Type EventType { get; private set; }

        private MethodBase method;

        public EventListenerWrapper(object listener)
        {
            Listener = listener;

            Type type = listener.GetType();

            method = type.GetMethod("OnEvent");
            if (method == null)
                throw new ArgumentException("Class " + type.Name + " does not containt method OnEvent");

            ParameterInfo[] parameters = method.GetParameters();
            if (parameters.Length != 1)
                throw new ArgumentException("Method OnEvent of class " + type.Name + " have invalid number of parameters (should be one)");

            EventType = parameters[0].ParameterType;
        }

        public void PostEvent(object e)
        {
            method.Invoke(Listener, new[] { e });
        }
    }      
}

用例：

public class OnProgressChangedEvent
{

    public int Progress { get; private set; }

    public OnProgressChangedEvent(int progress)
    {
        Progress = progress;
    }
}

public class SomeForm : Form
{
    // ...

    protected override void OnLoad(EventArgs e)
    {
        base.OnLoad(e);
        EventBus.Instance.Register(this);
    }

    public void OnEvent(OnProgressChangedEvent e)
    {
        progressBar.Value = e.Progress;
    }

    protected override void OnClosed(EventArgs e)
    {
        base.OnClosed(e);
        EventBus.Instance.Unregister(this);
    }
}

public class SomeWorkerSomewhere
{
    void OnDoWork()
    {
        // ...

        EventBus.Instance.PostEvent(new OnProgressChangedEvent(progress));

        // ...
    }
}

Answer 3

复合应用程序块包含一个事件代理，可能用于你。

Answer 4

您还可以查看 Unity 扩展：
http://msdn.microsoft.com/en-us/library/cc440958。 aspx

[Publishes("TimerTick")]
public event EventHandler Expired;
private void OnTick(Object sender, EventArgs e)
{
  timer.Stop();
  OnExpired(this);
}

[SubscribesTo("TimerTick")]
public void OnTimerExpired(Object sender, EventArgs e)
{
  EventHandler handlers = ChangeLight;
  if(handlers != null)
  {
    handlers(this, EventArgs.Empty);
  }
  currentLight = ( currentLight + 1 ) % 3;
  timer.Duration = lightTimes[currentLight];
  timer.Start();
}

有更好的吗？

Answer 5

我发现通用消息总线 。 这是一堂简单的课。

Answer 6

另一个好的实现可以在以下位置找到：

http: //code.google.com/p/fracture/source/browse/trunk/Squared/Util/EventBus.cs

用例可在以下位置访问：
/trunk/Squared/Util/UtilTests/Tests/EventTests.cs

此实现不需要外部库。

改进可能是能够使用类型而不是字符串进行订阅。

Answer 7

您应该查看 Ayende 的截屏系列 Hibernating Rhinos 中的第 3 集 - “实施事件代理” ”。

它展示了如何使用 Windsor 来实现一个非常简单的事件代理来连接事物。 还包括源代码。

所提出的事件代理解决方案非常简单，但不需要花费太多时间来增强该解决方案以允许参数与事件一起传递。

Answer 8

我创建了这个：

https://github.com/RemiBou/RemiDDD/tree /master/RemiDDD.Framework/Cqrs

与 ninject 存在依赖关系。
你有一个消息处理器。 如果你想观察一个事件，实现“IObserver”；如果你想处理命令，实现“ICommandHandleer”