快速入门：创建 Java Durable Functions 应用

向项目添加所需的依赖项和插件

将以下代码添加到 pom.xml 文件。 在复制之前，请将 your-unique-app-name 替换为一个全局唯一的函数应用名称。 调整region、javaVersion和resourceGroup以匹配您的环境。

<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>

添加所需的 JSON 文件

将 host.json 文件添加到项目目录。 它应如下例所示：

{
  "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)"
  }
}

Durable Functions 需要存储提供程序来存储运行时状态。 将 local.settings.json 文件添加到项目目录以配置存储提供程序。 若要使用 Azure 存储作为提供程序，请将 AzureWebJobsStorage 值设置为 Azure 存储帐户的连接字符串：

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

创建 Durable Functions 业务流程协调程序、活动和客户端函数

以下示例代码显示了每种函数类型的基本示例：

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 命令创建本地Durable Functions项目

运行以下命令，生成一个包含 Durable Functions 应用的基本函数的项目：

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

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

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

根据提示提供以下信息：

现在，你有一个本地项目，其中包含基本 Durable Functions 应用中的三个函数。 该原型会自动将 com.microsoft:durabletask-azure-functions 作为依赖项添加到你的 pom.xml 文件中。

为 Durable Functions 配置后端存储提供程序

Durable Functions 需要存储提供程序来存储运行时状态。 可以在 local.settings.json 中将 Azure 存储设置为存储提供程序。 使用 Azure 存储帐户的连接字符串作为 AzureWebJobsStorage 的值，如以下示例所示：

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

创建本地项目

1. 在Visual Studio Code中，选择 F1（或选择 Ctrl/Cmd+Shift+P）以打开命令面板。 在提示符 (>) 处输入命令，然后选择“Azure Functions: 创建新项目”。

   

2. 选择浏览。 在“选择文件夹”对话框中，转到要用于项目的文件夹，然后选择“选择”。

3. 根据提示提供以下信息：

   提示	Action
   选择语言	选择“Java”。
   选择 Java 版本	选择 Java 8 或更高版本。 在 Azure 中选择运行函数的 Java 版本，然后选择在本地验证的 Java 版本。
   提供组 ID	输入 com.function。
   提供项目 ID	输入 myDurableFunction。
   提供版本	输入 1.0-SNAPSHOT。
   提供包名称	输入 com.function。
   提供应用名称	输入 myDurableFunction。
   选择用于Java项目的生成工具	选择“Maven”。
   选择您希望打开项目的方式	选择“在新窗口中打开”。

现在，你有一个包含示例 HTTP 函数的项目。 可以删除生成的 HTTP 函数，因为你将在下一步中添加 Durable Functions。

向项目添加函数

1. 在命令面板中，输入并选择“Azure Functions：创建函数。

2. 对于“更改模板筛选器”，请选择“全部”。

3. 根据提示提供以下信息：

   提示	Action
   选择函数的模板	选择“DurableFunctionsOrchestration”。
   提供包名称	输入 com.function。
   提供函数名称	输入 DurableFunctionsOrchestrator。

4. 在对话框中，选择“选择存储帐户”设置存储帐户，然后按照提示进行操作。

现在，应该为 Durable Functions 应用生成了三个基本函数。

为Durable Functions配置 pom.xml 和 host.json

将以下依赖项添加到 pom.xml 文件：

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

将 extensions 属性添加到 host.json 文件。 如果文件已有其他属性，请将 extensions 块合并到现有 JSON 中：

{
  "version": "2.0",
  "extensions": {
    "durableTask": {
      "hubName": "JavaTestHub"
    }
  },
  "extensionBundle": {
    "id": "Microsoft.Azure.Functions.ExtensionBundle",
    "version": "[4.*, 5.0.0)"
  }
}