# Лабораторная работа №4 - Работа с брокером сообщений Lesson 1:   Lesson 2:   Lesson 3:   # Задачи Необходимо выбрать предметную область и разработать следующие приложения: 1. **Publisher**. Программа, которая создаёт один **exchange** с типом _fanout_. Программа должна раз в секунду генерировать сообщения в журнал событий согласно вашей предметной области. Например, событие "пришёл заказ" или "сообщение от пользователя" или "необходимо создать отчёт". 2. **Consumer 1**. Программа, которая создаёт под себя отдельную не анонимную (!) очередь (**queue**) (то есть имя queue НЕ пустая строка), создаёт **binding** на **exchange** и начинает принимать сообщения (_consume_). Программа должна обрабатывать сообщения 2-3 секунды. Можно реализовать через обычный _Thread.Sleep_ (для C#). 3. **Consumer 2**. Аналогично _Consumer 1_, только сообщения необходимо обрабатывать моментально. Только имя очереди должно отличаться от _Consumer 1_. Далее необходимо собрать и запустить приложения одновременно по одному экземпляру. # Запуск Проект запускается в ide просто по нажатию у питон файла на функцию мейн. Нужно последовательно запустить функцию мейн у файлов app.py, consumer1.py, consumer2.py. Очередь сообщений запускается такой командой docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management # Описание работы: Развернули два приложения Сервисы используем из предыдущей работы Предметная область - Скрипты и дефекты 1. Consumer 1 - Скрипт 1: 2. Consumer 2 - Скрипт 2: Оба скрипта обрабатывают дефекты. Flask-приложение с RabbitMQ, использующего библиотеку pika для publisher и для consumers. Надо обязательно вызвать метод publish, иначе обработка дефектов не начнется. Приложение Flask (app.py), для источника дефектов (publisher) и двух скриптов-потребителей (consumer1.py и consumer2.py). Запускаем приложение Flask и обоих потребителей запускаем отдельно в разных терминалах. Consumer ы будут прослушивать сообщения, опубликованные publisher ом.  # Ссылка на видео https://drive.google.com/file/d/1P8kKSZAre24I04DXL1WqkPtdL6RnDOPA/view?usp=sharing