RabbitMQ — Misión

Por qué aprendo esto

Llevo años enviando mensajes por RabbitMQ, casi siempre a través de una biblioteca que lo ocultaba: MassTransit en un proyecto, Spring AMQP en otro. Funcionó hasta el día en que dejó de hacerlo. Un consumidor se reinició y algunos pedidos se procesaron dos veces; otra vez, desaparecieron mensajes y nadie supo decir adónde habían ido. Cada vez me di cuenta de que conocía la API de la biblioteca y no el broker que había debajo.

Quiero saber qué hace realmente RabbitMQ con un mensaje desde que un productor lo envía hasta que un consumidor confirma su recepción, para poder diseñar una topología a conciencia, elegir el tipo de cola adecuado y averiguar qué salió mal con las herramientas del propio broker.

Para quién es este curso

Eres desarrollador de C# o Java. Has publicado o consumido mensajes, quizá a través de MassTransit, NServiceBus, Spring AMQP o Spring Cloud Stream, y ya has ejecutado un contenedor. No necesitas conocer AMQP. La parte de Java supone el nivel de Java para desarrolladores C#; la lección 3 remite las preguntas sobre Spring a Spring Boot, Spring Cloud y Reactor para desarrolladores C#, y la lección 1 las preguntas sobre contenedores a Contenedores WSL.

El ejemplo conductor

Las lecciones usan flujos pequeños y reconocibles en lugar de una sola aplicación: líneas de log enrutadas por gravedad, precios difundidos a varias pantallas, pedidos y pagos. Un programa en C# (code/rabbitmq/csharp), un programa con el cliente Java y una aplicación Spring Boot (code/rabbitmq/java) intercambian los mismos mensajes, porque un broker es el lugar donde se encuentran lenguajes distintos.

flowchart LR
    cs["Productor C#<br/>RabbitMQ.Client"] -->|order.created.eu| ex{{"orders.topic<br/>exchange"}}
    java["Productor Java<br/>amqp-client"] -->|order.created.us| ex
    spring["Productor Spring<br/>RabbitTemplate"] -->|order.created.ca| ex
    ex -->|"binding order.#"| q[("orders.billing<br/>cola")]
    q --> c1["Consumidor C#"]
    q --> c2["Consumidor Java"]
    q --> c3["@RabbitListener de Spring"]

Ninguno de los repositorios de GuitarAlchemist usa RabbitMQ en su código, así que todavía no hay un caso práctico sacado de ellos; el diario anota la única configuración que encontré.

Al final de este curso, sabré

explicar el modelo AMQP 0-9-1: conexiones, canales, exchanges, bindings, colas y mensajes;
ejecutar RabbitMQ en un contenedor e inspeccionarlo con la interfaz de gestión, rabbitmqctl y rabbitmq-diagnostics;
diseñar una topología con exchanges direct, fanout, topic y headers, y tratar los mensajes que nada enruta;
escribir productores y consumidores en C#, en Java y con Spring AMQP que interoperen;
decir quién es responsable de un mensaje en cada paso, y usar acuses de recibo, prefetch, confirmaciones de publicación y persistencia para no perder ninguno;
elegir entre colas clásicas, colas quorum y streams;
tratar los fallos con dead lettering, TTL y reintentos;
operar un clúster, asegurarlo, monitorizarlo y dimensionarlo;
mantener RabbitMQ en el tiempo: actualizaciones, definiciones, Kubernetes.

Plan

#	Lección	Lo que quizá ya conoces
1	Primeros pasos	una cola vista desde MassTransit o Spring, `docker run`
2	Topología: exchanges, bindings y colas	los topics y reglas de suscripción de Azure Service Bus, los destinos JMS
3	Clientes en C#, Java y Spring AMQP	la vida de un `HttpClient`, los consumidores `async`, `RabbitTemplate`
4	Fiabilidad: acuses de recibo, prefetch, confirmaciones	las transacciones de base de datos, la entrega al menos una vez
5	Tipos de colas: clásicas, quorum y streams (la próxima)	Raft, las particiones de Kafka
6	Errores: dead lettering, TTL, reintentos y mensajes diferidos	los reintentos de Polly, las colas de error de MassTransit
7	Patrones: work queues, publish/subscribe, RPC, consumidores en competencia, outbox	el outbox transaccional de MassTransit o de Spring Modulith
8	Clustering y alta disponibilidad: particiones de red, quorum	los clústeres de conmutación por error
9	Seguridad: virtual hosts, usuarios, permisos, TLS	las cadenas de conexión, los certificados en Kestrel
10	Observabilidad: Prometheus, Grafana, métricas clave, alarmas, control de flujo	OpenTelemetry, `dotnet-counters`
11	Rendimiento y dimensionamiento, medidos	BenchmarkDotNet
12	Otros protocolos: streams y super streams, MQTT, AMQP 1.0; RabbitMQ y Kafka	Kafka, Azure Event Hubs
13	Operaciones: actualizaciones, definiciones, el Cluster Operator de Kubernetes	los charts de Helm, las actualizaciones progresivas

Diario: lo que probé, lo que me sorprendió, lo que aún tengo que verificar.

Recursos

Documentación de RabbitMQ, en particular AMQP 0-9-1 model explained, los exchanges, las colas, los acuses de recibo de los consumidores y confirmaciones de publicación, y las recomendaciones para despliegues en producción
Tutoriales de RabbitMQ, en C# y Java entre otros lenguajes
Guía de la API del cliente .NET y guía de la API del cliente Java
Referencia de Spring AMQP y el capítulo de mensajería de Spring Boot
Referencia completa de AMQP 0-9-1: cada método y cada campo del protocolo
Código fuente: rabbitmq-server, rabbitmq-dotnet-client, rabbitmq-java-client, la imagen Docker