建置簡單的 Amazon SWF 應用程式

使用 Maven 啟動新專案：

mvn archetype:generate -DartifactId=helloswf \
-DgroupId=aws.example.helloswf -DinteractiveMode=false

這會建立具有標準 maven 專案結構的新專案：

helloswf
├── pom.xml
└── src
    ├── main
    │   └── java
    │       └── aws
    │           └── example
    │               └── helloswf
    │                   └── App.java
    └── test
        └── ...

您可以忽略或刪除test目錄及其包含的所有內容，我們不會將其用於本教學課程。您也可以刪除 App.java，因為我們會將它取代為新的類別。

編輯專案pom.xml的檔案，並在 <dependencies>區塊中新增其相依性，以新增 aws-java-sdk-simpleworkflow 模組。

<dependencies>
  <dependency>
    <groupId>com.amazonaws</groupId>
    <artifactId>aws-java-sdk-simpleworkflow</artifactId>
    <version>1.11.1000</version>
  </dependency>
</dependencies>

請確定 Maven 使用 JDK 1.7+ 支援建置您的專案。在 中將下列項目新增至您的專案 (<dependencies>區塊之前或之後）pom.xml：

<build>
  <plugins>
    <plugin>
      <artifactId>maven-compiler-plugin</artifactId>
      <version>3.6.1</version>
      <configuration>
          <source>1.8</source>
          <target>1.8</target>
      </configuration>
    </plugin>
  </plugins>
</build>

在專案src/main/java/aws/example/helloswf/目錄中的 中建立 檔案。

將package宣告新增至每個檔案的開頭，以宣告其命名空間。範例專案使用：

package aws.example.helloswf;

新增 AmazonSimpleWorkflowClient 類別和 com.amazonaws.services.simpleworkflow.model 命名空間中多個類別的import宣告。為了簡化物件，我們將使用：

import com.amazonaws.regions.Regions;
import com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflow;
import com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClientBuilder;
import com.amazonaws.services.simpleworkflow.model.*;

開啟文字編輯器並建立檔案 HelloTypes.java，根據常見步驟新增套件宣告和匯入。

宣告 HelloTypes類別，並提供用於已註冊活動和工作流程類型的值：

    public static final String DOMAIN = "HelloDomain";
    public static final String TASKLIST = "HelloTasklist";
    public static final String WORKFLOW = "HelloWorkflow";
    public static final String WORKFLOW_VERSION = "1.0";
    public static final String ACTIVITY = "HelloActivity";
    public static final String ACTIVITY_VERSION = "1.0";

這些值將在整個程式碼中使用。

在字串宣告之後，建立 AmazonSimpleWorkflowClient 類別的執行個體。這是 所提供 Amazon SWF 方法的基本界面 AWS SDK for Java。

private static final AmazonSimpleWorkflow swf =
    AmazonSimpleWorkflowClientBuilder.standard().withRegion(Regions.DEFAULT_REGION).build();

上一個程式碼片段假設暫時登入資料與default設定檔相關聯。如果您使用不同的設定檔，請修改上述程式碼，如下所示，並將 profile_name 取代為實際的設定檔名稱。

private static final AmazonSimpleWorkflow swf =
        AmazonSimpleWorkflowClientBuilder
                .standard()
                .withCredentials(new ProfileCredentialsProvider("profile_name"))
                .withRegion(Regions.DEFAULT_REGION)
                .build();

新增函數以註冊 SWF 網域。網域是許多相關 SWF 活動和工作流程類型的邏輯容器。SWF 元件只能在相同網域中存在時互相通訊。

    try {
        System.out.println("** Registering the domain '" + DOMAIN + "'.");
        swf.registerDomain(new RegisterDomainRequest()
            .withName(DOMAIN)
            .withWorkflowExecutionRetentionPeriodInDays("1"));
    } catch (DomainAlreadyExistsException e) {
        System.out.println("** Domain already exists!");
    }

註冊網域時，您會提供名稱 （一組 1 到 256 個字元，不包括 :、/、|、控制字元或常值字串 '`arn') 和保留期間，這是工作流程執行完成後 Amazon SWF ，工作流程執行歷史記錄資料的保留天數。工作流程執行保留期上限為 90 天。如需詳細資訊，請參閱 RegisterDomainRequest。

如果具有該名稱的網域已存在，則會引發 DomainAlreadyExistsException。由於我們未考量網域是否已建立，因此可以忽略例外狀況。

新增函數以註冊新的活動類型。活動代表工作流程中的工作單位。

    try {
        System.out.println("** Registering the activity type '" + ACTIVITY +
            "-" + ACTIVITY_VERSION + "'.");
        swf.registerActivityType(new RegisterActivityTypeRequest()
            .withDomain(DOMAIN)
            .withName(ACTIVITY)
            .withVersion(ACTIVITY_VERSION)
            .withDefaultTaskList(new TaskList().withName(TASKLIST))
            .withDefaultTaskScheduleToStartTimeout("30")
            .withDefaultTaskStartToCloseTimeout("600")
            .withDefaultTaskScheduleToCloseTimeout("630")
            .withDefaultTaskHeartbeatTimeout("10"));
    } catch (TypeAlreadyExistsException e) {
        System.out.println("** Activity type already exists!");
    }

活動類型由名稱和版本識別，用於唯一識別其註冊網域中任何其他人的活動。活動也包含許多選用參數，例如用於從 SWF 接收任務和資料的預設任務清單，以及可用於限制活動執行不同部分需要多長時間的不同逾時。如需詳細資訊，請參閱 RegisterActivityTypeRequest。

開啟您的文字編輯器並建立檔案 ActivityWorker.java，根據常見步驟新增套件宣告和匯入。

import com.amazonaws.regions.Regions;
import com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflow;
import com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClientBuilder;
import com.amazonaws.services.simpleworkflow.model.*;

將 ActivityWorker類別新增至 檔案，並為其提供資料成員，以保留我們將用來與之互動的 SWF 用戶端 Amazon SWF：

    private static final AmazonSimpleWorkflow swf =
            AmazonSimpleWorkflowClientBuilder.standard().withRegion(Regions.DEFAULT_REGION).build();

新增我們將用作活動的方法：

private static String sayHello(String input) throws Throwable {
    return "Hello, " + input + "!";
}

活動只需要一個字串，將其合併為問候語並傳回結果。雖然此活動不太可能引發例外狀況，但最好設計活動，以便在發生錯誤時引發錯誤。

新增main我們將用作活動任務輪詢方法的方法。我們會新增一些程式碼來輪詢活動任務的任務清單，以開始執行此作業：

        System.out.println("Polling for an activity task from the tasklist '"
                + HelloTypes.TASKLIST + "' in the domain '" +
                HelloTypes.DOMAIN + "'.");

        ActivityTask task = swf.pollForActivityTask(
            new PollForActivityTaskRequest()
                .withDomain(HelloTypes.DOMAIN)
                .withTaskList(
                    new TaskList().withName(HelloTypes.TASKLIST)));

        String task_token = task.getTaskToken();

活動 Amazon SWF 透過呼叫 SWF 用戶端的 pollForActivityTask方法接收來自 的任務，指定要在傳入 PollForActivityTaskRequest 中使用的網域和任務清單。

收到任務後，我們會呼叫任務的 getTaskToken方法來擷取其唯一識別符。

接著，撰寫一些程式碼來處理進來的任務。在輪詢任務並擷取其任務字符的程式碼之後，立即將以下內容新增至您的main方法。

    if (task_token != null) {
        String result = null;
        Throwable error = null;

        try {
            System.out.println("Executing the activity task with input '" +
                    task.getInput() + "'.");
            result = sayHello(task.getInput());
        } catch (Throwable th) {
            error = th;
        }

        if (error == null) {
            System.out.println("The activity task succeeded with result '"
                    + result + "'.");
            swf.respondActivityTaskCompleted(
                new RespondActivityTaskCompletedRequest()
                    .withTaskToken(task_token)
                    .withResult(result));
        } else {
            System.out.println("The activity task failed with the error '"
                    + error.getClass().getSimpleName() + "'.");
            swf.respondActivityTaskFailed(
                new RespondActivityTaskFailedRequest()
                    .withTaskToken(task_token)
                    .withReason(error.getClass().getSimpleName())
                    .withDetails(error.getMessage()));
        }
    }

如果任務字符不是 null，我們可以開始執行活動方法 (sayHello)，提供它與任務一起傳送的輸入資料。

如果任務成功 （未產生錯誤），則工作者會使用包含任務字符和活動結果資料的 RespondActivityTaskCompletedRequest 物件呼叫 SWF 用戶端的 respondActivityTaskCompleted方法來回應 SWF。

另一方面，如果任務失敗，我們會透過使用 RespondActivityTaskFailedRequest 物件呼叫 respondActivityTaskFailed方法，將任務權杖和錯誤的相關資訊傳遞給它來回應。

開啟文字編輯器並建立檔案 WorkflowWorker.java，根據常見步驟新增套件宣告和匯入。

將一些額外的匯入新增至 檔案：

import com.amazonaws.regions.Regions;
import com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflow;
import com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClientBuilder;
import com.amazonaws.services.simpleworkflow.model.*;
import java.util.ArrayList;
import java.util.List;
import java.util.UUID;

宣告 WorkflowWorker類別，並建立用於存取 SWF 方法的 AmazonSimpleWorkflowClient 類別執行個體。

    private static final AmazonSimpleWorkflow swf =
            AmazonSimpleWorkflowClientBuilder.standard().withRegion(Regions.DEFAULT_REGION).build();

新增 main方法。方法會持續循環，使用 SWF 用戶端的 pollForDecisionTask方法輪詢決策任務。PollForDecisionTaskRequest 提供詳細資訊。

    PollForDecisionTaskRequest task_request =
        new PollForDecisionTaskRequest()
            .withDomain(HelloTypes.DOMAIN)
            .withTaskList(new TaskList().withName(HelloTypes.TASKLIST));

    while (true) {
        System.out.println(
                "Polling for a decision task from the tasklist '" +
                HelloTypes.TASKLIST + "' in the domain '" +
                HelloTypes.DOMAIN + "'.");

        DecisionTask task = swf.pollForDecisionTask(task_request);

        String taskToken = task.getTaskToken();
        if (taskToken != null) {
            try {
                executeDecisionTask(taskToken, task.getEvents());
            } catch (Throwable th) {
                th.printStackTrace();
            }
        }
    }

一旦收到任務，我們就會呼叫其getTaskToken方法，傳回可用來識別任務的字串。如果傳回的字符不是 null，我們會在 executeDecisionTask方法中進一步處理它，並傳遞任務字符和隨任務傳送的 HistoryEvent 物件清單。

新增 executeDecisionTask方法，取得任務字符 (String) 和 HistoryEvent清單。

    List<Decision> decisions = new ArrayList<Decision>();
    String workflow_input = null;
    int scheduled_activities = 0;
    int open_activities = 0;
    boolean activity_completed = false;
    String result = null;

我們也設定一些資料成員來追蹤下列項目：

接下來，新增一些程式碼到 executeDecisionTask ，根據 getEventType方法報告的事件類型，處理與任務一起傳送的HistoryEvent物件。

System.out.println("Executing the decision task for the history events: [");
for (HistoryEvent event : events) {
    System.out.println("  " + event);
    switch(event.getEventType()) {
        case "WorkflowExecutionStarted":
            workflow_input =
                event.getWorkflowExecutionStartedEventAttributes()
                     .getInput();
            break;
        case "ActivityTaskScheduled":
            scheduled_activities++;
            break;
        case "ScheduleActivityTaskFailed":
            scheduled_activities--;
            break;
        case "ActivityTaskStarted":
            scheduled_activities--;
            open_activities++;
            break;
        case "ActivityTaskCompleted":
            open_activities--;
            activity_completed = true;
            result = event.getActivityTaskCompletedEventAttributes()
                          .getResult();
            break;
        case "ActivityTaskFailed":
            open_activities--;
            break;
        case "ActivityTaskTimedOut":
            open_activities--;
            break;
    }
}
System.out.println("]");

基於工作流程的目的，我們最感興趣的是：

如果您的工作流程需要，則可以使用其他事件類型。如需每個事件類型的相關資訊，請參閱 HistoryEvent 類別描述。

+ 注意：Java 7 中引入switch了陳述式中的字串。如果您使用的是舊版 Java，則可以使用 EventType 類別，將 String傳回的 history_event.getType() 轉換為列舉值，然後String視需要返回 ：

在switch陳述式之後，新增更多程式碼，根據收到的任務做出適當的決策來回應。

if (activity_completed) {
    decisions.add(
        new Decision()
            .withDecisionType(DecisionType.CompleteWorkflowExecution)
            .withCompleteWorkflowExecutionDecisionAttributes(
                new CompleteWorkflowExecutionDecisionAttributes()
                    .withResult(result)));
} else {
    if (open_activities == 0 && scheduled_activities == 0) {

        ScheduleActivityTaskDecisionAttributes attrs =
            new ScheduleActivityTaskDecisionAttributes()
                .withActivityType(new ActivityType()
                    .withName(HelloTypes.ACTIVITY)
                    .withVersion(HelloTypes.ACTIVITY_VERSION))
                .withActivityId(UUID.randomUUID().toString())
                .withInput(workflow_input);

        decisions.add(
                new Decision()
                    .withDecisionType(DecisionType.ScheduleActivityTask)
                    .withScheduleActivityTaskDecisionAttributes(attrs));
    } else {
        // an instance of HelloActivity is already scheduled or running. Do nothing, another
        // task will be scheduled once the activity completes, fails or times out
    }
}

System.out.println("Exiting the decision task with the decisions " + decisions);

無論哪種情況，決策資訊都會新增至方法頂端宣告的Decision清單。

傳回處理任務時收集的Decision物件清單，以完成決策任務。在我們撰寫executeDecisionTask的方法結尾新增此程式碼：

swf.respondDecisionTaskCompleted(
    new RespondDecisionTaskCompletedRequest()
        .withTaskToken(taskToken)
        .withDecisions(decisions));

SWF 用戶端的 respondDecisionTaskCompleted方法會取得識別任務的任務字符，以及Decision物件清單。

開啟文字編輯器並建立檔案 WorkflowStarter.java，根據常見步驟新增套件宣告和匯入。

新增 WorkflowStarter類別：

package aws.example.helloswf;


import com.amazonaws.regions.Regions;
import com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflow;
import com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClientBuilder;
import com.amazonaws.services.simpleworkflow.model.*;

public class WorkflowStarter {
    private static final AmazonSimpleWorkflow swf =
            AmazonSimpleWorkflowClientBuilder.standard().withRegion(Regions.DEFAULT_REGION).build();
    public static final String WORKFLOW_EXECUTION = "HelloWorldWorkflowExecution";

    public static void main(String[] args) {
        String workflow_input = "{SWF}";
        if (args.length > 0) {
            workflow_input = args[0];
        }

        System.out.println("Starting the workflow execution '" + WORKFLOW_EXECUTION +
                "' with input '" + workflow_input + "'.");

        WorkflowType wf_type = new WorkflowType()
            .withName(HelloTypes.WORKFLOW)
            .withVersion(HelloTypes.WORKFLOW_VERSION);

        Run run = swf.startWorkflowExecution(new StartWorkflowExecutionRequest()
            .withDomain(HelloTypes.DOMAIN)
            .withWorkflowType(wf_type)
            .withWorkflowId(WORKFLOW_EXECUTION)
            .withInput(workflow_input)
            .withExecutionStartToCloseTimeout("90"));

        System.out.println("Workflow execution started with the run id '" +
                run.getRunId() + "'.");
    }
}

WorkflowStarter 類別由單一方法 組成main，採用在命令列上傳遞的選用引數做為工作流程的輸入資料。

SWF 用戶端方法 startWorkflowExecution採用 StartWorkflowExecutionRequest 物件做為輸入。在這裡，除了指定要執行的網域和工作流程類型之外，我們還提供它：

startWorkflowExecution 傳回的執行物件提供執行 ID，此值可用來識別工作流程執行 Amazon SWF歷史記錄中的此特定工作流程執行。

+ 注意：執行 ID 是由 產生 Amazon SWF，與您在啟動工作流程執行時傳入的工作流程執行名稱不同。