From 06277e6a5d3ec020e42acf68dd1c2c8520e71798 Mon Sep 17 00:00:00 2001
From: zhangbin <460190368@qq.com>
Date: Thu, 10 Jul 2025 13:52:27 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=8E=B7=E5=8F=96=E9=85=8D?=
 =?UTF-8?q?=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Model/mqtt/MqttHostedService.cs           | 24 +++++++++++++++----
 1 file changed, 20 insertions(+), 4 deletions(-)

diff --git a/OpenAuth.WebApi/Model/mqtt/MqttHostedService.cs b/OpenAuth.WebApi/Model/mqtt/MqttHostedService.cs
index 5476411..09bb4c5 100644
--- a/OpenAuth.WebApi/Model/mqtt/MqttHostedService.cs
+++ b/OpenAuth.WebApi/Model/mqtt/MqttHostedService.cs
@@ -12,6 +12,7 @@ namespace OpenAuth.WebApi.Model.mqtt
         private readonly MqttMessageCenter _mqttCenter;
         private readonly AirportMaintenanceApp _app;
 
+
         public MqttHostedService(IServiceProvider serviceProvider, MqttMessageCenter mqttCenter, AirportMaintenanceApp app)
         {
             _serviceProvider = serviceProvider;
@@ -23,14 +24,29 @@ namespace OpenAuth.WebApi.Model.mqtt
         {
             using var scope = _serviceProvider.CreateScope();
             var handlers = scope.ServiceProvider.GetServices<IMqttMessageHandler>();
+            // 创建配置构建器
+            var builder = new ConfigurationBuilder()
+                .SetBasePath(Directory.GetCurrentDirectory())
+                .AddJsonFile("appsettings.json", optional: false, reloadOnChange: true)
+                .AddJsonFile(
+                    $"appsettings.{Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT") ?? "Development"}.json",
+                    optional: true)
+                .AddEnvironmentVariables();
+            // 构建配置
+            var configuration = builder.Build();
+            // 读取连接字符串
+            var serverIp = configuration["MQTT:Server"];
+            var port = configuration["MQTT:Port"];
+            var username = configuration["MQTT:UserName"];
+            var password = configuration["MQTT:Password"];
 
             await _mqttCenter.InitializeAsync(
                 handlers,
-                server: "175.27.168.120",
-                port: 6011,
+                server: serverIp,
+                port: int.Parse(port),
                 clientId: Guid.NewGuid().ToString(),
-                username: "sdhc",
-                password: ""
+                username: username,
+                password: password
             );
             //查询网关，订阅主题 
             var topics = new List<string>();