Institute of Information Science - University of Miskolc

User Tools

Site Tools

Trace: • xml-rpc_minta_feladat • kovetelmenyek • protobuf • questions • docker_loadbalancer • js
tanszek:oktatas:informacios_rendszerek_integralasa:uezenetsorok-rabbitmq_2

Differences

This shows you the differences between two versions of the page.

Link to this comparison view

Both sides previous revisionPrevious revision
Next revision		Previous revision
tanszek:oktatas:informacios_rendszerek_integralasa:uezenetsorok-rabbitmq_2 [2023/05/08 07:17] – kneheztanszek:oktatas:informacios_rendszerek_integralasa:uezenetsorok-rabbitmq_2 [2024/04/24 06:45] (current) – knehez
Line 3: Line 3:
 Egy minőségbiztosító rendszer mérőgépének 3 állapotát küldjük egy 'qualityQueue' nevű üzenetsorra. Készítsen egy több komponensből álló alkalmazást, amely 2 kliensen keresztül kommunikál az üzenetsorral az alábbi módon: Egy minőségbiztosító rendszer mérőgépének 3 állapotát küldjük egy 'qualityQueue' nevű üzenetsorra. Készítsen egy több komponensből álló alkalmazást, amely 2 kliensen keresztül kommunikál az üzenetsorral az alábbi módon:
  
-  * Az első kliens, ami a mérőgépre helyezett érzékelőre kapcsolódik a 'qualityQueue' üzenetsorra pont-pont csatlakozással véletlenszerűen GOOD, EXCELLENT és WRONG üzeneteket küld másodpercenként.  +  * Az első komponenst, ami a mérőgépre helyezett érzékelőre kapcsolódik a '**qualityQueue**' üzenetsorra pont-pont csatlakozással véletlenszerűen GOOD, EXCELLENT és WRONG üzeneteket küld másodpercenként.  
-  * **Készítsen egy komponenst** amely a 'GOOD', 'EXCELLENT' és a 'WRONG' üzeneteket leolvassa a qualityQueue sorról és gyűjti. Minden 10 megkapott azonos üzenet után a 'qualityStatistics' sorra küld egy üzenetet, amiben azt jelzi, hogy 10 (adott minőségű) üzenetet feldolgozott.  +  * **Készítsen egy második komponenst** amely a 'GOOD', 'EXCELLENT' és a 'WRONG' üzeneteket leolvassa a **qualityQueue** sorról és gyűjti. Minden 10 megkapott azonos üzenet után a '**qualityStatistics**' sorra küld egy üzenetet, amiben azt jelzi, hogy 10 (adott minőségű) üzenetet feldolgozott.  
-  * **Készítsen egy második klienst**, ami a 'qualityStatistics' sorrol olvassa a statisztikát és a konzolba kiírja hogy pl. '10 'WRONG' messages has been processed'+  * **Készítsen egy harmadik komponenst**, ami a 'qualityStatistics' sorrol olvassa a statisztikát és a konzolba kiírja hogy pl. '10 'WRONG' messages has been processed'
  
-A fenti feladatot a http://docker.iit.uni-miskolc.hu-n keretrendszerben oldjuk meg.+<mermaid> 
 +flowchart TB 
 +    MQ[("RabbitMQ Server\n(qualityQueue, qualityStatistics)")] 
 +    Client1["Component 1\n(Sensor Data Sender)"] -->|sends GOOD/EXCELLENT/WRONG| MQ 
 +    Client2["Component 2\n(Quality Message Consumer)"] -- collects messages --> MQ 
 +    Client2 -->|sends batch of 10 messages| MQ 
 +    Client3["Component 3\n(Statistics Consumer)"] -- receives and prints batches --> MQ 
 + 
 +    subgraph Docker 
 +    MQ 
 +    end 
 + 
 +    subgraph Components 
 +    Client1 
 +    Client2 
 +    Client3 
 +    end 
 + 
 +    classDef machine fill:#f9f,stroke:#333,stroke-width:2px; 
 +    classDef clients fill:#ccf,stroke:#333,stroke-width:2px; 
 +    class Docker machine; 
 +    class Client1,Client2,Client3 clients; 
 + 
 +</mermaid> 
 + 
 +A fenti feladatot a http://docker.iit.uni-miskolc.hu keretrendszerben oldjuk meg.
  
 === RabbitMQ indítása docker-ben === === RabbitMQ indítása docker-ben ===
Line 14: Line 39:
  
 <code> <code>
-docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3.11-management+docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:management-alpine
 </code> </code>
  
-A futtatás után a rabitMQ management konzol elérhető az 15672-es porton, a guest/guest megadásával. A bal oldali listában láthatjuk a node1 10.x.y.z belső IP címét, amit használhatunk a kliensekben.+A futtatás után a rabitMQ management konzol elérhető az 15672-es porton, a guest/guest megadásával. A bal oldali listában láthatjuk a node1 10.x.y.z belső IP címét, amit használhatunk a kliensekben és a feldolgozóban.
  
 Hozzunk létre egy másik konzolt és indítsuk el az alábbi parancsot: Hozzunk létre egy másik konzolt és indítsuk el az alábbi parancsot:
Line 27: Line 52:
 Ezzel telepítettük a pika modult, ami a rabbitMQ-hoz való csatlakozást biztosítja. Ezzel telepítettük a pika modult, ami a rabbitMQ-hoz való csatlakozást biztosítja.
  
-Hozzuk létre a quality_message_sender.py-t:+Hozzuk létre a **quality_message_sender.py**-t:
  
-<code python>+Használjuk a megfelelő IP-t a //__init__(self):// ben 
 + 
 +<sxh python>
 import pika import pika
 import random import random
 import time import time
- 
  
 class QualitySender: class QualitySender:
     def __init__(self):     def __init__(self):
-        self.connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))+        self.connection = pika.BlockingConnection(pika.ConnectionParameters('10.x.y.z'))
         self.channel = self.connection.channel()         self.channel = self.connection.channel()
         self.channel.queue_declare(queue='qualityQueue')         self.channel.queue_declare(queue='qualityQueue')
Line 51: Line 77:
     def close_connection(self):     def close_connection(self):
         self.connection.close()         self.connection.close()
- 
  
 if __name__ == '__main__': if __name__ == '__main__':
Line 60: Line 85:
         sender.close_connection()         sender.close_connection()
  
-</code>+</sxh>
  
-<code python> +A második komponenshez indítsunk egy új konzolt:
-import pika+
  
 +A //__init__(self):// konstruktorban állítsuk be a rabbitMQ szerver IP címét
 +
 +<sxh python>
 +import pika
  
 class QualityConsumer: class QualityConsumer:
Line 102: Line 130:
     def close_connection(self):     def close_connection(self):
         self.connection.close()         self.connection.close()
- 
  
 if __name__ == '__main__': if __name__ == '__main__':
Line 111: Line 138:
         consumer.close_connection()         consumer.close_connection()
  
 +</sxh>
  
-</code>+Készítsük el a statisztika kiírását egy új konzolban: 
 + 
 +<sxh python> 
 +import pika 
 + 
 +# RabbitMQ settings 
 +connection = pika.BlockingConnection(pika.ConnectionParameters('10.x.y.z')) 
 +channel = connection.channel() 
 + 
 +channel.queue_declare(queue='qualityStatistics') 
 + 
 +def callback(ch, method, properties, body): 
 +    message = body.decode() 
 +    print(f'{message}') 
 +    ch.basic_ack(delivery_tag=method.delivery_tag) 
 + 
 +channel.basic_consume(queue='qualityStatistics', on_message_callback=callback) 
 + 
 +print('Waiting for quality statistics...') 
 +channel.start_consuming() 
 +</sxh>
  
  
 +**Feladat:**
  
 +A 15672-es porton lépjük be a rabbitMQ management console-ra és vizsgáljuk meg a lehetőségeit.
  
  
tanszek/oktatas/informacios_rendszerek_integralasa/uezenetsorok-rabbitmq_2.1683530222.txt.gz · Last modified: 2023/05/08 07:17 by knehez