Bevezetés a RabbitMQ-ba

1. Áttekintés

A szoftverkomponensek leválasztása a szoftvertervezés egyik legfontosabb része. Ennek egyik módja az üzenetkezelő rendszerek használata, amelyek aszinkron módon biztosítják a kommunikációt az összetevők (szolgáltatások) között. Ebben a cikkben az egyik ilyen rendszerrel foglalkozunk: RabbitMQ.

A RabbitMQ egy üzenetközvetítő, amely az Advanced Message Queuing Protocol (AMQP) protokollt valósítja meg. Kliens könyvtárakat biztosít a főbb programozási nyelvekhez.

A szoftverkomponensek szétkapcsolása mellett a RabbitMQ használható:

  • Háttérműveletek végrehajtása
  • Aszinkron működés végrehajtása

2. Üzenetmodell

Először nézzük meg gyorsan, magas szinten az üzenetek működését.

Egyszerűen fogalmazva, kétféle alkalmazás van kölcsönhatásban egy üzenetkezelő rendszerrel: a gyártók és a fogyasztók. A termelők azok, akik üzeneteket küldenek (tesznek közzé) egy brókernek, és a fogyasztók, akik üzeneteket kapnak a brókertől. Általában ezek a programok (szoftver-alkatrészek) különböző gépeken futnak, és a RabbitMQ kommunikációs köztes szoftverként működik közöttük.

Ebben a cikkben egy egyszerű példát tárgyalunk két szolgáltatással, amelyek a RabbitMQ használatával fognak kommunikálni. Az egyik szolgáltatás üzeneteket fog közzétenni a RabbitMQ-n, a másik pedig fogyasztani fog.

3. Beállítás

Kezdetben futtassuk a RabbitMQ-t az itt található hivatalos telepítési útmutató használatával.

Természetesen a Java klienst használjuk a RabbitMQ szerverrel való interakcióhoz; ennek az ügyfélnek a Maven-függősége:

 com.rabbitmq amqp-client 4.0.0 

Miután lefuttattuk a RabbitMQ brókert a hivatalos útmutató segítségével, csatlakoznunk kell hozzá a java kliens segítségével:

ConnectionFactory gyár = new ConnectionFactory (); factory.setHost ("localhost"); Csatlakozási kapcsolat = gyár.newConnection (); Csatornacsatorna = connection.createChannel (); 

Használjuk a ConnectionFactory a szerverrel való kapcsolat beállításához gondoskodik a protokollról (AMQP) és a hitelesítésről is. Itt csatlakozunk a szerverhez helyi kiszolgáló, a gazdagép nevét a setHost funkció.

Tudjuk használni setPort a port beállításához, ha az alapértelmezett portot nem a RabbitMQ Server használja; az alapértelmezett port a RabbitMQ számára 15672:

gyár.setPort (15678);

Beállíthatjuk a felhasználónevet és a jelszót:

factory.setUsername ("user1"); factory.setPassword ("MyPassword");

Továbbá ezt a kapcsolatot fogjuk használni üzenetek közzétételéhez és felhasználásához.

4. Producer

Vegyünk egy egyszerű forgatókönyvet ahol egy webalkalmazás lehetővé teszi a felhasználók számára, hogy új termékeket adjanak hozzá egy webhelyhez. Bármely új termék hozzáadásakor e-mailt kell küldenünk az ügyfeleknek.

Először határozzunk meg egy sort:

channel.queueDeclare ("products_queue", hamis, hamis, hamis, null);

Minden alkalommal, amikor a felhasználók új terméket vesznek fel, üzenetet teszünk közzé a sorban:

String üzenet = "termék részletei"; channel.basicPublish ("", "products_queue", null, message.getBytes ());

Végül bezárjuk a csatornát és a kapcsolatot:

csatorna.zár (); kapcsolat.zár ();

Ezt az üzenetet egy másik szolgáltatás veszi fel, amely felelős az e-mailek küldéséért az ügyfeleknek.

5. Fogyasztó

Lássuk, mit tudunk megvalósítani a fogyasztói oldalon; ugyanezt a sort állítjuk be:

channel.queueDeclare ("products_queue", hamis, hamis, hamis, null);

Így határozhatjuk meg azt a fogyasztót, aki aszinkron módon dolgozza fel a várólista üzeneteit:

DefaultConsumer consumer = new DefaultConsumer (channel) {@Orride public void handleDelivery (String consumerTag, Envelope boríték, AMQP.BasicProperties tulajdonságok, bájt [] törzs) dobja az IOException {String üzenet = új String (törzs, "UTF-8"); // az üzenet feldolgozása}}; channel.basicConsume ("products_queue", true, consumer);

6. Következtetés

Ez az egyszerű cikk a RabbitMQ alapfogalmaival foglalkozott, és egy egyszerű példát tárgyalt annak használatáról.

Az oktatóanyag teljes megvalósítása megtalálható a GitHub projektben.