В мире распределенных систем транзакции саги – это популярный шаблон, используемый для управления сложными рабочими процессами, охватывающими несколько сервисов. В транзакции саги каждый шаг, известный как субтранзакция, выполняется независимо и может быть успешным или неудачным. В случае сбоя субтранзакции крайне важно правильно обработать сбой, чтобы обеспечить согласованность данных и обеспечить общую надежность системы. В этой статье мы рассмотрим различные методы обработки сбоев субтранзакций в транзакциях Saga, дополненные разговорными объяснениями и примерами кода.

Метод 1: компенсирующие действия
Одним из распространенных подходов к обработке сбоев субтранзакций являются компенсирующие действия. Компенсирующие действия предназначены для отмены последствий ранее выполненной субтранзакции. Определив компенсирующие действия для каждой субтранзакции, вы можете отменить изменения, внесенные неудачной субтранзакцией, и восстановить систему в согласованное состояние.

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

Пример кода:

def transfer_funds(source_account, destination_account, amount):
    try:
        # Perform the fund transfer
        debit(source_account, amount)
        credit(destination_account, amount)
    except InsufficientFundsError:
        # Trigger compensating action
        reverse_transfer(source_account, amount)
        raise SagaRollbackException("Transfer failed due to insufficient funds")
def reverse_transfer(account, amount):
    # Reverse the transfer by crediting the account
    credit(account, amount)

Метод 2: тайм-аут и повтор
Другой подход к обработке сбоев субтранзакций заключается в реализации механизма тайм-аута и повтора. В случае сбоя дополнительной транзакции вы можете установить период ожидания и попытаться повторить операцию через определенный интервал. Этот метод особенно полезен при временных сбоях, которые могут возникнуть из-за проблем с сетью или временной недоступности ресурсов.

Пример кода:

def perform_payment(order_id, payment_info):
    try:
        # Perform the payment operation
        response = make_payment(order_id, payment_info)
        if response.status_code == 200:
            # Payment successful
            return
        else:
            # Payment failed, retry after a timeout
            raise PaymentFailedException("Payment failed")
    except TimeoutException:
        # Retry the payment operation
        retry_payment(order_id, payment_info)

Метод 3: хранилище компенсаций
Хранилище компенсаций — это механизм постоянного хранения, используемый для записи состояния и информации, необходимой для компенсации неудачных субтранзакций. При сбое субтранзакции соответствующее компенсационное действие сохраняется в хранилище компенсаций. Позже эти компенсирующие действия могут быть выполнены, чтобы отменить последствия неудачных дополнительных транзакций.

Пример кода:

public void place_order(Order order) {
    try {
        // Perform order placement sub-transaction
        placeOrder(order);
    } catch (OrderPlacementFailedException ex) {
        // Store compensating action in the compensation store
        compensationStore.storeCompensatingAction(order.getId(), "cancelOrder", order);
        throw ex;
    }
}
public void cancel_order(String orderId) {
    // Retrieve compensating action from the compensation store
    Order order = compensationStore.retrieveCompensatingAction(orderId, "cancelOrder");
    // Execute compensating action
    cancelOrder(order);
}

Обработка сбоев субтранзакций в транзакциях Saga необходима для обеспечения согласованности данных и надежности системы. В этой статье мы обсудили три эффективных метода обработки таких сбоев: компенсирующие действия, тайм-аут и повтор, а также хранилище компенсаций. Применяя эти стратегии и адаптируя их к вашим конкретным сценариям использования, вы можете гарантировать, что ваши транзакции Saga корректно восстанавливаются после сбоев, обеспечивая надежную основу для ваших распределенных систем.