Hé! A redőnyök tavaszi szállítója vagyok, és ma szeretnék beszélgetni arról, hogyan lehet a mikroszolgáltatások kommunikációját tavasszal kezelni a redőnyök számára. Ez egy kicsit műszaki téma, de mindent megteszek, hogy könnyen érthető módon bontsam le.
Először beszéljünk arról, hogy miért olyan fontos a mikroszolgáltatások kommunikációja a redőnyök számára. A redőnyök világában van egy csomó különféle alkatrész és folyamat. Például megvan aHenger redőny oldalkeret 90 °, aHengeres redőny sebességváltó korona, és aHengeres redőny- Ezen alkatrészek mindegyikét a tavaszi alapú rendszerünkben eltérő mikroszolgáltatás kezelheti.
Amikor ezek a mikroszolgáltatások nem tudnak jól kommunikálni, olyan, mintha egy csomó ember egy gyárban nem beszélne egymással. Végül késéssel, hibákkal és rengeteg fejfájással jár. Tehát meg kell győződnünk arról, hogy ezek a mikroszolgáltatások zökkenőmentesen megoszthatják az információkat.
A mikroszolgáltatások kommunikációjának tavasszal történő kezelésének egyik legfontosabb módja a RESTful API -k révén. A REST (reprezentációs állami átadás) egy igazán népszerű módszer a webszolgáltatások felépítésére. A redőnyrendszer tavaszán minden mikroszolgáltatáshoz RESTful végpontot hozhatunk létre. Például, ha van olyan mikroszolgáltatónk, amely kezeli a [Roller Redőny Sidter 90 °] leltárát, akkor felfedezheti a REST API -t, amelyet más mikroszolgáltatások felhasználhatnak a készletszintek ellenőrzésére.
Íme egy egyszerű példa arra, hogyan tudunk tavasszal létrehozni egy RESTful API -t. A Spring Boot -ot használjuk, amely nagyszerű keret a tavaszi alapú alkalmazások gyors felépítéséhez.
import org.springframework.boot.springApplication; import org.springframework.boot.autoconfigure.springbootApplication; import org.springframework.web.bind.annotation.getMapping; import org.springframework.web.bind.annotation.restController; @SpringBootApplication @RestController public Class ShutterinVentoryService {public static void main (String [] args) {SpringApplication.run (ShutterinVentoryService.Class, Args); } @GetMapping ("/leltár/roller-shutter-oldal-keret-90") public int getRollerShuttersideFrame90Inventory () {// itt valójában lekérdeznénk az adatbázist, hogy a készletszámlálást megkapjuk 10; }}Ebben a kódexben létrehoztunk egy egyszerű RESTful API -t, amely visszaadja a [Roller redőny oldalkeret 90 °] leltárszámát. Más mikroszolgáltatások ezt követően felhívhatják ezt az API -t a HTTP -k segítségével, hogy kérjék a szükséges információkat.
A mikroszolgáltatások kommunikációjának másik fontos szempontja az üzenet alapú kommunikáció. A tavasz nagyszerű támogatást nyújt az üzenet alapú rendszerekhez olyan technológiákon keresztül, mint a Spring Cloud Stream. Az üzenet alapú kommunikációval a mikroszolgáltatások aszinkron módon küldhetnek és fogadhatnak üzeneteket.
Tegyük fel, hogy van egy mikroszolgáltatásunk, amely feldolgozza a [Roller Shutter Crank kerék] megrendeléseit. A megrendelés elhelyezésekor ez a mikroszolgáltatás üzenetet küldhet egy üzenet -brókernek (például a KAFKA vagy a RabbitMQ). Más mikroszolgáltatások, például a készletkezelés mikroszolgáltatása, ezután meghallgathatják ezeket az üzeneteket, és ennek megfelelően frissíthetik a leltárt.
Íme egy példa arra, hogyan használhatjuk a Spring Cloud Stream használatát üzenetek küldéséhez és fogadásához:
import org.springframework.cloud.stream.annotation.enableBinding; import org.springframework.cloud.stream.annotation.input; import org.springframework.cloud.stream.annotation.output; import org.springframework.cloud.stream.annotation.streamListener; import org.springframework.messaging.messageChannel; import org.springframework.messaging.support.messageBuilder; import org.springframework.stereotype.service; Import Java.util.logging.logger; Interface ShutterOrderChannels {String input = "Shutter - Rendelés - Input"; Karakterlánc output = "Shutter - Rendelés - Output"; @Input (input) org.springframework.messaging.subscripleChannel input (); @Output (output) messageChannel output (); } @EnableBinding (ShutterOrderChannels.class) @service nyilvános osztály ShutterOrorderService {privát statikus végleges naplózó logger = logger.getLogger (ShutterorderService.class.getName ()); privát végleges ShutterOrderChannels csatornák; public ShutterOrorderService (ShutterOrderChannels csatornák) {this.Channels = csatornák; } public void sendOderMessage (karakterláncrendelés) {channels.output (). Küldés (messageBuilder.WithPayLoad (rend) .Build ()); } @StreamListener (ShutterOrderChannels.input) public void HanderOrderMessage (karakterláncrendelés) {logger.info ("Váltás:" + rendelés); // itt megtehetünk valamit a megrendeléssel, például a leltár frissítésével}Ebben a kódexben létrehoztunk egy szolgáltatást, amely a redőny megrendeléseivel kapcsolatos üzeneteket küldhet és fogadhat. Ilyen módon a különböző mikroszolgáltatások aszinkron és elválasztott módon kommunikálhatnak egymással.
A mikroszolgáltatások kommunikációjának valódi világ forgatókönyveinek kezelése során gondolkodnunk kell a szolgáltatás felfedezéséről is. Egy nagy rugóban a redőnyök számára tucatnyi vagy akár több száz mikroszolgáltatás lehet. Az egyes mikroszolgáltatások számára nem praktikus, hogy megismerje minden más mikroszolgáltatás pontos helyét (IP -címe és portja), amelyhez kommunikálnia kell.
A Spring Cloud Netflix Eureka nagyszerű eszköz a szolgáltatás felfedezéséhez. A mikroszolgáltatások regisztrálhatják magukat az EUREKA szerveren, és más mikroszolgáltatások, majd megkereshetik a szükséges szolgáltatások helyét az EUREKA szerveren keresztül.
Így állíthatunk be egy Eureka -kiszolgálót a Spring Boot -ban:
import org.springframework.boot.springApplication; import org.springframework.boot.autoconfigure.springbootApplication; import org.springframework.cloud.netflix.eureka.server.enableeureKaserver; @SpringbootApplication @enableEureKaserver nyilvános osztályú ShuttereErekAserver {public Static void main (String [] args) {SpringApplication.run (ShuttereureKaserver.Class, Args); }}És így van egy mikroszolgáltatás regisztrálása az EUREKA szerveren:
import org.springframework.boot.springApplication; import org.springframework.boot.autoconfigure.springbootApplication; import org.springframework.cloud.netflix.eureka.enableeureKaclient; @SpringBootApplication @enableEureKaClient nyilvános osztályú ShutTermicRoservice {nyilvános statikus void main (String [] args) {SpringApplication.run (ShutTermicRoservice.Class, Args); }}Az Eureka használatával mikroszolgáltatásaink könnyen megtalálhatók és kommunikálhatnak egymással anélkül, hogy keményen kellene kódolniuk a szolgáltatási helyeket.
Összegezve, a mikroszolgáltatások kommunikációjának tavaszi kezelése redőnyök számára elengedhetetlen üzleti tevékenységünk zökkenőmentes működéséhez. Legyen szó a RESTful API -k, az üzenet -alapú kommunikációról vagy a szolgáltatás felfedezéséről, sok eszközünk van a rendelkezésünkre.
Ha a magas színvonalú rugót a redőnyök számára a magas színvonalú rugó piacán tartózkodik, és érdekli, hogyan kezeljük a mikroszolgáltatásainkat a legfelsőbb minőség és a hatékonyság biztosítása érdekében, szeretnék beszélgetni veled. Megbeszélhetjük az Ön egyedi igényeit és azt, hogy termékeink hogyan illeszkedhetnek az Ön vállalkozásához. Ne habozzon, keresse fel a beszerzési vitát.
Referenciák
- Tavaszi rendszerindító dokumentáció
- Tavaszi felhő dokumentáció
- RESTFUL API Design bevált gyakorlatok
- Üzenet alapú kommunikáció az elosztott rendszerekben
