c# - start - Configurar el consumidor RabbitMQ en la aplicación ASP.NET Core

rabbitmq tutorial español

Question

Tengo una aplicación ASP.NET Core donde me gustaría consumir mensajes RabbitMQ.

He configurado con éxito editores y consumidores en aplicaciones de línea de comandos, pero no estoy seguro de cómo configurarlo correctamente en una aplicación web.

Estaba pensando en inicializarlo en Startup.cs , pero por supuesto muere una vez que se completa el inicio.

¿Cómo inicializar al consumidor de la manera correcta desde una aplicación web?

Answer 1

Utilice el patrón Singleton para un oyente y DI incorporado para controlar su vida útil.

Use IApplicationLifetime para iniciar / detener el oyente en el inicio / detención de la aplicación.

public class Startup
{
    public void ConfigureServices(IServiceCollection services)
    {
        services.AddSingleton<RabbitListener>();
    }


    public void Configure(IApplicationBuilder app)
    {
        app.UseRabbitListener();
    }
}

public static class ApplicationBuilderExtentions
{
    public static RabbitListener Listener { get; set; }

    public static IApplicationBuilder UseRabbitListener(this IApplicationBuilder app)
    {
        Listener = app.ApplicationServices.GetService<RabbitListener>();

        var life = app.ApplicationServices.GetService<IApplicationLifetime>();

        life.ApplicationStarted.Register(OnStarted);

        //press Ctrl+C to reproduce if your app runs in Kestrel as a console app
        life.ApplicationStopping.Register(OnStopping);

        return app;
    }

    private static void OnStarted()
    {
        Listener.Register();
    }

    private static void OnStopping()
    {
        Listener.Deregister();    
    }
}

• Deberías preocuparte por el alojamiento de tu aplicación. Por ejemplo, IIS puede reciclar.
• Este patrón puede ser extensivo para un grupo de oyentes.