Можете объяснить концепцию Exchange в RabbitMQ и как он функционирует в передаче сообщений?

В RabbitMQ Exchange — это компонент, который принимает сообщения от производителей (producers) и направляет их в очереди (queues) по определённым правилам, называемым маршрутами (routing).

Основные типы Exchange:

• Direct — направляет сообщение в очередь, если ключ маршрутизации совпадает с ключом очереди.
• Fanout — рассылает сообщение во все очереди, связанные с этим Exchange.
• Topic — маршрутизирует сообщения по шаблонам ключей.
• Headers — маршрутизирует по заголовкам сообщений.

Пример работы:

1. Producer отправляет сообщение в Exchange с определённым routing key.
2. Exchange проверяет свои правила и связывает сообщение с одной или несколькими очередями.
3. Сообщение попадает в очередь, откуда consumer его забирает.

Это позволяет гибко управлять маршрутизацией сообщений и масштабировать систему.

Пример на C# с использованием RabbitMQ.Client:

var factory = new ConnectionFactory() { HostName = "localhost" };
using var connection = factory.CreateConnection();
using var channel = connection.CreateModel();

channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Fanout);

string message = "Hello RabbitMQ!";
var body = Encoding.UTF8.GetBytes(message);

channel.BasicPublish(exchange: "logs", routingKey: "", basicProperties: null, body: body);
Console.WriteLine(" [x] Sent {0}", message);