Wie erfolgt der Informationsaustausch zwischen Microservices in der Systemarchitektur?

Die Kommunikation zwischen Microservices erfolgt in der Regel über zwei Hauptansätze:

1. Synchrone Interaktion — mittels REST API oder gRPC. Microservices senden HTTP-Anfragen aneinander und warten auf eine Antwort. Das ist einfach und verständlich, kann aber zu Verzögerungen und Problemen bei der Fehlertoleranz führen.

2. Asynchrone Interaktion — über Messaging-Systeme (Message Broker) wie Kafka, RabbitMQ oder ActiveMQ. Microservices veröffentlichen Ereignisse oder Nachrichten in eine Warteschlange, und andere abonnieren diese. Dieser Ansatz erhöht die Skalierbarkeit und die Systemresilienz.

Beispiel für einen synchronen REST-Aufruf in Java mit Spring Boot:

@RestController
public class OrderController {

    private final PaymentService paymentService;

    public OrderController(PaymentService paymentService) {
        this.paymentService = paymentService;
    }

    @PostMapping("/order")
    public ResponseEntity<String> createOrder(@RequestBody Order order) {
        boolean paymentResult = paymentService.processPayment(order.getPaymentInfo());
        if (paymentResult) {
            return ResponseEntity.ok("Order created");
        } else {
            return ResponseEntity.status(HttpStatus.PAYMENT_REQUIRED).body("Payment failed");
        }
    }
}

Hier kann PaymentService ein Client eines anderen Microservices sein.

Für asynchrone Kommunikation kann Kafka Producer und Consumer verwendet werden, wobei ein Service ein Ereignis veröffentlicht und ein anderer es abhört und verarbeitet.