Mulai Cepat: Membuat aplikasi Java Durable Functions

Gunakan Durable Functions, fitur Azure Functions, untuk menulis alur kerja tanpa server stateful di Java. Dalam panduan singkat ini, Anda mengklon dan menjalankan aplikasi contoh yang menunjukkan dua pola orkestrasi umum:

  • Penautan fungsi: Memanggil aktivitas secara berurutan (Tokyo → Seattle → London).
  • Fan-out/fan-in: Memanggil aktivitas secara paralel di lima kota, lalu menggabungkan hasilnya.

Pada akhirnya, Anda akan memiliki kedua orkestrasi yang berjalan secara lokal dengan emulator Durable Task Scheduler dan dapat melihat statusnya di dasbor.

  • Kloning dan siapkan proyek sampel Hello Cities.
  • Siapkan emulator Durable Task Scheduler dan Azurite untuk pengembangan lokal.
  • Buat dan jalankan aplikasi fungsi, lalu picu kedua orkestrasi.
  • Tinjau status orkestrasi dan output di dasbor Durable Task Scheduler.

Prerequisites

Menyiapkan emulator "Durable Task Scheduler"

Emulator Task Scheduler Durable menyediakan lingkungan pengembangan lokal sehingga Anda dapat menguji orkestrasi tanpa langganan Azure. Host Java Functions juga memerlukan Azurite untuk penyimpanan lokal.

Mulai kedua kontainer:

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

Setelah emulator berjalan, Anda dapat mengakses dasbor Durable Task Scheduler di http://localhost:8082 untuk memantau orkestrasi.

Jalankan contoh memulai cepat

  1. Navigasikan ke direktori sampel Hello Cities:

    cd samples/durable-functions/java/HelloCities

  2. Verifikasi bahwa local.settings.json file berisi konfigurasi berikut:

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

  3. Bangun proyek tersebut:

    mvn clean package

  4. Mulai aplikasi fungsi:

    mvn azure-functions:run

  5. Di terminal terpisah, jalankan orkestrasi rantai fungsi:

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

    Respons berisi URL status untuk instans orkestrasi. statusQueryGetUri Salin nilai dan jalankan untuk memeriksa hasilnya:

    Invoke-RestMethod -Uri $response.statusQueryGetUri

  6. Picu orkestrasi fan-out/fan-in:

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

Output yang diharapkan

Permintaan POST mengembalikan respons JSON dengan URL status. Contohnya:

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

Saat Anda mengkueri statusQueryGetUri dan orkestrasi runtimeStatus adalah Completed, Anda bisa menemukan hasil salam di output bidang . Orkestrasi perangkaian mengembalikan:

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

Orkestrasi fan-out/fan-in mengembalikan:

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

Tip

Jika runtimeStatus memperlihatkan Running atau Pending, tunggu sebentar dan kueri lagi statusQueryGetUri .

Buka dasbor Durable Task Scheduler di http://localhost:8082 untuk melihat status orkestrasi dan riwayat eksekusi.

Memahami kode

Proyek sampel di src/main/java/com/example/Functions.java berisi ketiga jenis fungsi yang diperlukan untuk aplikasi Durable Functions.

Fungsi aktivitas

Aktivitas SayHello ini mengambil nama kota dan menghasilkan salam:

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

Fungsi orkestrator

orkestrator berantai memanggil SayHello secara berurutan untuk tiga kota:

@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;
}

Orkestrator fan-out/fan-in menjadwalkan aktivitas secara paralel:

@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;
}

Fungsi klien

Fungsi klien yang dipicu HTTP memulai setiap orkestrasi:

@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);
}

Konfigurasi

Sampel menggunakan emulator Durable Task Scheduler sebagai backend penyimpanannya. Ini dikonfigurasi dalam host.json:

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

String koneksi emulator ditetapkan dalam local.settings.json:

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

Membersihkan sumber daya

Hentikan kontainer emulator setelah Anda selesai:

docker stop dtsemulator azurite && docker rm dtsemulator azurite

Langkah berikutnya

  • Last updated on