Παράδειγμα δημιουργίας παραγγελίας. Υπάρχει ένα αίτημα προς την υπηρεσία και μια απάντηση, μεταξύ αυτών των δύο ενεργειών υπάρχει μια ανταλλαγή προϊόντων μεταξύ υπηρεσιών και εξωτερικών που περιγράφονται (π.χ. για τον υπολογισμό της δημοφιλίας των προϊόντων). Η υπηρεσία εκτελείται πολλές φορές, λειτουργεί αργά ή ακόμα και timeout και δεν προλαβαίνουμε να απαντήσουμε, χάνουμε την παραγγελία. Τι να κάνουμε για να σταματήσουμε να χάνουμε παραγγελίες και χρήματα;

Чтобы не терять заказы из-за медленной работы сервиса или таймаутов, нужно перейти от синхронной обработки к асинхронной и обеспечить надежную доставку сообщений.

Основные подходы:

1. Использование очередей сообщений (например, Kafka, RabbitMQ). Вместо того, чтобы ждать ответа от внешних сервисов, заказ помещается в очередь, и сервис сразу подтверждает прием заказа. Обработка заказа происходит асинхронно, что исключает потерю из-за таймаутов.

2. Идём по паттерну "Event Sourcing" или "CQRS" — запись события создания заказа в журнал, а затем асинхронная обработка и обновление состояния.

3. Реализация механизма повторных попыток (retry) и отложенной обработки (dead-letter queue) для обработки неудачных сообщений.

4. Мониторинг и алерты — чтобы быстро реагировать на сбои.

Пример на Java с использованием Kafka (упрощённо):

// Отправка заказа в Kafka
producer.send(new ProducerRecord<>("orders", orderId, orderData));
// Сервис сразу отвечает клиенту, что заказ принят

Таким образом, заказ не теряется, даже если внешние сервисы работают медленно или недоступны.