Apache Camel: introdu��o ao framework de integra��o

Nesse artigo vamos explorar o framework Apache Camel, abordando um pouco da sua hist�ria, uma vis�o geral do seu prop�sito e um exemplo do que ele � capaz.

O Apache Camel � um framework de integraç�o baseado em padr�es empresariais de integraç�o (EIP). Traduzindo em termos simples, ele pretende simplificar a integraç�o entre sistemas. O fato de ser baseado em padr�es � o que o torna uma das melhores opç�es do mercado. Padr�es, como sabemos, representam as melhores pr�ticas ou a melhor forma de se fazer alguma coisa. Padr�es tamb�m facilitam a comunicaç�o entre as pessoas e, al�m disso, s�o reaproveit�veis, trazendo maior produtividade e diminuindo o custo de propriedade.

Independente de todo esse discurso empresarial chato, desenvolver com Apache Camel pode ser extremamente divertido. Com poucas linhas de c�digo ou configuraç�o, podemos processar arquivos, process�-los em paralelo, invocar Web Services, publicar eventos em uma fila JMS e muito mais.

Criado em 2007 por James Strachan, o Apache Camel j� tem cinco anos de idade e est� crescendo firme e forte. Hoje ele � parte de produtos como Apache ServiceMix, Fuse ESB e Jboss Application Server. Esse framework � adapt�vel a diversas situaç�es pois sua arquitetura permite que voc� utilize apenas os componentes necess�rios para o seu projeto. Al�m disso, o Apache Camel tem um suporte fant�stico para construç�o de testes unit�rios e mocks.

Figura 1: Livro cl�ssico sobre EIP escrito por Gregor Hohpe e Bobby Woolf

Para demonstrar um pouco do que o Apache Camel � capaz, vamos ao c�digo:

Listagem 1: Arquivo pom.xml do projeto


<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" 
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

    <modelVersion>4.0.0</modelVersion>
    <artifactId>introducao-camel</artifactId>
    <groupId>devmedia</groupId>
    <packaging>jar</packaging>
    <version>0.0.1</version>
    <name>IntroCamel</name>
    <description>Introducao Apache Camel</description>

    <dependencies>
        <dependency>
	  <groupId>org.apache.camel</groupId>            
            <artifactId>camel-core</artifactId>
            <version>2.10.2</version>
        </dependency>
        <dependency>
	  <groupId>org.apache.camel</groupId>            
            <artifactId>camel-http</artifactId>
            <version>2.10.2</version>
        </dependency>
        <dependency>
	  <groupId>org.apache.camel</groupId>            
            <artifactId>camel-jetty</artifactId>
            <version>2.10.2</version>
        </dependency>        
        <dependency>
	  <groupId>org.apache.camel</groupId>            
            <artifactId>camel-test</artifactId>
            <version>2.10.2</version>
        </dependency>
        <dependency>
	  <groupId>ch.qos.logback</groupId>
	  <artifactId>logback-core</artifactId>
	  <version>1.0.7</version>
        </dependency>
	  <dependency>
	  <groupId>ch.qos.logback</groupId>
	  <artifactId>logback-classic</artifactId>
	  <version>1.0.7</version>
        </dependency>
    </dependencies>
</project>

No arquivo de projeto maven (pom.xml) temos tudo o que � necess�rio para o nosso pequeno teste. Os artefatos listados s�o:

camel-core: componente principal da arquitetura do Apache Camel. Nesse jar temos as classes principais para construç�o das aplicaç�es.
Camel-http, camel-jetty, camel-test: como dito, adicionamos apenas artefatos que precisamos. Nesse caso, adicionamos o cliente http, o servidor http Jetty e o suporte a testes unit�rios.
Logback-core e logback-classic: para quem n�o conhece, esses dois artefatos s�o implementaç�es da API do SLF4J, que � o mecanismo de logging utilizado pelo Apache Camel.

Para criaç�o dos descritores para o IDE Eclipse, executamos o comando

Listagem 2: Comando do maven


mvn eclipse:eclipse

Se voc� n�o conhece o maven, lembre-se de visitar http://maven.apache.org.

Agora examinaremos um pequeno teste unit�rio que cria e inicia um servidor Jetty. Dois m�todos de teste foram criados. O primeiro chamado �testEnvioSimples� submete ao servidor um xml e aguarda o retorno de apenas 1 (uma) mensagem. Em seguida examina o conte�do da mensagem retornada. O segundo teste chamado �testEnvioSimplesNaoSuportado� manda um xml levemente modificado. Como o valor �2� no conte�do do XML n�o � aceito, nenhuma mensagem ser� retornada. Vamos � listagem:

Listagem 3: Classe de teste


package br.com.devmedia.introcamel;

import java.util.List;

import org.apache.camel.EndpointInject;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.Produce;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.junit.Assert;
import org.junit.Test;

public class CamelTest extends CamelTestSupport {

	@Produce(uri = "http://localhost:9898/test" )
    protected ProducerTemplate template;
	
	@EndpointInject(uri = "mock:end")
	protected MockEndpoint mockEndpoint;
	
	@Test
	public void testEnvioSimples() throws Exception {
		template.sendBody("<doc><param>1</param></doc>");
		mockEndpoint.expectedMessageCount(1);
		mockEndpoint.assertIsSatisfied();
		List<Exchange> exchanges = mockEndpoint.getExchanges();
		Assert.assertTrue("Mensagem Inspecionada",exchanges.get(0).getIn().getHeader("OK",Boolean.class));;
	}
	
	@Test
	public void testEnvioSimplesNaoSuportado() throws Exception {
		template.sendBody("<doc><param>2</param></doc>");
		mockEndpoint.expectedMessageCount(0);
		mockEndpoint.assertIsSatisfied();
	}
	
	protected RouteBuilder createRouteBuilder() {
		return new RouteBuilder() {

	@Override
	public void configure() throws Exception {
             from("jetty://http://localhost:9898/test")
             .filter()
             .xpath("/doc/param='1'").process(new Processor() {					         
                public void process(Exchange exchange) 
                throws Exception {
	            exchange.getIn().setHeader("OK", Boolean.TRUE);
                }
					
		}).to("mock:end").end();
	}
			
};
}
}

Alguns fatos importantes sobre essa classe:

Ela estende org.apache.camel.test.junit4.CamelTestSupport. Essa � apenas uma das formas de se testar integraç�es no Camel. D� uma boa olhada em http://camel.apache.org/testing.html.
Ela sobrescreve o m�todo createRouteBuilder. Um RouteBuilder � um construtor de rotas. Uma rota representa uma mensagem indo de um lugar para outro. Normalmente envolve um produtor (from) e um consumidor (to). No exemplo, o produtor � o jetty://http://localhost:9898/test ou seja, alguma mensagem ser� produzida por esse endereço ou URI. Iremos capturar essa mensagem e trat�-la no nosso processador. Ali�s, esse endereço jetty � chamado de endpoint e s� funciona se o camel-jetty fizer parte do nosso projeto. Para mais exemplos: http://camel.apache.org/jetty.html.
Implementamos um processador. Processadores s�o classes que processam mensagens conhecidas por Exchange. Um Exchange encapsula todo tipo de informaç�o que trafega nas rotas. Veja mais em http://camel.apache.org/exchange.html.
O nosso servidor http jetty n�o processar� todo tipo de mensagem, apenas aquelas cujo conte�do XML seja 1. Repare na express�o xpath /doc/param='1'. Ela � utilizada como filtro de mensagens. Filtro de mensagens � um padr�o de intregraç�o. Detalhes em http://camel.apache.org/message-filter.html.
Toda mensagem � direcionada o mock:end. Mock � um componente do core do Apache Camel. Ele deve ser usado apenas nos teste e serve para fazer assertivas quanto �s mensagens.
Uso de anotaç�es. Atrav�s delas, a classe de teste injeta o uma inst�ncia de ProducerTemplate. Essa classe � essencial para interaç�o com as rotas e serve para enviar criar e enviar exchanges para os endpoints. No nosso exemplo, envia um XML para o servidor http. Tamb�m usamos anotaç�es para obter refer�ncias para os endpoints como no caso do mock.

Figura 2: Pattern de Integraç�o �Message Filter�

Reparem que com pouqu�ssimas linhas criamos um servidor HTTP que filtra mensagens e as processa. Com Apache Camel, seria muito f�cil enviar esse xml para um arquivo, banco de dados, Web Service ou o que o Camel suportar atrav�s de seus componentes. A lista completa de componentes pode ser vista em http://camel.apache.org/components.html.

� isso pessoal. Finalizamos nossa breve vis�o do que � o framework Apache Camel. Experimentem alterar os testes e adicionar novos componentes, sempre acompanhando as mensagens que saem no console. At� a pr�xima.

Introdu��o ao Apache Camel

Veja neste artigo uma breve introdução ao Apache Camel, um framework de integração baseado em padrões empresariais de integração (EIP). Traduzindo em termos simples, ele pretende simplificar a integração entre sistemas.

Artigos relacionados