Recibir mensajes de cola/tópicos del bus de servicios en una API web

Answer

1. 

   davy.ai

   July 24, 2023 at 3:57 pm

   Sí, es posible consumir mensajes de un bus de servicios en una API web en lugar de Azure functions. Aquí están los pasos que puedes seguir:

   1. Crea un nuevo proyecto de API web asp.net Core en Visual Studio.

   2. Instala el paquete NuGet Microsoft.Azure.ServiceBus en tu proyecto.

   3. Agrega una nueva clase a tu proyecto para el receptor del bus de servicios. En esta clase, puedes usar ServiceBusConnectionStringBuilder para obtener la cadena de conexión de tu bus de servicios y crear una nueva instancia de ServiceBusClient para conectarte al bus de servicios.

   “`C#
   private ServiceBusClient _serviceBusClient;
   private ServiceBusProcessor _serviceBusProcessor;
   private readonly string _serviceBusConnectionString;
   private readonly string _queueName;

   public ServiceBusReceiver(IConfiguration config)
   {
   _serviceBusConnectionString = config[“ServiceBusConnectionString”];
   _queueName = config[“QueueName”];
   }

   public async Task StartAsync(CancellationToken cancellationToken)
   {
   _serviceBusClient = new ServiceBusClient(_serviceBusConnectionString);
   _serviceBusProcessor = _serviceBusClient.CreateProcessor(_queueName);

   _serviceBusProcessor.ProcessMessageAsync += ProcessMessageAsync;
   _serviceBusProcessor.ProcessErrorAsync += ProcessErrorAsync;
   
   await _serviceBusProcessor.StartProcessingAsync(cancellationToken);
   

   }

   public async Task StopAsync(CancellationToken cancellationToken)
   {
   await _serviceBusProcessor.StopProcessingAsync(cancellationToken);
   await _serviceBusClient.DisposeAsync();
   }

   private async Task ProcessMessageAsync(ProcessMessageEventArgs args)
   {
   // Procesa el mensaje recibido del bus de servicios
   await _serviceBusProcessor.CompleteMessageAsync(args.Message);
   }

   private Task ProcessErrorAsync(ProcessErrorEventArgs args)
   {
   // Maneja cualquier error recibido durante el procesamiento de mensajes
   return Task.CompletedTask;
   }

   
   4. En tu archivo Startup.cs, registra el receptor del bus de servicios como un servicio alojado.
   
   ```C#
   services.AddHostedService<servicebusreceiver>();
   

   1. En tu controlador de API, puedes inyectar la clase del receptor del bus de servicios y llamar a sus métodos StartAsync y StopAsync para comenzar y detener la recepción de mensajes desde el bus de servicios.

   “`C#
   [ApiController]
   [Route(“[controller]”)]
   public class ServiceBusController : ControllerBase
   {
   private readonly IHostApplicationLifetime _hostApplicationLifetime;
   private readonly ServiceBusReceiver _serviceBusReceiver;

   public ServiceBusController(IHostApplicationLifetime hostApplicationLifetime, ServiceBusReceiver serviceBusReceiver)
   {
       _hostApplicationLifetime = hostApplicationLifetime;
       _serviceBusReceiver = serviceBusReceiver;
   }
   
   [HttpPost]
   public async Task<iactionresult> StartServiceBusReceiver()
   {
       _hostApplicationLifetime.ApplicationStarted.Register(async () =>
       {
           await _serviceBusReceiver.StartAsync(_hostApplicationLifetime.ApplicationStopping);
       });
   
       _hostApplicationLifetime.ApplicationStopping.Register(async () =>
       {
           await _serviceBusReceiver.StopAsync(CancellationToken.None);
       });
   
       return Ok();
   }
   

   }

   
   6. Finalmente, agrega la cadena de conexión y el nombre de la cola del bus de servicios a tu archivo appsettings.json.
   
   ```json
   {
       "ServiceBusConnectionString": "Endpoint=sb://[namespace].servicebus.windows.net/;SharedAccessKeyName=[keyname];SharedAccessKey=[key]",
       "QueueName": "queue-name"
   }
   

   ¡Eso es todo! Ahora tu API web debería poder consumir mensajes del bus de servicios.

Comments are closed.