Hızlı Başlangıç: Java Dayanıklı İşlevler uygulaması oluşturma

Projenize gerekli bağımlılıkları ve eklentileri ekleme

pom.xml dosyanıza aşağıdaki kodu ekleyin:

<properties>
  <azure.functions.maven.plugin.version>1.18.0</azure.functions.maven.plugin.version>
  <azure.functions.java.library.version>3.0.0</azure.functions.java.library.version>
  <durabletask.azure.functions>1.0.0</durabletask.azure.functions>
  <functionAppName>your-unique-app-name</functionAppName>
</properties>

<dependencies>
  <dependency>
    <groupId>com.microsoft.azure.functions</groupId>
    <artifactId>azure-functions-java-library</artifactId>
    <version>${azure.functions.java.library.version}</version>
  </dependency>
  <dependency>
    <groupId>com.microsoft</groupId>
    <artifactId>durabletask-azure-functions</artifactId>
    <version>${durabletask.azure.functions}</version>
  </dependency>
</dependencies>

<build>
  <plugins>
    <plugin>
      <groupId>org.apache.maven.plugins</groupId>
      <artifactId>maven-compiler-plugin</artifactId>
      <version>3.8.1</version>
    </plugin>
    <plugin>
      <groupId>com.microsoft.azure</groupId>
      <artifactId>azure-functions-maven-plugin</artifactId>
      <version>${azure.functions.maven.plugin.version}</version>
      <configuration>
        <appName>${functionAppName}</appName>
        <resourceGroup>java-functions-group</resourceGroup>
        <appServicePlanName>java-functions-app-service-plan</appServicePlanName>
        <region>westus</region>
        <runtime>
          <os>windows</os>
          <javaVersion>11</javaVersion>
        </runtime>
        <appSettings>
          <property>
            <name>FUNCTIONS_EXTENSION_VERSION</name>
            <value>~4</value>
          </property>
        </appSettings>
      </configuration>
      <executions>
        <execution>
          <id>package-functions</id>
          <goals>
            <goal>package</goal>
          </goals>
        </execution>
      </executions>
    </plugin>
    <plugin>
      <artifactId>maven-clean-plugin</artifactId>
      <version>3.1.0</version>
    </plugin>
  </plugins>
</build>

Gerekli JSON dosyalarını ekleme

Proje dizininize bir host.json dosyası ekleyin. Aşağıdaki örneğe benzer görünmelidir:

{
  "version": "2.0",
  "logging": {
    "logLevel": {
      "DurableTask.AzureStorage": "Warning",
      "DurableTask.Core": "Warning"
    }
  },
  "extensions": {
    "durableTask": {
      "hubName": "JavaTestHub"
    }
  },
  "extensionBundle": {
    "id": "Microsoft.Azure.Functions.ExtensionBundle",
    "version": "[4.*, 5.0.0)"
  }
}

Dayanıklı İşlevler çalışma zamanı durumunu depolamak için bir depolama sağlayıcısı gerekir. Depolama sağlayıcısını yapılandırmak için proje dizininize bir local.settings.json dosyası ekleyin. Sağlayıcı olarak Azure Depolama'yı kullanmak için değerini AzureWebJobsStorage Azure Depolama hesabınızın bağlantı dizesi olarak ayarlayın:

{
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "<your storage account connection string>",
    "FUNCTIONS_WORKER_RUNTIME": "java"
  }
}

İşlevlerinizi oluşturma

Aşağıdaki örnek kod, her işlev türünün temel bir örneğini gösterir:

import com.microsoft.azure.functions.annotation.*;
import com.microsoft.azure.functions.*;
import java.util.*;

import com.microsoft.durabletask.*;
import com.microsoft.durabletask.azurefunctions.DurableActivityTrigger;
import com.microsoft.durabletask.azurefunctions.DurableClientContext;
import com.microsoft.durabletask.azurefunctions.DurableClientInput;
import com.microsoft.durabletask.azurefunctions.DurableOrchestrationTrigger;

public class DurableFunctionsSample {
    /**
     * This HTTP-triggered function starts the orchestration.
     */
    @FunctionName("StartOrchestration")
    public HttpResponseMessage startOrchestration(
            @HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS) HttpRequestMessage<Optional<String>> request,
            @DurableClientInput(name = "durableContext") DurableClientContext durableContext,
            final ExecutionContext context) {
        context.getLogger().info("Java HTTP trigger processed a request.");

        DurableTaskClient client = durableContext.getClient();
        String instanceId = client.scheduleNewOrchestrationInstance("Cities");
        context.getLogger().info("Created new Java orchestration with instance ID = " + instanceId);
        return durableContext.createCheckStatusResponse(request, instanceId);
    }

    /**
     * This is the orchestrator function, which can schedule activity functions, create durable timers,
     * or wait for external events in a way that's completely fault-tolerant.
     */
    @FunctionName("Cities")
    public String citiesOrchestrator(
            @DurableOrchestrationTrigger(name = "taskOrchestrationContext") TaskOrchestrationContext ctx) {
        String result = "";
        result += ctx.callActivity("Capitalize", "Tokyo", String.class).await() + ", ";
        result += ctx.callActivity("Capitalize", "London", String.class).await() + ", ";
        result += ctx.callActivity("Capitalize", "Seattle", String.class).await() + ", ";
        result += ctx.callActivity("Capitalize", "Austin", String.class).await();
        return result;
    }

    /**
     * This is the activity function that is invoked by the orchestrator function.
     */
    @FunctionName("Capitalize")
    public String capitalize(@DurableActivityTrigger(name = "name") String name, final ExecutionContext context) {
        context.getLogger().info("Capitalizing: " + name);
        return name.toUpperCase();
    }
}

Maven komutunu kullanarak yerel proje oluşturma

Dayanıklı İşlevler uygulamasının temel işlevlerini içeren bir proje oluşturmak için aşağıdaki komutu çalıştırın:

mvn archetype:generate -DarchetypeGroupId=com.microsoft.azure -DarchetypeArtifactId=azure-functions-archetype -DarchetypeVersion=1.51 -Dtrigger=durablefunctions

mvn archetype:generate "-DarchetypeGroupId=com.microsoft.azure" "-DarchetypeArtifactId=azure-functions-archetype" "-DarchetypeVersion=1.51" "-Dtrigger=durablefunctions"

mvn archetype:generate "-DarchetypeGroupId=com.microsoft.azure" "-DarchetypeArtifactId=azure-functions-archetype" "-DarchetypeVersion=1.51" "-Dtrigger=durablefunctions"

İstemlerde aşağıdaki bilgileri sağlayın:

Artık temel bir Dayanıklı İşlevler uygulamasında bulunan üç işleve sahip yerel bir projeniz var.

pom.xml dosyanızda bağımlılık olarak ayarlandığından com.microsoft:durabletask-azure-functions emin olun.

Arka uç depolama sağlayıcısını yapılandırma

Dayanıklı İşlevler çalışma zamanı durumunu depolamak için bir depolama sağlayıcısı gerekir. Azure Depolama'yı local.settings.json'da depolama sağlayıcısı olarak ayarlayabilirsiniz. Azure depolama hesabınızın bağlantı dizesi değerini şu örnekte olduğu AzureWebJobsStorage gibi kullanın:

{
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "<your storage account connection string>",
    "FUNCTIONS_WORKER_RUNTIME": "java"
  }
}

Yerel projenizi oluşturma

1. Visual Studio Code'da komut paletini açmak için F1'i seçin (veya Ctrl/Cmd+Shift+P'yi seçin). İstemde ()> girin ve Azure İşlevleri: Yeni Proje Oluştur'u seçin.

   

2. Göz At'ı seçin. Klasör Seç iletişim kutusunda, projeniz için kullanılacak klasöre gidin ve Seç'i seçin.

3. İstemlerde aşağıdaki bilgileri sağlayın:

   İstem	Eylem
   Dil seçin	Java'ya tıklayın.
   Java sürümünü seçme	Java 8 veya sonraki bir sürümü seçin. İşlevlerinizin Azure'da çalıştırıldığı Java sürümünü ve yerel olarak doğruladığınız sürümü seçin.
   Grup kimliği belirtin	com.function girin.
   Yapıt kimliği sağlama	myDurableFunction girin.
   Sürüm sağlama	1.0-SNAPSHOT girin.
   Paket adı belirtin	com.function girin.
   Uygulama adı belirtin	myDurableFunction girin.
   Java projesi için derleme aracını seçin	Maven'ı seçin.
   Projenizi nasıl açmak istediğinizi seçin	Yeni pencerede aç'ı seçin.

Artık örnek bir HTTP işlevine sahip bir projeniz var. bir sonraki adımda bir Dayanıklı İşlevler uygulamasının temel işlevlerini eklediğinizden, isterseniz bu işlevi kaldırabilirsiniz.

Projeye işlev ekleme

1. Komut paletine girin ve Azure İşlevleri: İşlev Oluştur'u seçin.

2. Şablon filtresini değiştir için Tümü'ne tıklayın.

3. İstemlerde aşağıdaki bilgileri sağlayın:

   İstem	Eylem
   İşleviniz için şablon seçme	DurableFunctionsOrchestration öğesini seçin.
   Paket adı belirtin	com.function girin.
   İşlev adı belirtin	DurableFunctionsOrchestrator girin.

4. İletişim kutusunda Depolama hesabı seçin'i seçerek bir depolama hesabı ayarlayın ve ardından istemleri izleyin.

Artık bir Dayanıklı İşlevler uygulaması için oluşturulan üç temel işleve sahip olmanız gerekir.

pom.xml ve host.json yapılandırma

pom.xml dosyanıza aşağıdaki bağımlılığı ekleyin:

<dependency>
  <groupId>com.microsoft</groupId>
  <artifactId>durabletask-azure-functions</artifactId>
  <version>1.0.0</version>
</dependency>

extensions özelliğini host.json dosyanıza ekleyin:

"extensions": { "durableTask": { "hubName": "JavaTestHub" }}