Differences

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

--- tanszek:oktatas:informacios_rendszerek_integralasa:uezenetsorok-rabbitmq_2 [2023/06/30 11:32] – knehez
+++ tanszek: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:
-  * 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'
+<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.
@@ Line 27: / Line 52: @@
 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:
 Használjuk a megfelelő IP-t a //__init__(self):// ben
-<code python>
+<sxh python>
 import pika
 import random
@@ Line 60: / Line 85: @@
         sender.close_connection()
-</code>
+</sxh>
 A második komponenshez indítsunk egy új konzolt:
@@ Line 66: / Line 91: @@
 A //__init__(self):// konstruktorban állítsuk be a rabbitMQ szerver IP címét
-<code python>
+<sxh python>
 import pika
@@ Line 113: / Line 138: @@
         consumer.close_connection()
-</code>
+</sxh>
 Készítsük el a statisztika kiírását egy új konzolban:
-<code python>
+<sxh python>
 import pika
@@ Line 135: / Line 160: @@
 print('Waiting for quality statistics...')
 channel.start_consuming()
-</code>
+</sxh>