前言

在现代软件开发中，事件驱动架构（Event-Driven Architecture, EDA） 以其高度解耦、灵活扩展的特性被广泛应用于桌面应用、Web服务、微服务架构等多个领域。其中，事件的发布与订阅机制是实现模块间通信的核心手段之一。

本文将通过一个完整的代码示例，帮助你理解并掌握如何使用 C# 实现一个简易但功能完整的事件发布与订阅系统。

核心概念：什么是委托与事件？

在深入编码之前，我们先来了解两个关键概念：

委托（Delegate）

委托就像一个“方法容器”，可以用来引用一个或多个具有相同签名的方法，并在需要时调用它们。

public delegate void EventHandler(string message);

这表示一个名为 EventHandler 的委托，它接受一个字符串参数，没有返回值。

事件（Event）

事件是对委托的一种封装，用于限制外部直接调用委托，只能通过 += 和 -= 来添加或移除事件处理程序，从而提升安全性。

实现步骤详解

第一步：声明委托

定义一个用于事件处理的委托类型。

public delegate void MessageEventHandler(string message);

第二步：定义事件发布者（Publisher）

这是一个包含事件并负责触发事件的类。

public class Publisher
{
    // 声明事件
    public event MessageEventHandler OnMessagePublished;

    // 触发事件的方法
    public void Publish(string message)
    {
        // 使用空条件操作符安全调用事件
        OnMessagePublished?.Invoke(message);
    }
}

第三步：定义事件订阅者（Subscriber）

订阅者通过绑定到事件来响应发布的消息。

public classSubscriber
{
    public void Subscribe(Publisher publisher)
    {
        // 订阅事件
        publisher.OnMessagePublished += HandleMessage;
    }

    private void HandleMessage(string message)
    {
        Console.WriteLine($"收到消息: {message}");
    }

    public void Unsubscribe(Publisher publisher)
    {
        // 取消订阅事件
        publisher.OnMessagePublished -= HandleMessage;
    }
}

第四步：主程序测试运行

class Program
{
    static void Main(string[] args)
    {
        var publisher = new Publisher();
        var subscriber = new Subscriber();

        // 订阅事件
        subscriber.Subscribe(publisher);

        // 发布事件
        publisher.Publish("Hello, world!");

        Console.ReadLine();
    }
}

运行后输出：

收到消息: Hello, world!

完整代码整合如下：

using System;

namespaceEventDemo
{
    // 1. 声明委托
    public delegate void MessageEventHandler(string message);

    // 2. 定义发布者
    publicclassPublisher
    {
        publicevent MessageEventHandler OnMessagePublished;

        public void Publish(string message)
        {
            OnMessagePublished?.Invoke(message);
        }
    }

    // 3. 定义订阅者
    publicclassSubscriber
    {
        public void Subscribe(Publisher publisher)
        {
            publisher.OnMessagePublished += HandleMessage;
        }

        private void HandleMessage(string message)
        {
            Console.WriteLine($"收到消息: {message}");
        }

        public void Unsubscribe(Publisher publisher)
        {
            publisher.OnMessagePublished -= HandleMessage;
        }
    }

    // 4. 主程序入口
    classProgram
    {
        static void Main(string[] args)
        {
            var publisher = new Publisher();
            var subscriber = new Subscriber();

            subscriber.Subscribe(publisher);

            publisher.Publish("Hello, world!");

            Console.ReadLine();
        }
    }
}

深入理解：事件 vs 委托

特性	委托	事件
定义方式	可以单独定义	必须依附于类内部
外部访问控制	允许外部直接调用	仅允许通过 += / -= 修改订阅者
使用场景	方法回调，多用于函数式编程	组件间通信，适用于松耦合设计
线程安全	需手动处理	推荐使用空条件调用确保安全