diff --git a/OpenAuth.WebApi/Startup.cs b/OpenAuth.WebApi/Startup.cs
index 11cd4c6..f95a239 100644
--- a/OpenAuth.WebApi/Startup.cs
+++ b/OpenAuth.WebApi/Startup.cs
@@ -66,6 +66,7 @@ namespace OpenAuth.WebApi
 
             #endregion
 
+
             #region identityServer
 
             var identityServer =
@@ -166,6 +167,16 @@ namespace OpenAuth.WebApi
 
             #endregion
 
+            #region mqtt
+            services.AddSingleton<MqttMessageCenter>();
+            services.AddSingleton<IMqttMessageHandler, ThingRequestHandler>();
+            services.AddSingleton<IMqttMessageHandler, ThingServiceHandler>();
+            services.AddSingleton<IMqttMessageHandler, ThingOsdHandler>();
+            services.AddSingleton<IMqttMessageHandler, ThingEventHandler>();
+            //services.AddSingleton<IMqttMessageHandler, ThingDrcHandler>();
+            services.AddHostedService<MqttHostedService>();
+            #endregion
+
             #region AppSetting
 
             services.Configure<AppSetting>(Configuration.GetSection("AppSetting"));
@@ -327,25 +338,7 @@ namespace OpenAuth.WebApi
 
             #endregion
 
-            #region mqtt
-            //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>();
-            services.AddSingleton<IMqttMessageHandler, ThingEventHandler>();
-            //services.AddSingleton<IMqttMessageHandler, ThingDrcHandler>();
-            services.AddHostedService<MqttHostedService>();
-
-
-
-            #endregion
+            
         }
 
         public void ConfigureContainer(ContainerBuilder builder)