Sobes.tech
Senior
150

Am Beispiel der Auftragserstellung. Es gibt eine Anfrage an den Service und eine Antwort, zwischen diesen beiden Aktionen gibt es einen Austausch von Produkten zwischen den Diensten und externen, die beschrieben sind (z.B. zur Zählung der Beliebtheit von Produkten). Der Service wird mehrfach ausgeführt, arbeitet langsam oder timeoutet sogar ganz, und wir schaffen es nicht zu antworten, wir verlieren die Bestellung. Was tun, um keine Bestellungen und somit Geld mehr zu verlieren?

Unternehmen wurden gefragt
Ozon ФинтехOzon Финтех

Antwort von AI

sobes.tech KI

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

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

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

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

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

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

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

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

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