Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

HelloWorldWorkflow Solicitud

Aunque el HelloWorldejemplo básico está estructurado como un flujo de trabajo, se diferencia de un flujo de trabajo de Amazon SWF en varios aspectos clave:

Podría implementar una aplicación de flujo de trabajo asíncrono distribuida a partir de cero haciendo, por ejemplo, que el proceso de trabajo del flujo de trabajo interactúe con el proceso de trabajo de actividad directamente a través de llamadas a servicios web. Sin embargo, luego tendrá que implementar todo el código tan complicado que es necesario para administrar la ejecución asíncrona de varias actividades, controlar el flujo de datos, etc. Los SWF AWS Flow Framework para Java y Amazon se ocupan de todos esos detalles, lo que le permite centrarse en la implementación de la lógica empresarial.

HelloWorldWorkflow es una versión modificada HelloWorld que se ejecuta como un flujo de trabajo de Amazon SWF. La siguiente figura resume cómo funcionan las dos aplicaciones.

HelloWorld se ejecuta como un proceso único y el iniciador, el trabajador del flujo de trabajo y el trabajador de actividades interactúan mediante llamadas a métodos convencionales. Con HelloWorldWorkflow, el iniciador, el proceso de trabajo del flujo de trabajo y el proceso de trabajo de las actividades son componentes distribuidos que interactúan a través de Amazon SWF mediante solicitudes HTTP. Para gestionar la interacción, Amazon SWF mantiene listas de tareas de actividad y de flujos de trabajo, que envía a los componentes correspondientes. En esta sección se describe cómo funciona el marco para HelloWorldWorkflow.

HelloWorldWorkflow se implementa mediante la API AWS Flow Framework para Java, que gestiona los detalles, a veces complicados, de la interacción con Amazon SWF en segundo plano y simplifica considerablemente el proceso de desarrollo. Puede utilizar el mismo proyecto para el que utilizó HelloWorld, que ya está configurado AWS Flow Framework para las aplicaciones Java. Sin embargo, para ejecutar la aplicación, debe configurar una cuenta de Amazon SWF de la siguiente forma:

Para implementar el HelloWorldWorkflow, cree una copia de HelloWorld. HelloWorld empaquete en el directorio de su proyecto y asígnele el nombre HelloWorld. HelloWorldWorkflow. En las siguientes secciones se describe cómo modificar el HelloWorld código original para usarlo AWS Flow Framework para Java y ejecutarlo como una aplicación de flujo de trabajo de Amazon SWF.

HelloWorldWorkflow Trabajador de actividades

HelloWorld implementó sus actividades como trabajador como una sola clase. Un trabajador de actividades AWS Flow Framework para Java tiene tres componentes básicos:

En esta sección, se explican los métodos de actividades; las otras dos clases se explicarán más adelante.

HelloWorldWorkflow define la interfaz de actividades de GreeterActivities la siguiente manera:

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

@ActivityRegistrationOptions(defaultTaskScheduleToStartTimeoutSeconds = 300,
                             defaultTaskStartToCloseTimeoutSeconds = 10)
@Activities(version="1.0")

public interface GreeterActivities {
   public String getName();
   public String getGreeting(String name);
   public void say(String what);
}

Esta interfaz no era estrictamente necesaria para una aplicación Java HelloWorld, pero sí lo es AWS Flow Framework para una aplicación Java. Fíjese en que la definición de la interfaz en sí no ha cambiado. Sin embargo, debe aplicar dos AWS Flow Framework para las anotaciones de Java @ActivityRegistrationOptions y@Tareas, a la definición de la interfaz. Las anotaciones proporcionan información de configuración e indican al AWS Flow Framework procesador de anotaciones de Java que utilice la definición de la interfaz para generar una clase de cliente de actividades, como se explica más adelante.

@ActivityRegistrationOptionstiene varios valores con nombre que se utilizan para configurar el comportamiento de las actividades. HelloWorldWorkflow especifica dos tiempos de espera:

Estos tiempos de espera garantizan que la actividad complete su tarea en un tiempo razonable. Si se supera cualquiera de estos tiempos de espera, el marco de trabajo genera un error y el proceso de trabajo de flujo de trabajo debe decidir cómo tratar el problema. Para leer un debate sobre cómo tratar estos errores, consulte Control de errores.

@Activities tiene varios valores, pero normalmente tan solo especifica el número de versión de las actividades, lo que le permite realizar un seguimiento de diferentes generaciones de implementaciones de las actividades. Si cambia una interfaz de actividad después de registrarla con Amazon SWF, lo que incluye cambiar los valores de @ActivityRegistrationOptions, debe utilizar un número de versión nuevo.

HelloWorldWorkflow implementa los métodos de actividad de GreeterActivitiesImpl la siguiente manera:

public class GreeterActivitiesImpl implements GreeterActivities {
   @Override
   public String getName() {
      return "World";
   }
   @Override
   public String getGreeting(String name) {
      return "Hello " + name;
   }
   @Override
   public void say(String what) {
      System.out.println(what);
   }
}

Observe que el código es idéntico a la HelloWorld implementación. En esencia, una AWS Flow Framework actividad es solo un método que ejecuta algún código y, tal vez, devuelve un resultado. La diferencia entre una aplicación estándar y una aplicación de flujo de trabajo de Amazon SWF radica en la forma en que el flujo de trabajo ejecuta las actividades, dónde se ejecutan estas y cómo se devuelven los resultados al proceso de trabajo de flujo de trabajo.

HelloWorldWorkflow Trabajador de Workflow

Un proceso de trabajo de flujo de trabajo de Amazon SWF posee tres componentes básicos:

En esta sección, se explica la implementación del flujo de trabajo y el cliente de actividades; la clase WorkflowWorker se explicará más adelante.

HelloWorldWorkflow define la interfaz del flujo de trabajo de GreeterWorkflow la siguiente manera:

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 = "1.0")
   public void greet();
}

Esta interfaz tampoco es estrictamente necesaria HelloWorld , pero es esencial para una aplicación AWS Flow Framework para Java. Debe aplicar dos AWS Flow Framework para las anotaciones de Java @Flujo de trabajo y@WorkflowRegistrationOptions, a la definición de la interfaz de flujo de trabajo. Las anotaciones proporcionan información de configuración y también indican al procesador de anotaciones AWS Flow Framework para Java que genere una clase de cliente de flujo de trabajo basada en la interfaz, como se explica más adelante.

@Workflowtiene un parámetro opcional, DataConverter, que suele utilizarse con su valor predeterminado, NullDataConverter, que indica que JsonDataConverter debe utilizarse.

@WorkflowRegistrationOptions también posee una serie de parámetros opcionales que se pueden utilizar para configurar el proceso de trabajo de flujo de trabajo. Aquí, hay que establecer defaultExecutionStartToCloseTimeoutSeconds, que especifica el tiempo durante el que puede ejecutarse el flujo de trabajo: hasta 3600 segundos (1 hora).

La definición de la GreeterWorkflow interfaz difiere de HelloWorld la @Execute anotación en un aspecto importante. Las interfaces de flujo de trabajo especifican los métodos a los que pueden llamar las aplicaciones como el iniciador de flujo de trabajo y se limitan a un puñado de métodos, cada uno con un rol particular. El marco de trabajo no especifica una lista de parámetros o de nombres para los métodos de la interfaz del flujo de trabajo; se utiliza una lista de parámetros y nombres que sea adecuada para el flujo de trabajo y se aplica una anotación de AWS Flow Framework para Java con el fin de identificar el rol del método.

@Execute tiene dos fines:

Para obtener información acerca de otros métodos que se pueden incluir en una interfaz de flujo de trabajo, consulte Contratos de flujo de trabajo y de actividad.

HelloWorldWorkflow implementa el flujo de trabajo de GreeterWorkflowImpl la siguiente manera:

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

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

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

El código es similar a HelloWorld, pero con dos diferencias importantes.

HelloWorld es una aplicación Java estándar que se ejecuta localmente como un proceso único, por lo que GreeterWorkflowImpl puede implementar la topología del flujo de trabajo simplemente creando una instancia deGreeterActivitiesImpl, llamando a los métodos en orden y pasando los valores devueltos de una actividad a la siguiente. Con un flujo de trabajo de Amazon SWF, un método de actividad sigue realizando una tarea de actividad desde GreeterActivitiesImpl. Sin embargo, el método no se ejecuta necesariamente en el mismo proceso que el flujo de trabajo (es posible que ni siquiera se ejecute en el mismo sistema) y el flujo de trabajo tiene que ejecutar la actividad de manera asíncrona. Estos requisitos plantean los siguientes problemas:

Puede implementar una gran variedad de topologías de flujos de trabajo a través del flujo de control de la aplicación utilizando un control de flujo de Java conocido combinado con el cliente de actividades y Promise<T>.

Cliente de actividades

GreeterActivitiesClientImpl básicamente es un proxy para GreeterActivitiesImpl que permite que una implementación de flujo de trabajo ejecute los métodos GreeterActivitiesImpl de manera asíncrona.

Las clases GreeterActivitiesClient y GreeterActivitiesClientImpl se generan automáticamente utilizando la información que se proporciona en las anotaciones que se aplican a la clase GreeterActivities. No es necesario que las implemente personalmente.

El proceso de trabajo del flujo de trabajo ejecuta una actividad llamando al método de cliente correspondiente. El método es asíncrono y devuelve inmediatamente un objeto Promise<T>, donde T es el tipo de retorno de la actividad. El objeto Promise<T> devuelto es básicamente un marcador de posición del valor que devolverá al final el método de la actividad.

Promise <T> Type

La principal finalidad de los objetos Promise<T> es administrar el flujo de datos entre los componentes asíncronos y el control cuando se ejecutan. De esta forma, la aplicación ya no tiene que administrar la sincronización de forma explícita ni depender de mecanismos, como temporizadores, para asegurarse de que los componentes asíncronos no se ejecutan de forma prematura. Cuando se llama a un método del cliente de actividades, este se devuelve inmediatamente, pero el marco de trabajo aplaza la ejecución del método de actividad correspondiente hasta que haya preparado algún objeto Promise<T> de entrada que represente datos válidos.

Desde la perspectiva de GreeterWorkflowImpl, los tres métodos de cliente de las actividades se devuelven inmediatamente. Desde la perspectiva de GreeterActivitiesImpl, el marco de trabajo no llama a getGreeting hasta que name termina y no llama a say hasta que getGreeting termina.

Si utilizamos Promise<T> para pasar datos de una actividad a la siguiente, HelloWorldWorkflow no solo se asegura de que los métodos de actividad no intentan utilizar datos no válidos, sino que también controla cuándo se ejecutan las actividades y define de manera implícita la topología del flujo de trabajo. Para pasar el valor de retorno de Promise<T> de cada actividad a la siguiente, es necesario que las actividades se ejecuten en secuencia, definiendo la topología lineal que se ha explicado anteriormente. En el caso AWS Flow Framework de Java, no es necesario utilizar ningún código de modelado especial para definir incluso topologías complejas, solo el control de flujo estándar de Java y. Promise<T> Para ver un ejemplo detallado de cómo implementar una topología en paralelo sencilla, consulte Proceso de trabajo de actividades de HelloWorldWorkflowParallel.

Promise<T> permite que en una implementación de flujo de trabajo se utilicen métodos de cliente de actividades y sus valores de retorno de una forma muy parecida a los métodos síncronos. Sin embargo, debe tener cuidado al obtener acceso al valor de un objeto Promise<T>. A diferencia del tipo Future<T> de Java, el marco de trabajo se encarga de la sincronización para Promise<T>, no la aplicación. Si llama a Promise<T>.get y el objeto no está preparado, get genera una excepción. Fíjese en que HelloWorldWorkflow nunca obtiene acceso directamente al objeto Promise<T>; simplemente pasa los objetos de una actividad a la siguiente. Cuando un objeto está preparado, el marco de trabajo extrae el valor y lo pasa al método de actividad como un tipo estándar.

Solo se debería obtener acceso a los objetos Promise<T> por medio de código asíncrono, donde el marco de trabajo garantiza que el objeto está preparado y representa un valor válido. Para solucionar este problema, HelloWorldWorkflow pasa objetos Promise<T> solo a métodos de cliente de actividades. Para obtener acceso al valor de un objeto Promise<T> en la implementación del flujo de trabajo, pase el objeto a un método de flujo de trabajo asíncrono, que se comporta de una forma muy parecida a una actividad. Para ver un ejemplo, consulte Aplicación HelloWorldWorkflowAsync.

HelloWorldWorkflow Implementación de flujos de trabajo y actividades

Las implementaciones del flujo de trabajo y las actividades tienen clases de trabajadores asociadas, ActivityWorkery WorkflowWorker. Estas clases se encargan de la comunicación entre Amazon SWF y las implementaciones de actividades y flujos de trabajo al sondear la lista de tareas de Amazon SWF apropiada para buscar tareas, a la vez que ejecutan el método adecuado para cada tarea y administran el flujo de datos. Para obtener más información, consulte Conceptos básicos de AWS Flow Framework: estructura de la aplicación

Para asociar las implementaciones de actividades y flujos de trabajo con los objetos de proceso de trabajo correspondientes, tiene que implementar una o varias aplicaciones de proceso de trabajo que:

Si desea ejecutar el flujo de trabajo y las actividades como procesos independientes, debe implementar distintos hosts de procesos de trabajo de flujos de trabajo y actividades. Para ver un ejemplo, consulte Aplicación HelloWorldWorkflowDistributed. Para simplificar, HelloWorldWorkflow implementa un único servidor de trabajo que ejecuta las actividades y los trabajadores del flujo de trabajo en el mismo proceso, de la siguiente manera:

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 = "HelloWorldList";

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

GreeterWorkerno tiene HelloWorld contrapartida, por lo que debe añadir una clase Java denominada GreeterWorker al proyecto y copiar el código de ejemplo en ese archivo.

El primer paso consiste en crear y configurar un AmazonSimpleWorkflowClientobjeto que invoque los métodos de servicio de Amazon SWF subyacentes. Para ello, GreeterWorker:

Por comodidad, GreeterWorker define dos constantes de cadena.

GreeterWorkerutiliza las constantes de cadena y el AmazonSimpleWorkflowClientobjeto para crear objetos de trabajo, que gestionan la interacción entre las actividades y las implementaciones de los trabajadores y Amazon SWF. En particular, los objetos del proceso de trabajo se encargan de la tarea de sondeo de la lista de tareas correspondiente para buscar tareas.

GreeterWorker crea un objeto ActivityWorker y lo configura para que se encargue de GreeterActivitiesImpl añadiendo una nueva instancia de clase. Luego, GreeterWorker llama al método start del objeto ActivityWorker, que le indica al objeto que comience a sondear la lista de tareas de actividad especificada.

GreeterWorker crea un objeto WorkflowWorker y lo configura para que se encargue de GreeterWorkflowImpl añadiendo el nombre de archivo de clase, GreeterWorkflowImpl.class. Luego, llama al método start del objeto WorkflowWorker, que le indica al objeto que comience a sondear la lista de tareas del flujo de trabajo especificada.

En este momento, puede ejecutar GreeterWorker correctamente. Registra el flujo de trabajo y las actividades con Amazon SWF y hace que los objetos del proceso de trabajo comiencen a sondear sus correspondientes listas de tareas. Para verificar esto, ejecute GreeterWorker, vaya a la consola de Amazon SWF y seleccione helloWorldWalkthrough en la lista de dominios. Si elige Workflow Types (Tipos de flujo de trabajo) en el panel Navigation (Navegación), debería ver GreeterWorkflow.greet:

Si elige Activity Types (Tipos de actividad), se muestran los métodos GreeterActivities:

Sin embargo, si elige Workflow Executions (Ejecuciones de flujo de trabajo), verá las ejecuciones activas. Aunque los procesos de trabajo de flujos de trabajo y actividades sondean tareas, aún no hemos iniciado una ejecución de flujo de trabajo.

HelloWorldWorkflow Motor de arranque

La última pieza del puzle es la implementación de un iniciador de flujo de trabajo, que es una aplicación que inicia la ejecución del flujo de trabajo. Amazon SWF almacena el estado de la ejecución para que pueda consultar su historial y su estado de ejecución. HelloWorldWorkflow implementa un iniciador de flujo de trabajo modificando la GreeterMain clase de la siguiente manera:

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;

public class GreeterMain {

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

     GreeterWorkflowClientExternalFactory factory = new GreeterWorkflowClientExternalFactoryImpl(service, domain);
     GreeterWorkflowClientExternal greeter = factory.getClient("someID");
     greeter.greet();
   }
}

GreeterMain crea un objeto AmazonSimpleWorkflowClient utilizando el mismo código que GreeterWorker. Luego, crea un objeto GreeterWorkflowClientExternal, que sirve de proxy para el flujo de trabajo, de una forma muy parecida al cliente de actividades creado en GreeterWorkflowClientImpl, que sirve de proxy para los métodos de actividades. En lugar de crear un objeto de cliente de flujo de trabajo mediante new, debe:

El cliente que se devuelve de la fábrica solo crea flujos de trabajo con el nombre de la cadena que se haya pasado al método getClient (el cliente que se ha devuelto de la fábrica ya tiene un estado en Amazon SWF). Para ejecutar un flujo de trabajo con un identificador diferente, hay que volver a la fábrica y crear un cliente nuevo especificando el identificador diferente.

El cliente de flujo de trabajo expone un método greet al que llama GreeterMain para comenzar el flujo de trabajo, ya que greet() es el método que se ha especificado con la anotación @Execute.

Cierre GreeterWorker por ahora, si aún se está ejecutando, y ejecute GreeterMain. Ahora debería ver someID en la lista de ejecuciones de flujos de trabajo activas de la consola de Amazon SWF:

Si elige someID y luego la pestaña Events (Eventos), se muestran los eventos:

En la pestaña Events (Eventos) solo aparecen dos eventos:

El motivo de que el flujo de trabajo se bloquee en la primera tarea de decisión es porque está distribuido en dos aplicaciones: GreeterMain y GreeterWorker. GreeterMain ha comenzado la ejecución del flujo de trabajo, pero GreeterWorker no se está ejecutando, por lo que los procesos de trabajo no sondean las listas ni ejecutan tareas. Puede ejecutar cualquiera de las aplicaciones de forma independiente, pero necesita ambas para que la ejecución del flujo de trabajo continúe después de la primera tarea de decisión. Si ahora ejecuta GreeterWorker, los procesos de trabajo de flujo de trabajo y actividad comenzarán a realizar el sondeo y las diversas tareas se realizarán rápidamente. Si comprueba ahora la pestaña Events (Eventos), verá el primer lote de eventos.

Puede elegir eventos individuales para obtener más información. Cuando haya terminado de consultarlos, el flujo de trabajo debería haber imprimido las palabras “Hello World!” en la consola.

Una vez completado el flujo de trabajo, desaparece de la lista de ejecuciones activas. Sin embargo, si desea revisarlo, elija el botón de estado de ejecución Closed (Cerrado) y luego elija List Executions (Lista de ejecuciones). Aquí se muestran todas las instancias de flujo de trabajo completadas en el dominio especificado (helloWorldWalkthrough) que no han superado su tiempo de retención, que especificó en el momento de crear el dominio.

Fíjese en que cada instancia de flujo de trabajo tiene un valor de Run ID (Identificador de ejecución) único. Puede utilizar el mismo identificador de ejecución para diferentes instancias de flujo de trabajo, pero solo para una ejecución activa al mismo tiempo.