Simple basé sur java gestionnaire de flux de travail / de données de flux de travail avec la possibilité de commencer ext. demande, appelez web services, etc

Apache Camel est un open source d'intégration de cadre qui va vous aider dans cette.

Vous pouvez utiliser Apache Camel de construire votre propre simple gestionnaire de flux de travail, où chaque processus met en œuvre Processeur. Vos données transmises par l'intermédiaire de transformateurs à l'aide de chameau L'échange. Découvrez chameau exemples pour plus d'informations.

Pour plus d'informations sur la façon d'écrire processeur personnalisé, veuillez lire ici.

Vous pouvez ajouter des Processeurs à un Chameau RouteBuilder de manière dynamique, de planifier l'aide de Planificateur Quartz etc., qui aura plus ou moins d'adresse à toutes vos exigences.

Ici est une bonne introduction à dos de Chameau : http://www.kai-waehner.de/blog/2012/05/04/apache-camel-tutorial-introduction/

Une simple mise en œuvre de Gestionnaire de Flux de travail à l'aide de Chameau:

WorkflowManager.java

import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;

public class WorkflowManager {

    DefaultCamelContext camelContext;

    public WorkflowManager() {
        camelContext = new DefaultCamelContext();
        RouteBuilder routeBuilder = new RouteBuilder() {

            @Override
            public void configure() throws Exception {
                from("timer:schedule?period=1s&daemon=true").process(new ProcessOne()).process(new ProcessTwo());
            }
        };
        try {
            camelContext.addRoutes(routeBuilder);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public void start() throws Exception {
        camelContext.start();
    }

    public void stop() throws Exception {
        camelContext.stop();
    }

    public static void main(String[] args) {
        WorkflowManager workflowManager = new WorkflowManager();
        try {
            workflowManager.start();
            while(true) {

            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

ProcessOne.java

import org.apache.camel.Exchange;
import org.apache.camel.Processor;

public class ProcessOne implements Processor {
    @Override
    public void process(Exchange exchange) throws Exception {
        System.out.println("In ProcessOne");
    }
}

ProcessTwo.java

import org.apache.camel.Exchange;
import org.apache.camel.Processor;

public class ProcessTwo implements Processor {
    @Override
    public void process(Exchange exchange) throws Exception {
        System.out.println("In ProcessTwo");
    }
}

J'ai utilisé Chameau version 2.9.0 pour compiler ce code. Veuillez noter que j'ai utilisé une boucle infinie dans la principale méthode pour garder le thread principal en vie.

Ce code sera exécuté un itinéraire avoir ProcessOne et ProcessTwo, avec une période de 1 seconde. Vous pouvez voir la période de(...) méthode où j'ai ajouter des processeurs de route builder. Par conséquent, cette route va être exécuté plusieurs fois. Aussi, je n'essaie pas de flux de données. Vous pouvez utiliser de l'échange dans la méthode de traitement de chaque processeur de flux de données.

Sortie sera:

In ProcessOne

In ProcessTwo

In ProcessOne

In ProcessTwo

Vous pouvez utiliser des composants camel, afin de rendre votre WorkflowManager robuste.

OriginalL'auteur jainbasil