.net8.0 maqtt订阅方法封装

在.NET 8.0中，MAQ (Microsoft Amqp Quadrupled) 是一个用于AMQP（Advanced Message Queuing Protocol）的消息队列库。如果你想要封装MQTT（Message Queuing Telemetry Transport）的订阅方法，虽然它们属于不同的协议栈，但你可以创建一个通用的接口或抽象类来管理MQTT订阅的行为。首先，你需要安装相关的NuGet包，如`MqttNet`。

下面是一个简单的例子：

using MqttNet;
using System.Threading.Tasks;

public interface IMqttSubscriptionManager
{
    Task SubscribeAsync(string topicFilter, Action<MqttApplicationMessage> messageHandler);
    void UnsubscribeAsync(string topicFilter);
}

public class MqttSubscriptionManager : IMqttSubscriptionManager
{
    private readonly MqttClient _mqttClient;

    public MqttSubscriptionManager(MqttClient mqttClient)
    {
        _mqttClient = mqttClient;
    }

    public async Task SubscribeAsync(string topicFilter, Action<MqttApplicationMessage> messageHandler)
    {
        await _mqttClient.ConnectAsync();
        await _mqttClient.SubscribeAsync(new TopicSubscription(topicFilter));
        _mqttClient.ApplicationMessageReceived += (_, e) => messageHandler(e.ApplicationMessage);
    }

    public void UnsubscribeAsync(string topicFilter)
    {
        _mqttClient.UnsubscribeAsync(topicFilter);
        // Make sure to unsubscribe before disconnecting
    }
    
    public async Task DisconnectAsync()
    {
        await _mqttClient.DisconnectAsync();
    }
}

在这个例子中，`IMqttSubscriptionManager`是一个接口，它定义了订阅和取消订阅的方法。`MqttSubscriptionManager`实现了这个接口，内部管理实际的MQTT连接和消息处理。你可以通过实例化`MqttSubscriptionManager`并传递你的MQTT客户端来使用这个封装。