Introducción
Las aplicaciones modernas suelen necesitar emitir eventos a través de múltiples servicios. Por ejemplo, cuando se crea un pedido en un sistema de comercio electrónico, el servicio de pedidos publica un evento y varios suscriptores reaccionan de forma independiente: un servicio de facturación cobra al cliente, un servicio de correo envía el recibo y un servicio de analítica rastrea el pedido. Esto es la esencia del patrón Publish/Subscribe o Pub/Sub.
Qué es el patrón Pub/Sub
El patrón Pub/Sub desacopla emisores y receptores. El publicador crea un mensaje, por ejemplo OrderSubmitted, y lo envía a un canal o broker. El broker entrega ese mensaje a todos los suscriptores interesados. Cada suscriptor recibe una copia del mensaje y lo procesa de forma independiente.
Beneficios principales
Desacoplamiento: los publicadores no conocen a los suscriptores. Escalabilidad: múltiples suscriptores pueden procesar en paralelo. Flexibilidad: se pueden añadir o eliminar suscriptores sin modificar el publicador.
Por qué importa
El patrón Pub/Sub existe desde hace décadas en middleware como IBM MQ, JMS, RabbitMQ y Kafka. Es fundamental en microservicios orientados a eventos y en sistemas en tiempo real como aplicaciones de chat, plataformas de trading, sistemas de notificaciones, canalizaciones de datos, analítica e IoT. En esencia, Pub/Sub habilita comunicación asíncrona y acoplamiento débil.
Hosted Services en ASP NET Core
Un hosted service es una tarea en segundo plano que se ejecuta junto con el host de la aplicación. En .NET se suele heredar de BackgroundService e implementar ExecuteAsync. En el ejemplo con MassTransit se muestra un PublisherService implementado como hosted service para publicar mensajes periódicamente.
1 Pub/Sub con MassTransit y RabbitMQ
MassTransit es un framework para aplicaciones distribuidas que facilita trabajar con brokers como RabbitMQ o Azure Service Bus. Gestiona serialización, ciclo de vida de consumidores, reintentos y la configuración de endpoints. Implementación típica en .NET: definir un tipo de mensaje OrderSubmitted como record, crear un consumidor que implemente IConsumer para procesar el mensaje, y añadir un servicio de publicación que use IPublishEndpoint para enviar eventos periódicos. En appsettings json se configuran datos de conexión a RabbitMq y un intervalo de publicación. En Program se registra MassTransit, se añade el consumer y se configura UsingRabbitMq con ReceiveEndpoint para el queue name masstransitdemo order submitted y con políticas de retry e in memory outbox.
Ejecutar RabbitMQ
Se puede levantar RabbitMQ con Docker usando un comando como docker run -it --rm -p 5672:5672 -p 15672:15672 rabbitmq:3-management para disponer de la interfaz de gestión en el puerto 15672 con usuario guest y contraseña guest.
Cuándo usar MassTransit y RabbitMQ
Use esta opción cuando necesite mensajería distribuida, tolerancia a fallos, persistencia de eventos y escalado horizontal entre procesos o máquinas. Ideal para arquitecturas de microservicios y pipelines de integración.
2 Pub/Sub con Reactive Extensions Rx
Reactive Extensions o Rx es una librería para componer programas asíncronos y basados en eventos mediante secuencias observables. Se basa en IObservable como fuente de eventos e IObserver como suscriptor. Ofrece operadores estilo LINQ como Where, Select y Buffer para transformar y filtrar flujos. Es perfecta para pipelines en memoria y escenarios de interfaz de usuario. Un ejemplo típico usa Subject como bus en memoria, varios Subscribe para distintos consumidores y operadores para filtrar por total o calcular métricas.
Limitación de Rx
Rx funciona solo en memoria: los eventos desaparecen cuando la aplicación se detiene. No proporciona persistencia ni distribución entre procesos distintos.
3 Pub/Sub con BlockingCollection
BlockingCollection es una colección segura para productor y consumidor incluida en .NET. Soporta bloqueo para que los consumidores esperen hasta que haya datos, y acotamiento para limitar la capacidad y evitar sobrecarga. Es útil para workers en segundo plano, pipelines y procesadores por lotes. Una implementación típica crea una BlockingCollection boundedCapacity 100, lanza tareas consumidoras que recorren GetConsumingEnumerable y un bucle publicador que añade OrderSubmitted y finalmente completa la colección con CompleteAdding.
Limitación de BlockingCollection
Solo funciona dentro de un mismo proceso, por lo que no sirve para escenarios distribuidos donde los productores y consumidores están en máquinas distintas.
Comparación rápida
Rx y BlockingCollection son opciones livianas para flujos en memoria con baja latencia y fácil integración dentro de una sola aplicación. MassTransit con RabbitMQ aporta robustez, persistencia y capacidad de distribuir mensajes entre servicios independientes en diferentes hosts. La elección depende de los requisitos de durabilidad, escalabilidad y distribución.
Q2BSTUDIO y cómo podemos ayudarte
En Q2BSTUDIO somos una empresa de desarrollo de software y aplicaciones a medida especializada en soluciones empresariales. Diseñamos software a medida, desarrollamos aplicaciones a medida y construimos arquitecturas orientadas a eventos que incorporan Pub/Sub según las necesidades del cliente. Nuestra experiencia incluye inteligencia artificial, ia para empresas, agentes IA, ciberseguridad, servicios cloud aws y azure y servicios inteligencia de negocio como integraciones con power bi. Podemos implementar desde pipelines en memoria y workers hasta soluciones distribuidas con MassTransit y RabbitMQ, y añadir capas de seguridad y monitorización para cumplir requisitos de ciberseguridad y cumplimiento.
Servicios destacados de Q2BSTUDIO
Desarrollo de aplicaciones a medida y software a medida. Integración de inteligencia artificial y agentes IA para automatizar procesos. Consultoría y despliegue en servicios cloud aws y azure. Soluciones de inteligencia de negocio y dashboards con power bi. Auditorías y hardening de ciberseguridad. Implementación de pipelines de datos y arquitecturas basadas en eventos con Pub/Sub.
Casos de uso recomendados
Si necesita notificaciones en tiempo real, auditoría de eventos, procesamiento paralelo o integración entre microservicios, recomendamos evaluar MassTransit con RabbitMQ para escenarios distribuidos. Para prototipos rápidos, procesamiento dentro del mismo proceso o UIs reactivas, Rx o BlockingCollection son excelentes opciones. Q2BSTUDIO puede asesorar y desarrollar la solución más adecuada para su caso, combinando arquitecturas Pub/Sub con inteligencia artificial y servicios cloud para maximizar valor.
Conclusión
El patrón Publish/Subscribe sigue siendo fundamental porque permite que los sistemas sean más modulares, escalables y resilientes al cambio. Con las tres alternativas en .NET descritas dispone del espectro completo: streams en memoria ligeros con Rx y BlockingCollection, y mensajería distribuida robusta con MassTransit y RabbitMQ. Contacte a Q2BSTUDIO para diseñar e implementar una solución de Pub/Sub adaptada a sus objetivos de negocio aprovechando software a medida, inteligencia artificial, ciberseguridad, servicios cloud aws y azure, servicios inteligencia de negocio, ia para empresas, agentes IA y power bi.