using System.Text; using RabbitMQ.Client; var фабрика = new ConnectionFactory { HostName = "localhost" }; using var подключение = фабрика.CreateConnection(); using var канал = подключение.CreateModel(); канал.ExchangeDeclare(exchange: "job", type: ExchangeType.Fanout); Random rand = new Random(); foreach (var элемент in Enumerable.Range(0, 1000)) { var сообщение = rand.Next().ToString(); var тело = Encoding.UTF8.GetBytes(сообщение); канал.BasicPublish(exchange: "job", routingKey: string.Empty, basicProperties: null, body: тело); Console.WriteLine($" [x] Поступила заявка {сообщение}"); await Task.Delay(500); } Console.WriteLine(" Нажмите [Enter] для выхода."); Console.ReadLine(); static string ПолучитьСообщение(string[] аргументы) { return ((аргументы.Length > 0) ? string.Join(" ", аргументы) : "info: Принято!"); }