MQTTNet.Client 1.0.2

基于MQTTNet二次开发的MQTTClient（MQTT客户端）
***************************说明**************************************************
1.0.2：
去掉 Microsoft.Extensions.DependencyInjection 的依赖避免出现兼容性问题
********************************************************************************
使用示例(示例所用为WorkService)：
********************************************************************************
Program.cs
using example;
using MQTTNet.Client;

var builder = Host.CreateApplicationBuilder(args);
var service = builder.Services;
service.AddHostedService<Worker>();
var host = builder.Build();
host.Run();
********************************************************************************
Worker.cs

using MQTTNet.Client.Attributes;
using MQTTNet.Client.Model;
using MQTTNet.Client.Common;
using MQTTNet.Client.Enums;

namespace example
{
   public class Worker : BackgroundService
   {
       private readonly ILogger<Worker> _logger;

       public Worker(ILogger<Worker> logger)
     {
     _logger = logger;
     }
     IMQTTNetClient client = null;
     protected override async Task ExecuteAsync(CancellationToken stoppingToken)
     {
     client = new MQTTNet.Client.MQTTNetClient("127.0.0.1",1883);
     if(client.InitMQTT())
     _logger.LogInformation("连接成功");
     }
     }
     public class MQTTData : ReceivedModel {
     [Router("+/device/message/up/ivs_result", QOSEnum.ExactlyOnce)]
     public async Task GetData(test resultR3)
     {
     if (resultR3 == null)
     return;
     Console.WriteLine($@"a：{resultR3.ObjectToJson()}");
     Console.WriteLine($@"主题：{this.Topic}");
     Console.WriteLine($@"原始字符串：{this.Content}");
     await Task.CompletedTask;
     }
     }
     public class test
     {
     public Guid strc { get; set; }
     public string? strs { get; set; }
     public string? stra { get; set; }
     public List<test1> array { get; set; }
   }
}