修改注册

OpenAuth.WebApi/Startup.cs

@@ -328,7 +328,14 @@ namespace OpenAuth.WebApi
             #endregion
 
             #region mqtt
-            services.AddSingleton<MqttMessageCenter>();
+            //services.AddSingleton<MqttMessageCenter>();
+            services.AddSingleton<MqttMessageCenter>(sp =>
+            {
+                var mqtt = new MqttMessageCenter();
+                var handlers = sp.GetServices<IMqttMessageHandler>();
+                mqtt.InitializeAsync(handlers, "175.27.168.120", 6011, "mqtt_client_15821").GetAwaiter().GetResult();
+                return mqtt;
+            });
             services.AddSingleton<IMqttMessageHandler, ThingRequestHandler>();
             services.AddSingleton<IMqttMessageHandler, ThingServiceHandler>();
             services.AddSingleton<IMqttMessageHandler, ThingOsdHandler>();