Ehilà! Sono un fornitore di primavera per l'otturatore, e oggi voglio parlare di come gestire la comunicazione dei microservizi in primavera per i nostri prodotti di scatto. È un po 'un argomento tecnico, ma farò del mio meglio per scomporlo in un modo facile da capire.
Prima di tutto, parliamo del motivo per cui la comunicazione dei microservizi è così importante per la nostra primavera per il business dell'otturatore. Nel mondo della produzione di shutter, abbiamo un sacco di componenti e processi diversi. Ad esempio, abbiamo ilFrame laterale dell'otturatore a rulli 90 °, ILCorona di trasmissione dell'otturatore a rullie ilRuota a manovella dell'otturatore rullo. Ognuna di queste parti potrebbe essere gestita da un diverso microservizio nel nostro sistema basato sulla molla.
Quando questi microservizi non possono comunicare bene, è come avere un mucchio di persone in una fabbrica che non si parla. Finisci con ritardi, errori e un sacco di mal di testa. Quindi, dobbiamo assicurarci che questi microservizi possano condividere le informazioni senza intoppi.
Uno dei modi chiave per gestire la comunicazione dei microservizi in primavera è attraverso le API RESTful. Rest (Repupertional State Transfer) è un modo davvero popolare per costruire servizi web. Nella nostra primavera per il sistema di otturatore, possiamo creare endpoint riposanti per ogni microservizio. Ad esempio, se abbiamo un microservizio che gestisce l'inventario di [frame laterale dell'otturatore a rullo 90 °], può esporre un'API di riposo che altri microservizi possono utilizzare per controllare i livelli di serie.
Ecco un semplice esempio di come possiamo creare un'API riposante in primavera. Useremo Spring Boot, che è un ottimo quadro per costruire rapidamente applicazioni basate sulla molla.
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 Classe pubblica ShutterInventoryService {public static void main (String [] args) {SpringApplication.run (ShutterInventoryService.class, args); } @Getmapping ("/inventario/rullo-shutter-lato-frame-90") pubblico int getrollershuttersideFrame90Inventory () {// Qui in realtà interrogheremmo il database per ottenere il reso del conteggio dell'inventario 10; }}In questo codice, abbiamo creato una semplice API RESTful che restituisce il conteggio dell'inventario del [frame laterale dell'otturatore a rulli 90 °]. Altri microservizi possono quindi chiamare questa API utilizzando le richieste HTTP per ottenere le informazioni di cui hanno bisogno.
Un altro aspetto importante della comunicazione dei microservizi è la comunicazione basata sul messaggio. Spring offre un ottimo supporto per i sistemi basati su messaggi attraverso tecnologie come Spring Cloud Stream. Con la comunicazione basata sul messaggio, i microservizi possono inviare e ricevere messaggi in modo asincrono.
Supponiamo che abbiamo un microservizio che elabora gli ordini per la [ruota a mano otura a rullo]. Quando viene effettuato un ordine, questo microservizio può inviare un messaggio a un broker di messaggi (come Kafka o RabbitMQ). Altri microservizi, come il microservizio di gestione dell'inventario, possono quindi ascoltare questi messaggi e aggiornare l'inventario di conseguenza.
Ecco un esempio di come possiamo usare Spring Cloud Stream per inviare e ricevere messaggi:
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; interfaccia ShutterOrderChannels {String input = "Shutter - Order - Input"; String output = "Shutter - ordine - output"; @Input (input) org.springFramework.messaging.subscripableChannel Input (); @Output (output) messageChannel output (); } @EnableBinding (ShutterOrderChannels.class) @Service Public Class ShutterorDerService {Logger Final Logger statico privato = logger.getLogger (Shutterorderservice.class.getName ()); Canali privati finali ShutterorderCannels; Public ShutterordeRservice (canali di shutterorderCannels) {this.channels = canali; } public void SendOrderMessage (String Order) {Channels.output (). Send (messageBuilder.WithPayload (Order) .Build ()); } @StreamListener (ShutterOrderChannels.Input) public void HandleOrderMessage (String Order) {logger.info ("ordine ricevuto:" + ordine); // Qui possiamo fare qualcosa con l'ordine, come l'inventario degli aggiornamenti}In questo codice, abbiamo creato un servizio in grado di inviare e ricevere messaggi relativi agli ordini dell'otturatore. In questo modo, diversi microservizi possono comunicare tra loro in modo asincrono e disaccoppiato.
Quando si tratta di gestire la comunicazione dei microservizi in uno scenario mondiale reale, dobbiamo anche pensare alla scoperta del servizio. In una grande molla per il sistema di otturatore, potrebbero esserci dozzine o addirittura centinaia di microservizi. Non è pratico per ogni microservizio conoscere la posizione esatta (indirizzo IP e porta) di ogni altro microservizio con cui ha bisogno per comunicare.
Spring Cloud Netflix Eureka è un ottimo strumento per la scoperta del servizio. I microservizi possono registrarsi con il server Eureka e altri microservizi possono quindi cercare la posizione dei servizi di cui hanno bisogno attraverso il server Eureka.
Ecco come possiamo impostare un server Eureka in Spring Boot:
import org.springframework.boot.springapplication; import org.springframework.boot.autoconfigure.springbootapplication; import org.springframework.cloud.netflix.eureka.server.enableeurekaserver; @Springbootapplication @enableeurekaserver classe pubblica shuttereurekaserver {public static void main (string [] args) {SpringApplication.run (ShutteureureKaserver.class, args); }}Ed ecco come un microservizio può registrarsi con il server Eureka:
import org.springframework.boot.springapplication; import org.springframework.boot.autoconfigure.springbootapplication; import org.springframework.cloud.netflix.eureka.enableeurekaclient; @Springbootapplication @enableeureKaclient Classe pubblica ShutterMicRoService {public static void main (string [] args) {SpringApplication.run (Shuttermicroservice.class, args); }}Utilizzando Eureka, i nostri microservizi possono facilmente trovare e comunicare tra loro senza dover codificare le posizioni del servizio.
In conclusione, la gestione della comunicazione dei microservizi in primavera per i nostri prodotti a scatto è fondamentale per il corretto funzionamento della nostra attività. Che si tratti di API RESTful, comunicazione basata sul messaggio o scoperta di servizi, abbiamo molti strumenti a nostra disposizione.
Se sei sul mercato per la primavera di alta qualità per i prodotti a scatto e sei interessato a come gestiamo i nostri microservizi per garantire la qualità ed efficienza di tacca, mi piacerebbe fare una chiacchierata con te. Possiamo discutere le tue esigenze specifiche e come i nostri prodotti possono adattarsi alla tua attività. Non esitare a raggiungere una discussione sugli appalti.
Riferimenti
- Documentazione di avvio a molla
- Documentazione della nuvola di primavera
- Best practice di design API RESTful
- Messaggio: comunicazione basata sui sistemi distribuiti
