|
|
|
@ -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)
|
|
|
|
|