Merge pull request '优化MQTT功能' (#266) from koy07555/Admin.NET.Pro:优化MQTT功能 into v2

Reviewed-on: https://code.adminnet.top/Admin.NET/Admin.NET.Pro/pulls/266

Admin.NET/Admin.NET.Core/Service/Mqtt/Dto/SysMqttDto.cs

@@ -0,0 +1,19 @@
+// Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
+//
+// 本项目主要遵循 MIT 许可证和 Apache 许可证（版本 2.0）进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
+//
+// 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动！任何基于本项目二次开发而产生的一切法律纠纷和责任，我们不承担任何责任！
+
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Admin.NET.Core;
+public class PublicMessageInput
+{
+    public string Topic { get; set; }
+
+    public string Message { get; set; }
+}

Admin.NET/Admin.NET.Core/Service/Mqtt/MqttService.cs

@@ -1,34 +0,0 @@
-// Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
-//
-// 本项目主要遵循 MIT 许可证和 Apache 许可证（版本 2.0）进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
-//
-// 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动！任何基于本项目二次开发而产生的一切法律纠纷和责任，我们不承担任何责任！
-
-using Admin.NET.Core.Service.Mqtt.Dto;
-
-namespace Admin.NET.Core.Service;
-
-/// <summary>
-/// 系统职位服务 🧩
-/// </summary>
-[ApiDescriptionSettings(Order = 460, Description = "MQTT 服务")]
-public class MqttService : IDynamicApiController, ITransient
-{
-    MqttHostedService _mqttHostedService;
-    public MqttService(MqttHostedService mqttProvider)
-    {
-        _mqttHostedService = mqttProvider;
-    }
-
-    /// <summary>
-    /// 发布消息 🔖
-    /// </summary>
-    /// <param name="input"></param>
-    /// <returns></returns>
-    [AllowAnonymous]
-    [DisplayName("发布消息")]
-    public async Task PublicMessage(PublicMessageInput input)
-    {
-        _mqttHostedService.PublicMessage(input.Topic, input.Message);
-    }
-}

Admin.NET/Admin.NET.Core/Service/Mqtt/SysMqttService.cs

@@ -25,5 +25,18 @@ public class SysMqttService() : IDynamicApiController, ITransient
             throw Oops.Oh("【MQTT】服务未启动");
 
         return await MqttHostedService.MqttServer.GetClientsAsync();
+    }
+
+    /// <summary>
+    /// 发布主题 🔖
+    /// </summary>
+    /// <param name="input"></param>
+    /// <returns></returns>
+    [AllowAnonymous]
+    [DisplayName("发布主题")]
+    public async Task PublicMessage(PublicMessageInput input)
+    {
+        MqttHostedService mqttHostedService = App.GetRequiredService<MqttHostedService>();
+        mqttHostedService.PublicMessage(input.Topic, input.Message);
     }
 }

Admin.NET/Admin.NET.Web.Core/Admin.NET.Web.Core.csproj

@@ -11,6 +11,7 @@
 
   <ItemGroup>
     <PackageReference Include="IGeekFan.AspNetCore.Knife4jUI" Version="0.0.16" />
+    <PackageReference Include="MQTTnet.AspNetCore" Version="5.0.1.1416" />
     <PackageReference Include="System.Security.Cryptography.Pkcs" Version="9.0.2" />
   </ItemGroup>