Update 'labs/lab_4.md'
This commit is contained in:
parent
7af5aaa299
commit
9e85fa9e0f
@ -1 +1,54 @@
|
|||||||
To be done
|
# Лабораторная работа №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) Моисеева В.В.
|
Loading…
Reference in New Issue
Block a user