morozov_vladimir_lab_4 is ready
BIN
morozov_vladimir_lab_4/Teacher_student_message/FirstTest.png
Normal file
After Width: | Height: | Size: 312 KiB |
After Width: | Height: | Size: 42 KiB |
After Width: | Height: | Size: 57 KiB |
BIN
morozov_vladimir_lab_4/Teacher_student_message/SecondTest.png
Normal file
After Width: | Height: | Size: 374 KiB |
After Width: | Height: | Size: 62 KiB |
@ -0,0 +1,24 @@
|
||||
import pika
|
||||
|
||||
connection = pika.BlockingConnection(
|
||||
pika.ConnectionParameters(host='localhost'))
|
||||
channel = connection.channel()
|
||||
channel.basic_qos(prefetch_count=1)
|
||||
channel.exchange_declare(exchange='grade_book', exchange_type='fanout')
|
||||
|
||||
result = channel.queue_declare(queue='cool_student', exclusive=True)
|
||||
queue_name = result.method.queue
|
||||
|
||||
channel.queue_bind(exchange='grade_book', queue=queue_name)
|
||||
|
||||
print(' [*] Waiting for logs. To exit press CTRL+C')
|
||||
|
||||
def callback(ch, method, properties, body):
|
||||
print(f" [x] Receive: {body}")
|
||||
print(f" [+] Complete: {body}")
|
||||
ch.basic_ack(delivery_tag=method.delivery_tag)
|
||||
|
||||
channel.basic_consume(
|
||||
queue=queue_name, on_message_callback=callback)
|
||||
|
||||
channel.start_consuming()
|
@ -0,0 +1,31 @@
|
||||
import random
|
||||
import time
|
||||
|
||||
import pika
|
||||
|
||||
connection = pika.BlockingConnection(
|
||||
pika.ConnectionParameters(host='localhost'))
|
||||
channel = connection.channel()
|
||||
|
||||
channel.basic_qos(prefetch_count=1)
|
||||
|
||||
channel.exchange_declare(exchange='grade_book', exchange_type='fanout')
|
||||
|
||||
result = channel.queue_declare(queue='normal_student', durable=True)
|
||||
|
||||
queue_name = result.method.queue
|
||||
|
||||
channel.queue_bind(exchange='grade_book', queue=queue_name)
|
||||
|
||||
print(' [*] Waiting for tasks. To exit press CTRL+C')
|
||||
|
||||
def callback(ch, method, properties, body):
|
||||
print(f" [x] Receive: {body}")
|
||||
time.sleep(random.randint(2,4))
|
||||
print(f" [+] Complete: {body}")
|
||||
ch.basic_ack(delivery_tag=method.delivery_tag)
|
||||
|
||||
channel.basic_consume(
|
||||
queue=queue_name, on_message_callback=callback)
|
||||
|
||||
channel.start_consuming()
|
25
morozov_vladimir_lab_4/Teacher_student_message/teacher.py
Normal file
@ -0,0 +1,25 @@
|
||||
import sys
|
||||
import time
|
||||
|
||||
import pika
|
||||
|
||||
connection = pika.BlockingConnection(
|
||||
pika.ConnectionParameters(host='localhost'))
|
||||
channel = connection.channel()
|
||||
|
||||
channel.exchange_declare(exchange='grade_book',
|
||||
exchange_type='fanout')
|
||||
|
||||
count = 0
|
||||
while True:
|
||||
count+= 1
|
||||
time.sleep(1)
|
||||
message = f"Homework #{count}"
|
||||
channel.basic_publish(exchange='grade_book',
|
||||
routing_key='',
|
||||
body=message,
|
||||
properties=pika.BasicProperties(
|
||||
delivery_mode=pika.DeliveryMode.Persistent
|
||||
))
|
||||
print(f" [x] Sent {message}")
|
||||
|
BIN
morozov_vladimir_lab_4/lesson_1/img.png
Normal file
After Width: | Height: | Size: 178 KiB |
25
morozov_vladimir_lab_4/lesson_1/receive.py
Normal file
@ -0,0 +1,25 @@
|
||||
import pika, sys, os
|
||||
|
||||
def main():
|
||||
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
|
||||
channel = connection.channel()
|
||||
|
||||
channel.queue_declare(queue='hello')
|
||||
|
||||
def callback(ch, method, properties, body):
|
||||
print(f" [x] Received {body}")
|
||||
|
||||
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
|
||||
|
||||
print(' [*] Waiting for messages. To exit press CTRL+C')
|
||||
channel.start_consuming()
|
||||
|
||||
if __name__ == '__main__':
|
||||
try:
|
||||
main()
|
||||
except KeyboardInterrupt:
|
||||
print('Interrupted')
|
||||
try:
|
||||
sys.exit(0)
|
||||
except SystemExit:
|
||||
os._exit(0)
|
11
morozov_vladimir_lab_4/lesson_1/send.py
Normal file
@ -0,0 +1,11 @@
|
||||
import pika
|
||||
|
||||
connection = pika.BlockingConnection(
|
||||
pika.ConnectionParameters(host='localhost'))
|
||||
channel = connection.channel()
|
||||
|
||||
channel.queue_declare(queue='hello')
|
||||
|
||||
channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')
|
||||
print(" [x] Sent 'Hello World!'")
|
||||
connection.close()
|
BIN
morozov_vladimir_lab_4/lesson_2/img.png
Normal file
After Width: | Height: | Size: 362 KiB |
18
morozov_vladimir_lab_4/lesson_2/new_task.py
Normal file
@ -0,0 +1,18 @@
|
||||
import sys
|
||||
import pika
|
||||
|
||||
connection = pika.BlockingConnection(
|
||||
pika.ConnectionParameters(host='localhost'))
|
||||
channel = connection.channel()
|
||||
|
||||
channel.queue_declare(queue='task_queue', durable=True)
|
||||
|
||||
message = ' '.join(sys.argv[1:]) or "Hello World!"
|
||||
|
||||
channel.basic_publish(exchange='',
|
||||
routing_key="task_queue",
|
||||
body=message,
|
||||
properties=pika.BasicProperties(
|
||||
delivery_mode = pika.DeliveryMode.Persistent
|
||||
))
|
||||
print(f" [x] Sent {message}")
|
29
morozov_vladimir_lab_4/lesson_2/worker.py
Normal file
@ -0,0 +1,29 @@
|
||||
import time
|
||||
|
||||
import pika, sys, os
|
||||
|
||||
def main():
|
||||
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
|
||||
channel = connection.channel()
|
||||
channel.basic_qos(prefetch_count=1)
|
||||
channel.queue_declare(queue='task_queue', durable=True)
|
||||
def callback(ch, method, properties, body):
|
||||
print(f" [x] Received {body.decode()}")
|
||||
time.sleep(body.count(b'.'))
|
||||
print(" [x] Done")
|
||||
ch.basic_ack(delivery_tag=method.delivery_tag)
|
||||
|
||||
channel.basic_consume(queue='task_queue', on_message_callback=callback)
|
||||
|
||||
print(' [*] Waiting for messages. To exit press CTRL+C')
|
||||
channel.start_consuming()
|
||||
|
||||
if __name__ == '__main__':
|
||||
try:
|
||||
main()
|
||||
except KeyboardInterrupt:
|
||||
print('Interrupted')
|
||||
try:
|
||||
sys.exit(0)
|
||||
except SystemExit:
|
||||
os._exit(0)
|
BIN
morozov_vladimir_lab_4/lesson_3/img.png
Normal file
After Width: | Height: | Size: 148 KiB |
22
morozov_vladimir_lab_4/lesson_3/receiver.py
Normal file
@ -0,0 +1,22 @@
|
||||
import pika
|
||||
|
||||
connection = pika.BlockingConnection(
|
||||
pika.ConnectionParameters(host='localhost'))
|
||||
channel = connection.channel()
|
||||
|
||||
channel.exchange_declare(exchange='logs', exchange_type='fanout')
|
||||
|
||||
result = channel.queue_declare(queue='', exclusive=True)
|
||||
queue_name = result.method.queue
|
||||
|
||||
channel.queue_bind(exchange='logs', queue=queue_name)
|
||||
|
||||
print(' [*] Waiting for logs. To exit press CTRL+C')
|
||||
|
||||
def callback(ch, method, properties, body):
|
||||
print(f" [x] {body}")
|
||||
|
||||
channel.basic_consume(
|
||||
queue=queue_name, on_message_callback=callback, auto_ack=True)
|
||||
|
||||
channel.start_consuming()
|
20
morozov_vladimir_lab_4/lesson_3/send.py
Normal file
@ -0,0 +1,20 @@
|
||||
import sys
|
||||
import pika
|
||||
|
||||
connection = pika.BlockingConnection(
|
||||
pika.ConnectionParameters(host='localhost'))
|
||||
channel = connection.channel()
|
||||
|
||||
channel.exchange_declare(exchange='logs',
|
||||
exchange_type='fanout')
|
||||
|
||||
message = ' '.join(sys.argv[1:]) or "Hello World!"
|
||||
|
||||
channel.basic_publish(exchange='logs',
|
||||
routing_key='',
|
||||
body=message,
|
||||
properties=pika.BasicProperties(
|
||||
delivery_mode=pika.DeliveryMode.Persistent
|
||||
))
|
||||
|
||||
print(f" [x] Sent {message}")
|
44
morozov_vladimir_lab_4/readme.md
Normal file
@ -0,0 +1,44 @@
|
||||
# Лабораторная работа №4 - Работа с брокером сообщений
|
||||
|
||||
## Прохождение уроков
|
||||
|
||||
Урок №1.
|
||||
![img.png](lesson_1%2Fimg.png)
|
||||
|
||||
Урок №2.
|
||||
![img.png](lesson_2%2Fimg.png)
|
||||
|
||||
Урок №3.
|
||||
![img.png](lesson_3%2Fimg.png)
|
||||
|
||||
Все приложения были разработаны на Python
|
||||
|
||||
## Разработанные приложения
|
||||
В качестве предметной области было выбрано общение учителя и его учеников. Учитель дает задание ученикам, а они их выполняют. Я выделил 2 вида учеников: обычные, которым нужно некоторое время на то, чтобы выполнить задание; крутые ученики, которые выполняют задание моментально, как только получают его.
|
||||
Были созданы следующие приложения:
|
||||
- teacher - программа, которая представляет учителя и отправляет задания ученикам
|
||||
- Student_Normal - программа, которая представялет обычного ученика, получает и обрабатывает, с задержкой, полученные задания.
|
||||
- Student_Cool - программа, которая представялет крутого ученика, получает и моментально обрабатывает полученные задания.
|
||||
Все программы были разработаны на языке Python.
|
||||
Проведенные тесты:
|
||||
#### Тест №1. Запущены 1 учитель, 1 обычный ученик, 1 крутой ученик:
|
||||
![FirstTest.png](Teacher_student_message%2FFirstTest.png)
|
||||
Показатели очереди обычного ученика:
|
||||
![FirstTest_Normal.png](Teacher_student_message%2FFirstTest_Normal.png)
|
||||
Показатели очереди крутого ученика:
|
||||
![FirstTest_Cool.png](Teacher_student_message%2FFirstTest_Cool.png)
|
||||
|
||||
Вывод: одного обычного ученика не хватает на то, чтобы выполнять все полученные в срок, ему тяжело :(
|
||||
Крутому же ученику все дается с легкостью.
|
||||
|
||||
#### Тест №2. Запущены 1 учитель, 4 обычных ученика:
|
||||
![SecondTest.png](Teacher_student_message%2FSecondTest.png)
|
||||
Показатели очереди обычного ученика:
|
||||
![FirstTest_Normal.png](Teacher_student_message%2FFirstTest_Normal.png)
|
||||
Вывод: если 4 обычных ученика объединяться и будут делать задания вместе, то они смогут избежать переполнения очереди заданий.
|
||||
|
||||
|
||||
|
||||
|
||||
## Запись тестирования
|
||||
Работа приложения представлена в [видео](https://disk.yandex.ru/i/zzwvXXpZhavh7A)
|