From 235eb1adb347f23e2206c39aa85684e1efeb71da Mon Sep 17 00:00:00 2001 From: Vladislav Moiseev Date: Mon, 20 Nov 2023 00:10:30 +0400 Subject: [PATCH 1/4] Add lw04 --- labs/lab_3/README.md | 2 +- labs/lab_4/README.md | 59 ++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 60 insertions(+), 1 deletion(-) create mode 100644 labs/lab_4/README.md diff --git a/labs/lab_3/README.md b/labs/lab_3/README.md index 1088741..91fd5ad 100644 --- a/labs/lab_3/README.md +++ b/labs/lab_3/README.md @@ -126,4 +126,4 @@ [Пример файла с настройкой nginx](./example_nginx.conf). -[Ещё один пример связи воркеров и nginx](../../tasks/moiseev-vv/lab_3). \ No newline at end of file +[Ещё один пример связи воркеров и nginx](../../tasks/moiseev-vv/lab_3). diff --git a/labs/lab_4/README.md b/labs/lab_4/README.md new file mode 100644 index 0000000..aa44b49 --- /dev/null +++ b/labs/lab_4/README.md @@ -0,0 +1,59 @@ +# Лабораторная работа №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_). + Программа должна обрабатывать сообщения, например, 3 секунды. + Можно реализовать через обычный _Thread.Sleep_ (для C#). +3. **Consumer 2**. + Аналогично _Consumer 1_, только сообщения необходимо обрабатывать моментально. + Только имя очереди должно отличаться от _Consumer 1_. + +Далее необходимо собрать и запустить приложения одновременно по одному экземпляру. + +Сделать в отчёте вывод о скорости обработки _consumer_-ами событий от _publisher_-а. +Для этого можно посмотреть заполненность созданных очередей. +А для этого можно использовать скриншот из **RabbitMQ Management UI**. + +Запустить несколько копий _Consumer 1_. +Проверить заново заполненность очередей через _UI_. + +## Правила оформления pull request + +Код и отчёт со скриншотами необходимо положить в папку `tasks/фамилия-инициалы/lab_4`. + +Не забудьте о файле `.gitignore`, чтобы не закоммтить ничего лишнего. +Для C#-проектов это, например, папки `bin` и `obj`. + +Правила именования ветки: `фамилия-инициалы-lab-номер`, например, `moiseev-vv-lab-4`. + +Название pull request: `[Л/Р 4] ФАМИЛИЯ ИМЯ`, например, `[Л/Р 4] Моисеев Владислав`. -- 2.25.1 From 95a4d84451048f2e815e98bdfb7f869c3b4abeb2 Mon Sep 17 00:00:00 2001 From: Vladislav Moiseev Date: Mon, 20 Nov 2023 00:17:33 +0400 Subject: [PATCH 2/4] Update README.md --- README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/README.md b/README.md index 1c92238..433f63f 100644 --- a/README.md +++ b/README.md @@ -8,7 +8,7 @@ 1. [Знакомство с docker и docker-compose](labs/lab_1/README.md) 2. [Разработка простейшего распределённого приложения](labs/lab_2/README.md) 3. [REST API, Gateway и синхронный обмен между микросервисами](labs/lab_3/README.md) -4. TBA +4. [Работа с брокером сообщений](labs/lab_4/README.md) 5. TBA 6. TBA 7. TBA -- 2.25.1 From 2c9547985dece3727f3ecc4aa2a149ffe22a0583 Mon Sep 17 00:00:00 2001 From: Vladislav Moiseev Date: Mon, 20 Nov 2023 00:27:20 +0400 Subject: [PATCH 3/4] Typo fixes --- labs/lab_4/README.md | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/labs/lab_4/README.md b/labs/lab_4/README.md index aa44b49..ba57b42 100644 --- a/labs/lab_4/README.md +++ b/labs/lab_4/README.md @@ -8,7 +8,7 @@ 2. Пройти уроки 1, 2 и 3 из [RabbitMQ Tutorials](https://www.rabbitmq.com/getstarted.html) на любом языке программирования. 3. Продемонстрировать работу брокера сообщений. -## Установка брокера сообщений RabbitMQ. +## Установка брокера сообщений RabbitMQ Можно не использовать Docker и использовать локальный ПК. @@ -20,7 +20,7 @@ Достаточно для каждого урока скриншота, где виден запуск одновременно `producer` и `consumer`, а также видно, что сообщения передаются. -# Разработка демонстрационных приложений +## Разработка демонстрационных приложений См. 3 главу tutorial. @@ -31,7 +31,7 @@ Программа должна раз в секунду генерировать сообщения в журнал событий согласно вашей предметной области. Например, событие "пришёл заказ" или "сообщение от пользователя" или "необходимо создать отчёт". 2. **Consumer 1**. - Программа, которая создаёт под себя отдельную неанонимную (!) очередь (**queue**) (то есть имя queue НЕ пустая строка), создаёт **binding** на **exchange** и начинает принимать сообщения (_consume_). + Программа, которая создаёт под себя отдельную не анонимную (!) очередь (**queue**) (то есть имя queue НЕ пустая строка), создаёт **binding** на **exchange** и начинает принимать сообщения (_consume_). Программа должна обрабатывать сообщения, например, 3 секунды. Можно реализовать через обычный _Thread.Sleep_ (для C#). 3. **Consumer 2**. @@ -51,7 +51,7 @@ Код и отчёт со скриншотами необходимо положить в папку `tasks/фамилия-инициалы/lab_4`. -Не забудьте о файле `.gitignore`, чтобы не закоммтить ничего лишнего. +Не забудьте о файле `.gitignore`, чтобы не закоммитить ничего лишнего. Для C#-проектов это, например, папки `bin` и `obj`. Правила именования ветки: `фамилия-инициалы-lab-номер`, например, `moiseev-vv-lab-4`. -- 2.25.1 From 87550bc07504ba1e7f043ea2f94cae0fbf6762ba Mon Sep 17 00:00:00 2001 From: Vladislav Moiseev Date: Mon, 20 Nov 2023 14:46:11 +0400 Subject: [PATCH 4/4] Fix lw4 --- labs/lab_4/README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/labs/lab_4/README.md b/labs/lab_4/README.md index ba57b42..9db8d7e 100644 --- a/labs/lab_4/README.md +++ b/labs/lab_4/README.md @@ -32,7 +32,7 @@ Например, событие "пришёл заказ" или "сообщение от пользователя" или "необходимо создать отчёт". 2. **Consumer 1**. Программа, которая создаёт под себя отдельную не анонимную (!) очередь (**queue**) (то есть имя queue НЕ пустая строка), создаёт **binding** на **exchange** и начинает принимать сообщения (_consume_). - Программа должна обрабатывать сообщения, например, 3 секунды. + Программа должна обрабатывать сообщения 2-3 секунды. Можно реализовать через обычный _Thread.Sleep_ (для C#). 3. **Consumer 2**. Аналогично _Consumer 1_, только сообщения необходимо обрабатывать моментально. -- 2.25.1