| .. | ||
| screenshots | ||
| consumer_1.py | ||
| consumer_2.py | ||
| publisher.py | ||
| README.MD | ||
Лабораторная работа №4 - Работа с брокером сообщений
Задачи:
Необходимо выбрать предметную область и разработать следующие приложения:
- Publisher. Программа, которая создаёт один exchange с типом fanout. Программа должна раз в секунду генерировать сообщения в журнал событий согласно вашей предметной области. Например, событие "пришёл заказ" или "сообщение от пользователя" или "необходимо создать отчёт".
- Consumer 1. Программа, которая создаёт под себя отдельную не анонимную (!) очередь (queue) (то есть имя queue НЕ пустая строка), создаёт binding на exchange и начинает принимать сообщения (consume). Программа должна обрабатывать сообщения 2-3 секунды. Можно реализовать через обычный Thread.Sleep (для C#).
- Consumer 2. Аналогично Consumer 1, только сообщения необходимо обрабатывать моментально. Только имя очереди должно отличаться от Consumer 1.
Как запустить
Запустить python 'название_файла'
Работа программы
publisher:
consumer_1:
consumer_2:
1-я очередь
2-я очередь
Видео: https://youtu.be/3pxgHmm3i0Q