9.4. 예

saga가 완료되면 일부 유형의 처리가 필요합니다. 보수 끝점은 문제가 발생하여 saga가 취소될 때 호출됩니다. saga가 성공적으로 완료되면 완료 끝점 을 호출하여 추가 처리를 수행할 수 있습니다. 예를 들어 위의 주문 서비스에서 실제로 주문 준비를 시작하기 위해 주문이 완료되는 시점과 예약된 신용을 알아야 할 수 있습니다. 결제가 완료되지 않은 경우 주문 준비를 시작하지 않는 것이 좋습니다(읽기 권한을 보장하기 전에 예약된 메모리에 대한 액세스 권한을 부여하는 최신 CPU와 달리). 이 작업은 수정된 direct:newOrder 끝점으로 쉽게 수행할 수 있습니다.

from("direct:newOrder")
  .saga()
  .propagation(SagaPropagation.MANDATORY)
  .compensation("direct:cancelOrder")
  .completion("direct:completeOrder")
    .transform().header(Exchange.SAGA_LONG_RUNNING_ACTION)
    .bean(orderManagerService, "newOrder")
    .log("Order ${body} created");

from("direct:completeOrder")
  .transform().header(Exchange.SAGA_LONG_RUNNING_ACTION)
  .bean(orderManagerService, "findExternalId")
  .to("jms:prepareOrder")
  .log("Order ${body} sent for preparation");

saga가 완료되면 준비를 위해 명령이 JMS 큐로 전송됩니다. 조정 동작과 마찬가지로 완료 작업은 사가 코디네이터(특히 네트워크 오류와 같은 오류의 경우)에 의해 여러 번 호출될 수 있습니다. 이 예에서 prepareOrder JMS 큐를 수신하는 서비스는 가능한 중복을 보유할 준비가 되었습니다(복제 처리 방법에 대한 예제는 Idempotent Consumer EIP 참조).

sa 옵션을 사용하여 사용자 정의 식별자를 등록할 수 있습니다. 예를 들어, 신용 서비스는 다음과 같이 리팩터링됩니다.

from("direct:reserveCredit")
  .bean(idService, "generateCustomId")
  .to("direct:creditReservation")

from("direct:creditReservation")
  .saga()
  .propagation(SagaPropagation.SUPPORTS)
  .option("CreditId", body())
  .compensation("direct:creditRefund")
    .bean(creditService, "reserveCredit")
    .log("Credit ${header.amount} reserved. Custom Id used is ${body}");

from("direct:creditRefund")
  .transform(header("CreditId")) // retrieve the CreditId option from headers
  .bean(creditService, "refundCredit")
  .log("Credit for Custom Id ${body} refunded");

direct:creditReservation 엔드포인트는 사도 외부에서 호출할 수 있으며, 전파 모드를 SUPPORTS 로 설정하면 됩니다. 이렇게 하면 사가 경로에 여러 옵션을 선언할 수 있습니다.

saga EIPs에서 시간 초과를 설정하면 시스템 오류 발생 시 saga가 영구적으로 유지되지 않습니다. saga EIP 구현에는 명시적으로 지정하지 않는 모든saga EIP에 설정된 기본 시간 초과가 있습니다. 시간 제한이 만료되면, 사가 EIP는 이전에 다른 결정을하지 않는 한 사가 (모든 참가자를 보완함)를 취소하기 로 결정합니다.

saga 참가자에 시간 초과는 다음과 같이 설정할 수 있습니다.

from("direct:newOrder")
  .saga()
  .timeout(1, TimeUnit.MINUTES) // newOrder requires that the saga is completed within 1 minute
  .propagation(SagaPropagation.MANDATORY)
  .compensation("direct:cancelOrder")
  .completion("direct:completeOrder")
    // ...
    .log("Order ${body} created");

모든 참가자(예: 신용 서비스, 주문 서비스)는 자체 시간 초과를 설정할 수 있습니다. 이러한 시간 초과의 최소 값은 함께 구성될 때 saga의 시간 초과 값으로 사용됩니다. 시간 초과는 다음과 같이 사가 수준에서 지정할 수도 있습니다.

from("direct:buy")
  .saga()
  .timeout(5, TimeUnit.MINUTES) // timeout at saga level
    .to("direct:newOrder")
    .to("direct:reserveCredit");

위의 예제에서는 다른 항목이 지정되지 않은 경우 사용되는 기본 전파 모드인 MANDATORY , SUPPORTS 및 REQUIRED 전파 모드를 사용합니다. 이러한 전파 모드는 1:1 트랜잭션 컨텍스트에서 사용되는 동등한 모드를 매핑합니다.

사가가 모두 동기적으로 실행될 수는 없지만, 예를 들어 비동기식 통신 채널을 사용하는 외부 서비스와의 통신이 필요한 경우,acga는 해당 채널을 생성하는 교환이 완료될 때 완료 모드를 AUTO (기본값)로 설정할 수 없기 때문입니다. 이는 종종 장기 실행 시간 (시간, 일)이 있는 사가 EIP의 경우입니다. 이러한 경우 MANUAL 완료 모드를 사용해야 합니다.

from("direct:mysaga")
  .saga()
  .completionMode(SagaCompletionMode.MANUAL)
  .completion("direct:finalize")
  .timeout(2, TimeUnit.HOURS)
    .to("seda:newOrder")
    .to("seda:reserveCredit");

seda:newOrder 및 seda:reserveCredit에 대한 비동기 처리를 추가합니다. 비동기 콜백을 seda:operationCompleted로 보냅니다.

from("seda:operationCompleted") // an asynchronous callback
  .saga()
  .propagation(SagaPropagation.MANDATORY)
    .bean(controlService, "actionExecuted")
    .choice()
      .when(body().isEqualTo("ok"))
        .to("saga:complete") // complete the current saga manually (saga component)
    .end()

direct:finalize 엔드포인트를 추가하여 최종 작업을 실행할 수 있습니다.

완료 모드를 MANUAL 로 설정하면 경로 direct:mysaga 에서 교환이 처리될 때 saga가 완료되지 않지만 더 오래 지속됩니다(최대 기간은 2시간으로 설정됨). 두 비동기 작업이 모두 완료되면sa가 완료됩니다. Camel saga Component의 saga:complete 엔드포인트를 사용하여 완료되는 호출이 수행됩니다. saga:compensate)를 수동으로 보완하기 위한 유사한 엔드포인트가 있습니다.