From 102b336a85bf1afc7cae4719890546d4581c8e60 Mon Sep 17 00:00:00 2001
From: yzp <yzp0755@qq.com>
Date: Sat, 22 Feb 2025 08:46:28 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E7=BC=BA=E5=A4=B1=E4=BE=9D=E6=87=92?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Service/Mqtt/SysMqttService.cs             | 18 ++++++------------
 .../Admin.NET.Web.Core.csproj                  |  1 +
 2 files changed, 7 insertions(+), 12 deletions(-)

diff --git a/Admin.NET/Admin.NET.Core/Service/Mqtt/SysMqttService.cs b/Admin.NET/Admin.NET.Core/Service/Mqtt/SysMqttService.cs
index 1f1d174b..85dbdfb0 100644
--- a/Admin.NET/Admin.NET.Core/Service/Mqtt/SysMqttService.cs
+++ b/Admin.NET/Admin.NET.Core/Service/Mqtt/SysMqttService.cs
@@ -13,14 +13,7 @@ namespace Admin.NET.Core.Service;
 /// </summary>
 [ApiDescriptionSettings(Order = 90, Description = "MQTT 服务")]
 public class SysMqttService() : IDynamicApiController, ITransient
-{
-
-    MqttHostedService _mqttHostedService;
-    public SysMqttService(MqttHostedService mqttProvider)
-    {
-        _mqttHostedService = mqttProvider;
-    }
-
+{
     /// <summary>
     /// 获取客户端列表 🔖
     /// </summary>
@@ -35,14 +28,15 @@ public class SysMqttService() : IDynamicApiController, ITransient
     }
 
     /// <summary>
-    /// 发布消息 🔖
+    /// 发布主题 🔖
     /// </summary>
     /// <param name="input"></param>
     /// <returns></returns>
     [AllowAnonymous]
-    [DisplayName("发布消息")]
+    [DisplayName("发布主题")]
     public async Task PublicMessage(PublicMessageInput input)
-    {
-        _mqttHostedService.PublicMessage(input.Topic, input.Message);
+    {
+        MqttHostedService mqttHostedService = App.GetRequiredService<MqttHostedService>();
+        mqttHostedService.PublicMessage(input.Topic, input.Message);
     }
 }
\ No newline at end of file
diff --git a/Admin.NET/Admin.NET.Web.Core/Admin.NET.Web.Core.csproj b/Admin.NET/Admin.NET.Web.Core/Admin.NET.Web.Core.csproj
index 9a5475c5..4bb365c3 100644
--- a/Admin.NET/Admin.NET.Web.Core/Admin.NET.Web.Core.csproj
+++ b/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>