46 lines
1.7 KiB
Markdown
46 lines
1.7 KiB
Markdown
|
# Лабораторная работа 4. Работа с брокером сообщений
|
|||
|
### Задание на лабораторную работу
|
|||
|
1. Установить брокер сообщений RabbitMQ.
|
|||
|
2. Пройти уроки 1, 2 и 3 из RabbitMQ Tutorials на любом языке программирования.
|
|||
|
3. Продемонстрировать работу брокера сообщений.
|
|||
|
|
|||
|
***
|
|||
|
### Описание работы
|
|||
|
Были разработаны 3 приложения на *java*:
|
|||
|
1. **Publisher**. Программа, которая создаёт один *exchange* с типом *fanout* и раз в секунду генерирует сообщение.
|
|||
|
|
|||
|
![](images/publisher.jpg)
|
|||
|
|
|||
|
2. **Consumer1**. Программа, которая создаёт под себя отдельную не анонимную очередь (*queue1*), создаёт *binding* на
|
|||
|
*exchange* и начинает принимать сообщения. Программа обрабатывает сообщения 3 секунды.
|
|||
|
|
|||
|
![](images/consumer1.jpg)
|
|||
|
|
|||
|
3. **Consumer2**. Аналогично *Consumer1*, только сообщения обрабатываются моментально и имя очереди (*queue2*)
|
|||
|
отличается от *Consumer1*.
|
|||
|
|
|||
|
![](images/consumer2.jpg)
|
|||
|
|
|||
|
***
|
|||
|
### Отчеты
|
|||
|
***RabbitMQ Management UI***
|
|||
|
|
|||
|
![](images/result1.jpg)
|
|||
|
|
|||
|
![](images/result2.jpg)
|
|||
|
|
|||
|
***Exchange***
|
|||
|
|
|||
|
![](images/result3.jpg)
|
|||
|
|
|||
|
***Очередь Consumer1***
|
|||
|
|
|||
|
![](images/queue1.jpg)
|
|||
|
|
|||
|
***Очередь Consumer2***
|
|||
|
|
|||
|
![](images/queue2.jpg)
|
|||
|
|
|||
|
### Ссылка на видео:
|
|||
|
https://drive.google.com/file/d/19OdXnNM29SjayVZJ1qdsrMFTHkAUGxZf/view?usp=sharing
|