快速入門：建立 Java Durable Functions 應用程式

使用 Azure Functions 的一項功能 Durable Functions，在 Java 中撰寫具狀態的無伺服器工作流程。 在這個快速入門中，你會複製並執行一個範例應用程式，示範兩種常見的編排模式：

  • 函式鏈：依序呼叫活動（東京→西雅圖→倫敦）。
  • 扇出/扇入：在五個城市並行呼叫活動，然後彙整結果。

最後，你會用 Durable Task Scheduler 模擬器在本地執行兩個編排任務，並能在儀表板中查看它們的狀態。

  • 複製並準備 Hello Cities 的範例專案。
  • 設置 Durable Task Scheduler 模擬器和 Azurite 進行本地開發。
  • 建置並執行函式應用程式，觸發兩個編排。
  • 在 Durable Task Scheduler 儀表板中檢視編排狀態與輸出。

先決條件

設定長期工作排程器模擬器

Durable Task Scheduler 模擬器提供本地開發環境，讓你無需Azure訂閱即可測試編排。 Java Functions 主機也需要 Azurite 來進行本地儲存。

同時啟動兩個容器：

docker run -d --name dtsemulator -p 8080:8080 -p 8082:8082 \
  mcr.microsoft.com/dts/dts-emulator:latest

docker run -d --name azurite -p 10000:10000 -p 10001:10001 -p 10002:10002 \
  mcr.microsoft.com/azure-storage/azurite

Tip

模擬器運行後，你可以進入 Durable Task Scheduler 儀表板 http://localhost:8082 來監控編排進度。

執行快速啟動範例

  1. 請前往 Hello Cities 範例目錄：

    cd samples/durable-functions/java/HelloCities

  2. 請確認檔案 local.settings.json 包含以下設定：

    {
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "UseDevelopmentStorage=true",
    "FUNCTIONS_WORKER_RUNTIME": "java",
    "DURABLE_TASK_SCHEDULER_CONNECTION_STRING": "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None"
  }
}

  3. 建置專案：

    mvn clean package

  4. 啟動功能應用程式：

    mvn azure-functions:run

  5. 在另一個終端機中，觸發 函式鏈結 編排：

    $response = Invoke-RestMethod -Method POST -Uri http://localhost:7071/api/StartChaining
$response

    回應包含編排實例的狀態 URL。 複製這個 statusQueryGetUri 值並執行以檢查結果：

    Invoke-RestMethod -Uri $response.statusQueryGetUri

  6. 啟動 扇出/扇入 編曲：

    $response = Invoke-RestMethod -Method POST -Uri http://localhost:7071/api/StartFanOutFanIn
Invoke-RestMethod -Uri $response.statusQueryGetUri

預期產出

POST 請求會回傳一個帶有狀態 URL 的 JSON 回應。 例如：

{
  "id": "<instanceId>",
  "statusQueryGetUri": "http://localhost:7071/runtime/webhooks/durabletask/instances/<instanceId>?code=...",
  "sendEventPostUri": "...",
  "terminatePostUri": "...",
  "purgeHistoryDeleteUri": "..."
}

當你查詢 statusQueryGetUri 時，編排 runtimeStatus 的結果是 Completed，你可以在 output 欄位中找到問候結果。 連鎖編曲回歸：

{
  "name": "ChainingOrchestration",
  "runtimeStatus": "Completed",
  "output": "Hello Tokyo! Hello Seattle! Hello London!"
}

扇出/扇入協調流程回來了：

{
  "name": "FanOutFanInOrchestration",
  "runtimeStatus": "Completed",
  "output": ["Hello Tokyo!", "Hello Seattle!", "Hello London!", "Hello Paris!", "Hello Berlin!"]
}

Tip

如果runtimeStatus顯示Running或Pending，請稍等再查詢。statusQueryGetUri

打開 Durable Task Scheduler 儀表板 http://localhost:8082 ，查看協調狀態和執行歷史。

了解程式碼

src/main/java/com/example/Functions.java 中的範例專案包含 Durable Functions 應用程式所需的三種函式類型。

活動函式

該 SayHello 活動會取一個城市名稱並回應問候語：

@FunctionName("SayHello")
public String sayHello(
        @DurableActivityTrigger(name = "city") String city) {
    return "Hello " + city + "!";
}

協調器函式

鏈式協調器依序針對三個城市呼叫 SayHello：

@FunctionName("ChainingOrchestration")
public String chainingOrchestration(
        @DurableOrchestrationTrigger(name = "ctx") TaskOrchestrationContext ctx) {

    String result = "";
    result += ctx.callActivity("SayHello", "Tokyo", String.class).await();
    result += " " + ctx.callActivity("SayHello", "Seattle", String.class).await();
    result += " " + ctx.callActivity("SayHello", "London", String.class).await();
    return result;
}

扇出/扇入協調器會平行排程活動：

@FunctionName("FanOutFanInOrchestration")
public List<String> fanOutFanInOrchestration(
        @DurableOrchestrationTrigger(name = "ctx") TaskOrchestrationContext ctx) {

    String[] cities = {"Tokyo", "Seattle", "London", "Paris", "Berlin"};
    List<Task<String>> parallelTasks = new ArrayList<>();

    for (String city : cities) {
        parallelTasks.add(ctx.callActivity("SayHello", city, String.class));
    }

    List<String> results = new ArrayList<>();
    for (Task<String> task : parallelTasks) {
        results.add(task.await());
    }

    return results;
}

客戶端函數

由 HTTP 觸發的用戶端函式會啟動每個協調流程：

@FunctionName("StartChaining")
public HttpResponseMessage startChaining(
        @HttpTrigger(name = "req", methods = {HttpMethod.POST},
            authLevel = AuthorizationLevel.ANONYMOUS)
            HttpRequestMessage<Void> request,
        @DurableClientInput(name = "durableContext") DurableClientContext durableContext) {

    DurableTaskClient client = durableContext.getClient();
    String instanceId = client.scheduleNewOrchestrationInstance("ChainingOrchestration");
    return durableContext.createCheckStatusResponse(request, instanceId);
}

Configuration

範例使用 Durable Task Scheduler 模擬器作為儲存後端。 這是在 host.json 中設定的：

{
  "extensions": {
    "durableTask": {
      "hubName": "default",
      "storageProvider": {
        "type": "azureManaged",
        "connectionStringName": "DURABLE_TASK_SCHEDULER_CONNECTION_STRING"
      }
    }
  }
}

模擬器連線字串設定於 local.settings.json：

{
  "Values": {
    "AzureWebJobsStorage": "UseDevelopmentStorage=true",
    "FUNCTIONS_WORKER_RUNTIME": "java",
    "DURABLE_TASK_SCHEDULER_CONNECTION_STRING": "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None"
  }
}

清理資源

完成後請停止模擬器容器：

docker stop dtsemulator azurite && docker rm dtsemulator azurite

下一步

  • Last updated on