Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Application HelloWorldWorkflowAsync

Il est parfois préférable de faire exécuter certaines tâches en local par un flux de travail au lieu d'utiliser une activité. Cependant, les tâches de flux de travail impliquent souvent le traitement des valeurs représentées par des objets Promise<T>. Si vous transmettez un objet Promise<T> à une méthode de flux de travail synchrone, la méthode s'exécute immédiatement mais elle ne peut pas accéder à la valeur de l'objet Promise<T> tant que l'objet n'est pas prêt. Vous pouvez interroger l'objet Promise<T>.isReady jusqu'à ce qu'il renvoie true, mais cela s'avère inefficace et la méthode peut se bloquer pendant longtemps. Une meilleure approche consiste à utiliser une méthode asynchrone.

Une méthode asynchrone est implémentée de façon presque similaire à une méthode standardsouvent en tant que membre de la classe d'implémentation de flux de travailet s'exécute dans le contexte de l'implémentation de flux de travail. Vous la désignez en tant que méthode asynchrone en appliquant une annotation @Asynchronous qui demande à l'infrastructure de la traiter comme une activité.

Cette rubrique décrit la procédure pas à pas de HelloWorldWorkflowAsync, une version modifiée de HelloWorldWorkflow qui remplace l'une des activités par une méthode asynchrone. Pour implémenter l'application, créez une copie du package helloWorld.HelloWorldWorkflow dans le répertoire de votre projet et nommez celle-ci helloWorld.HelloWorldWorkflowAsync.

Les sections suivantes expliquent comment modifier le code HelloWorldWorkflow initial pour utiliser une méthode asynchrone.

Implémentation d'activités HelloWorldWorkflowAsync

HelloWorldWorkflowAsync implémente son interface d'exécuteur d'activités dans GreeterActivities, comme suit :

import com.amazonaws.services.simpleworkflow.flow.annotations.Activities;
import com.amazonaws.services.simpleworkflow.flow.annotations.ActivityRegistrationOptions;

@Activities(version="2.0")
@ActivityRegistrationOptions(defaultTaskScheduleToStartTimeoutSeconds = 300,
                             defaultTaskStartToCloseTimeoutSeconds = 10)
public interface GreeterActivities {
   public String getName();
   public void say(String what);
}

Cette interface est similaire celle utilisée par HelloWorldWorkflow, avec les exceptions suivantes :

Les implémentations de méthode d'activité restantes sont identiques à celles de HelloWorldWorkflow. Supprimez juste getGreeting de GreeterActivitiesImpl.

Implémentation de flux de travail HelloWorldWorkflowAsync

HelloWorldWorkflowAsync définit l'interface de flux de travail comme suit :

import com.amazonaws.services.simpleworkflow.flow.annotations.Execute;
import com.amazonaws.services.simpleworkflow.flow.annotations.Workflow;
import com.amazonaws.services.simpleworkflow.flow.annotations.WorkflowRegistrationOptions;

@Workflow
@WorkflowRegistrationOptions(defaultExecutionStartToCloseTimeoutSeconds = 3600)
public interface GreeterWorkflow {

   @Execute(version = "2.0")
   public void greet();
}

L'interface est identique à HelloWorldWorkflow à l'exception d'un nouveau numéro de version. Comme avec les activités, si vous souhaitez modifier un flux de travail enregistré, vous devez changer sa version.

HelloWorldWorkflowAsync implémente le flux de travail comme suit :

import com.amazonaws.services.simpleworkflow.flow.annotations.Asynchronous;
import com.amazonaws.services.simpleworkflow.flow.core.Promise;

public class GreeterWorkflowImpl implements GreeterWorkflow {
   private GreeterActivitiesClient operations = new GreeterActivitiesClientImpl();

   @Override
   public void greet() {
      Promise<String> name = operations.getName();
      Promise<String> greeting = getGreeting(name);
      operations.say(greeting);
   }

   @Asynchronous
   private Promise<String> getGreeting(Promise<String> name) {
      String returnString = "Hello " + name.get() + "!";
      return Promise.asPromise(returnString);
   }
}

HelloWorldWorkflowAsync remplace l'activité getGreeting par une méthode asynchrone getGreeting, mais la méthode greet fonctionne de la même manière :

La différence est que, au lieu d'appeler le client d'activités pour exécuter une activité getGreeting, la salutation appelle la méthode getGreeting asynchrone. le résultat est le même, mais la méthode getGreeting fonctionne quelque peu différemment de l'activité getGreeting.

getGreeting crée une valeur de retour en transmettant la chaîne de salutation à la méthode Promise.asPromise statique. Cette méthode crée un objet Promise<T> du type approprié, définit la valeur et le met à l'état prêt.

Hôte et démarreur de flux de travail et d'activités HelloWorldWorkflowAsync

HelloWorldWorkflowAsync implémente GreeterWorker en tant que classe hôte pour les implémentations de flux de travail et d'activité. Cette implémentation est identique à l'implémentation HelloWorldWorkflow, à l'exception du nom de taskListToPoll, qui est défini sur « HelloWorldAsyncList ».

import com.amazonaws.ClientConfiguration;
import com.amazonaws.auth.AWSCredentials;
import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflow;
import com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClient;
import com.amazonaws.services.simpleworkflow.flow.ActivityWorker;
import com.amazonaws.services.simpleworkflow.flow.WorkflowWorker;

public class GreeterWorker {
    public static void main(String[] args) throws Exception {
        ClientConfiguration config = new ClientConfiguration().withSocketTimeout(70*1000);

        String swfAccessId = System.getenv("AWS_ACCESS_KEY_ID");
        String swfSecretKey = System.getenv("AWS_SECRET_KEY");
        AWSCredentials awsCredentials = new BasicAWSCredentials(swfAccessId, swfSecretKey);

        AmazonSimpleWorkflow service = new AmazonSimpleWorkflowClient(awsCredentials, config);
        service.setEndpoint("https://swf.us-east-1.amazonaws.com");

        String domain = "helloWorldWalkthrough";
        String taskListToPoll = "HelloWorldAsyncList";

        ActivityWorker aw = new ActivityWorker(service, domain, taskListToPoll);
        aw.addActivitiesImplementation(new GreeterActivitiesImpl());
        aw.start();

        WorkflowWorker wfw = new WorkflowWorker(service, domain, taskListToPoll);
        wfw.addWorkflowImplementationType(GreeterWorkflowImpl.class);
        wfw.start();
    }
}

HelloWorldWorkflowAsync implémente le démarreur de flux de travail dans GreeterMain ; cette implémentation est identique à l'implémentation HelloWorldWorkflow.

Pour exécuter le flux de travail, lancez GreeterWorker et GreeterMain, de la même manière qu'avec HelloWorldWorkflow.