Hei acolo! Sunt un furnizor de primăvară pentru obturator, iar astăzi vreau să vorbesc despre cum să gestionez comunicarea microservicii în primăvară pentru produsele noastre de obturare. Este un subiect tehnic, dar voi face tot posibilul să -l descompun într -un mod ușor de înțeles.
În primul rând, să vorbim despre motivul pentru care comunicarea microservicii este atât de importantă pentru primăvara noastră pentru obturatorul. În lumea producției de obloane, avem o grămadă de componente și procese diferite. De exemplu, avemCadru lateral al obturatorului cu role 90 °, TheCoroana de transmisie a obturatorului cu role, și TheRoată cu manivelă de cotitură cu role. Fiecare dintre aceste părți ar putea fi gestionată de un microserviciu diferit în sistemul nostru bazat pe primăvară.
Când aceste microservicii nu pot comunica bine, este ca și cum ai avea o grămadă de oameni într -o fabrică să nu vorbească între ei. Terminați cu întârzieri, greșeli și o mulțime de dureri de cap. Deci, trebuie să ne asigurăm că aceste microservicii pot împărtăși informații fără probleme.
Unul dintre modalitățile cheie de a gestiona comunicarea microservicii în primăvară este prin API -uri odihnitoare. Rest (Reprezentant State Transfer) este un mod cu adevărat popular de construire a serviciilor web. În arcul nostru pentru sistemul de declanșare, putem crea obiective odihnitoare pentru fiecare microserviciu. De exemplu, dacă avem un microservice care gestionează inventarul [cadru lateral al obturatorului cu role 90 °], poate expune o API REST pe care alte microservicii îl pot utiliza pentru a verifica nivelurile de stoc.
Iată un exemplu simplu despre modul în care putem crea o API odihnitoare în primăvară. Vom folosi Spring Boot, care este un cadru excelent pentru construirea rapidă a aplicațiilor bazate pe primăvară.
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 ("/inventar/roller-obturator-side-frame-90") public int getrollerShuttersideFrame90Inventtory () {// Aici am interoga de fapt baza de date pentru a obține numărul de inventar returând 10; }}În acest cod, am creat o API simplă RESTful care returnează numărul de inventar al [cadrului lateral al obturatorului cu role 90 °]. Alte microservicii pot apela apoi această API folosind HTTP GET GET pentru a obține informațiile de care au nevoie.
Un alt aspect important al comunicării microservicii este comunicarea bazată pe mesaje. Spring oferă un suport excelent pentru sistemele bazate pe mesaje prin tehnologii precum Spring Cloud Stream. Cu comunicarea bazată pe mesaje, microserviciile pot trimite și primi mesaje asincron.
Să zicem că avem un microserviciu care procesează comenzi pentru [roata manivelă a obturatorului cu role]. Când este plasată o comandă, acest microservice poate trimite un mesaj unui broker de mesaje (cum ar fi Kafka sau RabbitMQ). Alte microservicii, cum ar fi microserviciul de gestionare a inventarului, pot asculta aceste mesaje și actualiza inventarul în consecință.
Iată un exemplu despre modul în care putem folosi Spring Cloud Stream pentru a trimite și primi mesaje:
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; Interfață ShutterOrderChannels {String input = "Shutter - Order - Intrare"; String output = "obturator - comandă - ieșire"; @Input (intrare) org.springframework.messaging.subscribableChannel input (); @Output (ieșire) messageChannel output (); } @EnableBinding (ShutterOrderChannels.Class) @Service Public Class ShutteRorderService {private static final logger logger = logger.getLogger (ShutterOrderService.class.getName ()); Canalele ShutterRoderChannels finale private finale; public ShutterRorService (canale ShutterOrderChannels) {this.Channels = canale; } public void sendOrdeMessage (String comanda) {Channels.output (). Send (MessageBuilder.withPayload (comandă) .Build ()); } @StreamListener (ShutterOrderChannols.input) public void HandleRoderMessage (String Order) {logger.info ("comandă primită:" + ordin); // Aici putem face ceva cu comanda, cum ar fi inventarul de actualizare}}În acest cod, am creat un serviciu care poate trimite și primi mesaje legate de comenzi de obturare. În acest fel, microservicii diferite pot comunica între ele într -un mod asincron și decuplat.
Când vine vorba de gestionarea comunicării microservicii într -un scenariu real, de asemenea, trebuie să ne gândim la descoperirea serviciilor. Într -un arc mare pentru un sistem de obturare, ar putea exista zeci sau chiar sute de microservicii. Nu este practic pentru fiecare microservice să cunoască locația exactă (adresa IP și portul) a oricărui alt microserviciu cu care trebuie să comunice.
Spring Cloud Netflix Eureka este un instrument excelent pentru descoperirea serviciilor. Microservicii se pot înregistra la serverul Eureka, iar alte microservicii pot căuta apoi locația serviciilor de care au nevoie prin serverul Eureka.
Iată cum putem configura un server Eureka în Spring Boot:
import org.springframework.boot.springapplication; import org.springframework.boot.autoconfigure.springbootApplication; import org.springframework.cloud.netflix.eureka.server.enableEurekAServer; @SPringBootApplication @EnableEureKAServer public class ShutteReureKAServer {public static void main (String [] args) {springApplication.run (ShuttereKasever.class, args); }}Și iată cum se poate înregistra un microservice la serverul Eureka:
import org.springframework.boot.springapplication; import org.springframework.boot.autoconfigure.springbootApplication; import org.springframework.cloud.netflix.eureka.enableEureKaclient; @SPringBootApplication @EnableEureKaclient public clasa ShuttermicRoService {public static void main (String [] args) {springApplication.run (ShuttermicRoservice.class, args); }}Folosind Eureka, microserviciile noastre pot găsi și comunica cu ușurință între ele fără a fi nevoiți să codificați locațiile de serviciu.
În concluzie, gestionarea comunicării microservicii în primăvară pentru produsele noastre obturatoare este crucială pentru funcționarea lină a activității noastre. Indiferent dacă este vorba de API -uri odihnitoare, de comunicare bazată pe mesaje sau de descoperire a serviciilor, avem o mulțime de instrumente la dispoziția noastră.
Dacă sunteți pe piață pentru arc de înaltă calitate pentru produsele de obloane și sunteți interesat de modul în care ne gestionăm microserviciile pentru a ne asigura calitatea și eficiența de top, mi -ar plăcea să discutăm cu tine. Putem discuta despre nevoile dvs. specifice și modul în care produsele noastre se pot încadra în afacerea dvs. Nu ezitați să ajungeți la o discuție de achiziții.
Referințe
- Documentația de cizme de primăvară
- Documentația Cloud Spring
- Restful API Design Cele mai bune practici
- Mesaj - comunicare bazată pe sisteme distribuite
