Bevezetés az AMQP protokollba
Az AMQP (Advanced Message Queuing Protocol) egy alkalmazásrétegi szabványos protokoll, amely egységes üzenetküldő szolgáltatásokat nyújt, és nyílt szabvány az alkalmazási szintű protokollok számára, amelyeket üzenetorientált közműszoftverhez terveztek. Az AMQP egy hálózati protokoll, amely aszinkron üzeneteket továbbít folyamatok között.
Az ezen protokollon alapuló kliensek és üzenetközmű anélkül tudnak üzeneteket továbbítani, hogy különböző kliens/middleware termékek, különböző fejlesztői nyelvek stb. korlátoznák őket.
Az AMQP fő jellemzői az üzenetorientáltság, sorba helyezés, útválasztás (beleértve peer-to-peer és publikálás/előfizetést), megbízhatóság és biztonság. Az AMQP érvényesíti az üzenetszolgáltatók és ügyfelek viselkedését, lehetővé téve a valódi interoperabilitást a különböző szolgáltatók között.
Útvonali üzenetek
Az AMQP architektúrában bármely sikeres üzenetútozás három részből áll:
- Exchange: Ahol a producerek üzeneteket közölnek
- Sorok: Ahol a fogyasztók üzeneteket kapnak
- Kötések: Hogyan irányítják az üzeneteket a kapcsolóról egy adott sorba
Csere- és kötőrendszerek
Hogyan jut el az üzenet a sorba? Amikor üzenetet szeretnél eljuttatni egy fogyasztóhoz, először el kell küldened a váltónak. Ezután bizonyos szabályok vagy útvonalkulcsok alapján a RabbitMQ dönt arról, melyik sorba küldi az üzeneteket.
A szabályok – vagy útvonalkulcsok – lehetővé teszik, hogy egy sorba köthess a cserehöz. A RabbitMQ megpróbálja összeegyeztetni az üzenetben szereplő útvonalkulcsot a kötésben használt kulcshoz. Az üzenetet ezután a sorba juttatják a négy cseretípus egyike alapján: fanout, topic, direct, header
Fanout Exchange
Ez a cseretípus minden kapott üzenetet továbbít az összes hozzá kötött sorba. A közzétett üzenethez mellékelt útvonalkulcsokat figyelmen kívül hagyjuk.
Témacsere
Ebben a fajta csereben az üzeneteket a sorba küldik az útvonalkulcs alapján. Ez azt jelenti, hogy a témacsere üzeneteinek meghatározott útvonalkulcsa kell legyen, amely egy szavak listájának kell lennie, pontokkal elválasztva (pl. 'acs.deviceoperations.'). A megfogalmazási határ 255 bájt.
A kötési kulcsnak ugyanabban a formátumban kell lennie, mint az útvonalkulcsnak. Ezért a meghatározott útvonaltartó kulmával küldött üzenetek minden sorhoz egy hozzá tartozó kötő kulmánnyal érkeznek.
A kötési kulcsok lehetővé teszik a következő kifejezési szabályokat:
*(csillag) csak egy szót helyettesíthet
# (hash) helyettesítheti nulla vagy több szót
Ha egy sorba egy "#" (hash) kötő kulmilla van kötve, minden üzenetet megkap, függetlenül az útvonalkulcstól, pont úgy, mint egy Fanout fan-out csere esetén.
Közvetlen csere
Amikor egy sorban áll, az így fogAutomatikusan kötözz egy switchhez, amely a sornévet használja az útvonalkulcsként。 Ha az útvonalkulcs egyezik, az üzenet a megfelelő sorba kerül.
Fejléccsere
A fejléckapcsolók valamennyire hasonlóak a témakapcsolókhoz, de a témakapcsolókkal ellentétben az útvonal kulcsokon alapul, a fejléckapcsolók útvonalértékei pedig az üzenet fejlécadatain alapulnak.
A témakapcsoló útvonalkulcsa csak egy string, míg a fejléckapcsoló lehet egész szám és hash.
(Vége)
|
Közzétéve 2022. 08. 14. 23:32:43
|
|
|
|
