.net 自建发布订阅

.NET自建发布订阅

1. 流程概述

下面是使用.NET自建发布订阅的流程概述：

2. 步骤详解及代码示例

2.1 创建发布者类

首先，我们需要创建一个发布者类，负责发布消息给订阅者。以下是一个示例代码：

public class Publisher
{
    // 定义事件
    public event EventHandler<MessageEventArgs> MessageSent;

    // 发布消息的方法
    public void PublishMessage(string message)
    {
        OnMessageSent(new MessageEventArgs(message));
    }

    // 触发事件的方法
    protected virtual void OnMessageSent(MessageEventArgs e)
    {
        MessageSent?.Invoke(this, e);
    }
}

在上述代码中，我们创建了一个名为Publisher的类。这个类包含一个MessageSent事件，用于发布消息给订阅者。PublishMessage方法用于发布消息，它会调用OnMessageSent方法来触发事件。

2.2 创建订阅者接口

接下来，我们需要创建一个订阅者接口，用于定义订阅者类的方法。以下是一个示例代码：

public interface ISubscriber
{
    void ReceiveMessage(object sender, MessageEventArgs e);
}

在上述代码中，我们定义了一个名为ISubscriber的接口，它包含一个ReceiveMessage方法用于接收消息。该方法的参数sender表示消息的发送者，e表示消息的内容。

2.3 创建订阅者类

然后，我们需要创建一个订阅者类，实现订阅者接口中的方法。以下是一个示例代码：

public class Subscriber : ISubscriber
{
    // 实现接口中的方法
    public void ReceiveMessage(object sender, MessageEventArgs e)
    {
        Console.WriteLine($"Received message: {e.Message}");
    }
}

在上述代码中，我们创建了一个名为Subscriber的类，它实现了ISubscriber接口中的ReceiveMessage方法。该方法会打印接收到的消息。

2.4 注册订阅者

接下来，我们需要在发布者中注册订阅者，以便发布者能够向订阅者发送消息。以下是一个示例代码：

Publisher publisher = new Publisher();
Subscriber subscriber = new Subscriber();

// 注册订阅者
publisher.MessageSent += subscriber.ReceiveMessage;

在上述代码中，我们创建了一个Publisher对象和一个Subscriber对象。然后，通过使用+=运算符，我们将订阅者的ReceiveMessage方法注册到发布者的MessageSent事件上。

2.5 发布消息

最后，我们可以通过调用发布者的PublishMessage方法来发布消息给订阅者。以下是一个示例代码：

publisher.PublishMessage("Hello, subscribers!");

在上述代码中，我们调用了发布者的PublishMessage方法，并传入了要发布的消息。

3. 总结

使用.NET自建发布订阅可以实现消息的发布和订阅机制。通过创建发布者类、订阅者接口和订阅者类，我们可以有效地实现消息的发送和接收。希望这篇文章对你理解和实现.NET自建发布订阅有所帮助。