知識庫 / Spring / Spring Boot RSS 訂閱

總結：編排式 Saga 模式提供了一種在微服務架構中實現協調、一致和可擴展的分佈式事務的方法，並且通過補償事務處理故障，使其成為構建健壯和可擴展的分佈式應用程序的強大模式。

5. 使用 Orkés Conductor 實施 Saga 編排模式

現在，讓我們來看一個使用 Saga 模式和 Orkés Conductor 的實際應用示例。

考慮一個訂單管理系統，包含以下服務：

• OrderService – 處理初始訂單放置，包括將項目添加到購物車、指定數量和初始化結賬流程。
• InventoryService – 檢查和確認項目可用性。
• PaymentService – 安全地管理支付流程，處理各種支付方式。
• ShipmentService – 準備項目進行運輸，包括包裝、生成運輸標籤和啓動運輸流程。
• NotificationService – 向用户發送關於訂單更新的通知。

讓我們使用 Orkés Conductor 和 Spring Boot 3 複製這個流程。

在開始應用開發之前，請確保系統滿足以下先決條件。

• 安裝 Java 17

要為我們的應用程序設置 Orkés Conductor，可以選擇以下方法：

• 本地設置 Conductor
• 使用 Playground
• 使用 Orkés Cloud – Conductor 企業版

在這個例子中，我們將使用 Playground。

這是使用 Saga 模式構建的食品外賣應用程序的代碼片段：

@AllArgsConstructor
@Component
@ComponentScan(basePackages = {"io.orkes"})
public class ConductorWorkers {
    
    @WorkerTask(value = "order_food", threadCount = 3, pollingInterval = 300)
    public TaskResult orderFoodTask(OrderRequest orderRequest) {
        String orderId = OrderService.createOrder(orderRequest);
        TaskResult result = new TaskResult();
        Map<String, Object> output = new HashMap<>();

        if(orderId != null) {
            output.put("orderId", orderId);
            result.setOutputData(output);
            result.setStatus(TaskResult.Status.COMPLETED);
        } else {
            output.put("orderId", null);
            result.setStatus(TaskResult.Status.FAILED);
        }

        return result;
    }
}

5.1. 食品外賣應用程序

以下是從 Conductor UI 呈現的食品外賣應用程序示例：

讓我們看看工作流程的進展情況：

• 應用程序開始於用户在食品外賣應用程序上下單。初始流程被實現為一個一系列 工件任務，其中包括將食物添加到購物車（order_food）、檢查餐廳的食物可用性（check_inventory）、支付流程（make_payment）和送貨流程（ship_food）。
• 應用程序流程隨後移動到 分支合併任務，該任務處理通知服務。它有兩個分支，一個通知送貨員，另一個告知用户。

現在，讓我們運行應用程序！

5.2. 運行應用程序

1. 克隆項目。
2. 使用生成的訪問密鑰更新 application.properties 文件。為了將此工作者與應用程序服務器實例（先前解釋的工作流程）連接，需要在 Orkes Conductor 中創建應用程序並生成訪問密鑰。
1. 如果使用 Playground，請參考此視頻生成訪問密鑰。
2. 如果本地設置 Conductor，請按照此處提供的説明 (安裝並本地運行)。

conductor.server.url=https://play.orkes.io/api
conductor.security.client.key-id=<key>
conductor.security.client.secret=<secret>

注意事項:

• 由於我們使用的是 Playground，conductor.server.url 仍然保持不變。如果我們在本地配置了 Conductor，請用 Conductor 服務器 URL 替換它。
• 用生成的密鑰替換 key-id 和 secret。
• 為了使 Worker 與 Conductor 服務器連接，我們需要提供權限（在剛剛創建的應用程序中），以便訪問工作流程和任務。
• 默認情況下，conductor.worker.all.domain 設置為 ‘saga’。請確保更新為不同的名稱，以避免與 Orkes Playground 中其他人啓動的工作流程和 Worker 衝突。

使用以下命令從根項目運行應用程序:

gradle bootRun

應用程序正在運行；下一步是調用 triggerRideBookingFlow API 從應用程序中創建訂單。

$ curl --location 'http://localhost:8081/triggerFoodDeliveryFlow' \
 --header 'Content-Type: application/json' \
 --data '{
     "customerEmail": "[email protected]",
     "customerName": "Tester QA",
     "customerContact": "+1(605)123-5674",
     "address": "350 East 62nd Street, NY 10065",
     "restaurantId": 2,
     "foodItems": [
         {
             "item": "Chicken with Broccoli",
             "quantity": 1
         },
         {
             "item": "Veggie Fried Rice",
             "quantity": 1
         },
         {
             "item": "Egg Drop Soup",
             "quantity": 2
         }
     ],
     "additionalNotes": [
         "Do not put spice.",
         "Send cutlery."
     ],
     "paymentMethod" : {
         "type": "Credit Card",
         "details": {
             "number": "1234 4567 3325 1345",
             "cvv": "123",
             "expiry": "05/2022"
         }
     },
     "paymentAmount": 45.34,
     "deliveryInstructions": "Leave at the door!"
  }'

請求發送後，我們會收到一個工作流ID，表明我們的食品外賣應用已開始運行！🍕

使用工作流ID，我們可以通過Conductor UI可視化我們的應用程序。 讓我們複製工作流ID，然後在Conductor控制枱中，從左側菜單導航到“Executions > Workflow”。

一個示例執行情況如下:

讓我們看看如果某個服務失敗時應用程序流程會發生什麼。

5.3. 補償流程

以下是對食品外賣應用補償交易的簡化可視化：

在 Orkes Conductor 中定義工作流時，當主應用程序失敗時，我們可以觸發 failureWorkflow。在定義中包含要運行的工作流名稱，以防主應用程序失敗。

"failureWorkflow": "<name of the workflow to be run on failure>",

Orkes Conductor 在發生故障時，會回滾補償流程中的變更：

在 Playground 中查看

此流程在我們的主應用程序中的任何服務失敗時觸發。

假設由於資金不足導致支付失敗。 那麼，故障流程會觸發，啓動補償流程如下：

系統取消支付，隨後取消訂單，並將失敗通知發送給用户。

砰 🎊！ 這樣，我們使用 Orkes Conductor 在我們的食品外賣應用程序中回滾已完成的交易，從而保持應用程序的一致性。

此外，還有一個 Slack 社區 可供查閲，其中包含與 Conductor 相關的任何問題。

6. 結論

在本文中，我們成功地使用 Orkes Conductor 和 Java Spring Boot 3 開發了一個訂單管理應用程序，並實現了 Saga 模式。

Orkes Conductor 可在所有主流雲平台上使用：AWS、Azure 和 GCP。

如往常一樣，本文的源代碼可在 GitHub 上找到：GitHub。