diff --git a/labs/lab_4.md b/labs/lab_4.md index ee8cbf5..7726c54 100644 --- a/labs/lab_4.md +++ b/labs/lab_4.md @@ -1 +1,54 @@ -To be done \ No newline at end of file +# Лабораторная работа №4 - Работа с брокером сообщений + +**Цель**: изучение проектирования приложений при помощи брокера сообщений. + +**Задачи**: + +1. Установить брокер сообщений RabbitMQ. +2. Пройти уроки 1, 2 и 3 из [RabbitMQ Tutorials](https://www.rabbitmq.com/getstarted.html) на любом языке программирования. +3. Продемонстрировать работу брокера сообщений. + +## Установка брокера сообщений RabbitMQ + +Можно не использовать Docker и использовать локальный ПК. + +[Страница скачивания RabbitMQ с офф. сайта](https://www.rabbitmq.com/download.html). + +[Страница релизов RabbitMQ](https://github.com/rabbitmq/rabbitmq-server/releases/), где есть бинарные установщики для всех современных платформ. + +## Прохождение tutorial + +Достаточно для каждого урока скриншота, где виден запуск одновременно `producer` и `consumer`, а также видно, что сообщения передаются. + +## Разработка демонстрационных приложений + +См. 3 главу tutorial. + +Необходимо выбрать предметную область и разработать следующие приложения: + +1. **Publisher**. + Программа, которая создаёт один **exchange** с типом _fanout_. + Программа должна раз в секунду генерировать сообщения в журнал событий согласно вашей предметной области. + Например, событие "пришёл заказ" или "сообщение от пользователя" или "необходимо создать отчёт". +2. **Consumer 1**. + Программа, которая создаёт под себя отдельную не анонимную (!) очередь (**queue**) (то есть имя queue НЕ пустая строка), создаёт **binding** на **exchange** и начинает принимать сообщения (_consume_). + Программа должна обрабатывать сообщения 2-3 секунды. + Можно реализовать через обычный _Thread.Sleep_ (для C#). +3. **Consumer 2**. + Аналогично _Consumer 1_, только сообщения необходимо обрабатывать моментально. + Только имя очереди должно отличаться от _Consumer 1_. + +Далее необходимо собрать и запустить приложения одновременно по одному экземпляру. + +Сделать в отчёте вывод о скорости обработки _consumer_-ами событий от _publisher_-а. +Для этого можно посмотреть заполненность созданных очередей. +А для этого можно использовать скриншот из **RabbitMQ Management UI**. + +Запустить несколько копий _Consumer 1_. +Проверить заново заполненность очередей через _UI_. + +## Правила оформления pull request + +Как в предыдущих лабораторных. + +P.S. Задание взято из [репозитория](http://student.git.athene.tech/v.moiseev/distributed-computing/src/branch/main/labs/lab_4) Моисеева В.В. \ No newline at end of file