.idea/misc.xml

@@ -1,7 +1,4 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
-  <component name="Black">
-    <option name="sdkName" value="Python 3.12 (DAS_2024_1)" />
-  </component>
   <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.9 (tukaeva_alfiya_lab_4)" project-jdk-type="Python SDK" />
 </project>

melnikov_igor_lab_4/Consumer_1.py

@@ -1,31 +0,0 @@
-
-import time
-import pika
-
-
-def callback(ch, method, properties, body):
-    print(f'Consumer 1 получил сообщение: {body.decode()}')
-
-    # Время задержки по условию
-    time.sleep(2)
-
-    print('Consumer 1 закончил обработку')
-
-
-def consume_events_1():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-    channel = connection.channel()
-
-    # Создание очереди
-    channel.queue_declare(queue='consumer1_queue')
-    # Привязка очереди
-    channel.queue_bind(exchange='beauty_salon_events', queue='consumer1_queue')
-
-    channel.basic_consume(queue='consumer1_queue', on_message_callback=callback, auto_ack=True)
-
-    print('Consumer 1 начал ожидать сообщения...')
-    channel.start_consuming()
-
-
-if __name__ == "__main__":
-    consume_events_1()

melnikov_igor_lab_4/Consumer_2.py

@@ -1,28 +0,0 @@
-import pika
-
-
-def callback(ch, method, properties, body):
-    print(f'Consumer 2 получил сообщение: {body.decode()}')
-
-    # Обработка "нон-стопом"
-    print('Consumer 2 закончил обработку')
-
-
-def consume_events_2():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-    channel = connection.channel()
-
-    # Создание очереди
-    channel.queue_declare(queue='consumer2_queue')
-
-    # Привязка очереди
-    channel.queue_bind(exchange='beauty_salon_events', queue='consumer2_queue')
-
-    channel.basic_consume(queue='consumer2_queue', on_message_callback=callback, auto_ack=True)
-
-    print('Consumer 2 начал ожидать сообщения...')
-    channel.start_consuming()
-
-
-if __name__ == "__main__":
-    consume_events_2()

melnikov_igor_lab_4/README.md

@@ -1,48 +0,0 @@
-### Лабораторная работа №4 - Работа с брокером сообщений
-
-#### Задание
-
-1. Установить брокер сообщений RabbitMQ.
-2. Пройти уроки 1, 2 и 3 из RabbitMQ Tutorials на любом языке программирования.
-3. Продемонстрировать работу брокера сообщений.
-
-#### Описание работы программы:
-
-- **Класс Publisher** осуществляет отправку сообщений своим клиентам.
-  
-- **Класс Consumer1** принимает и обрабатывает сообщения с задержкой в 3 секунды.
-
-- **Класс Consumer2** мгновенно принимает и обрабатывает сообщения.
-
-#### Tutorials
-
-1. tutorial_1
-
-![tutorial_1.png](tutorial_1.png)
-
-2. tutorial_2
-
-![tutorial_2.png](tutorial_2.png)
-
-3. tutorial_3
-
-![tutorial_3.png](tutorial_3.png)
-
-## Работа с RabbitMQ
-
-![rabbitMQ.png](rabbitMQ.png)
-
-## Показания очереди queue_1 при одном запущенном экземпляре Consumer_1
-
-![queue_1_1.png](queue_1_1.png)
-
-## Показания очереди queue_2
-
-![queue_2_1.png](queue_2_1.png)
-
-## Показания очереди queue_1 при двух запущенных экземплярах Consumer_1
-![queue_1_2.png](queue_1_2.png)
-
-## Показания очереди queue_1 при трех запущенных экземплярах Consumer_1
-
-![queue_1_3.png](queue_1_3.png)

melnikov_igor_lab_4/publisher.py

@@ -1,28 +0,0 @@
-import pika
-import time
-
-
-def publish_events():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-    channel = connection.channel()
-
-    # Создание exchange типа fanout
-    channel.exchange_declare(exchange='beauty_salon_events', exchange_type='fanout')
-
-    events = [
-        "Test1",
-        "Test2",
-        "Test3",
-        "Test4",
-        "Test5"
-    ]
-
-    while True:
-        event = events[int(time.time()) % len(events)]
-        channel.basic_publish(exchange='beauty_salon_events', routing_key='', body=event)
-        print(f'Отправлено: {event}')
-        time.sleep(1)
-
-
-if __name__ == "__main__":
-    publish_events()

melnikov_igor_lab_4/tutorial_1/receive.py

@@ -1,25 +0,0 @@
-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)

melnikov_igor_lab_4/tutorial_1/send.py

@@ -1,11 +0,0 @@
-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()

melnikov_igor_lab_4/tutorial_2/new_task.py

@@ -1,19 +0,0 @@
-import pika
-import sys
-
-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}")
-connection.close()

melnikov_igor_lab_4/tutorial_2/worker.py

@@ -1,23 +0,0 @@
-#!/usr/bin/env python
-import pika
-import time
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.queue_declare(queue='task_queue', durable=True)
-print(' [*] Waiting for messages. To exit press CTRL+C')
-
-
-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_qos(prefetch_count=1)
-channel.basic_consume(queue='task_queue', on_message_callback=callback)
-
-channel.start_consuming()

melnikov_igor_lab_4/tutorial_3/emit_log.py

@@ -1,13 +0,0 @@
-import pika
-import sys
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.exchange_declare(exchange='logs', exchange_type='fanout')
-
-message = ' '.join(sys.argv[1:]) or "info: Hello World!"
-channel.basic_publish(exchange='logs', routing_key='', body=message)
-print(f" [x] Sent {message}")
-connection.close()

melnikov_igor_lab_4/tutorial_3/receive_logs.py

@@ -1,22 +0,0 @@
-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()