Spring Integration
Spring Integration es un producto relativamente desconocido del Spring. Brinda una extensión a Spring para soportar los Patrones de Integración Corporativos en pocas palabras es un ESB liviano montado sobre el contenedor de Spring e independiente del Servidor de aplicaciones. Permite utilizar mensajería dentro de una aplicación Spring, y se integra con sistemas externos a través de adaptadores. Se basa en el concepto de "mensajes" para intercambiar datos entre distintos componentes.
Contenido
Conceptos y componentes básicos
Conceptos
- Channel (MessageChannel), representa un canal lógico por donde se reciben o se envían mensajes.
- Channel-adapter, representa el adaptador entre el canal lógico y una implementación física de ese canal.
- Bridge, se encarga de redireccionar todos los mensajes del canal de entrada hacia un canal de salida.
- Router, se encarga de redireccionar los mensajes que llegan a un canal de entrada hacia uno o varios canales de salida, dependiendo de ciertas condiciones.
- Splitter, se encarga de separar el contenido de un mensaje en muchos mensajes.
- Transformer, se encarga de transformar el formato del contenido del mensaje.
Componentes
- Message, esta compuesto por una cabecera (headers) y por un cuerpo (Payload).
- MessageChannel, provee métodos para enviar y recibir.
- MessageEndpoint, Conecta un Handler a un MessageChannel de entrada o/y a uno de salida.
- MessageHandler, interfaz que permite transformer, rutear y en general “tartar” cualquier mensaje de Entrada.
- Channel Adapters, se usan para enviar y recibir mensajes a sistemas externos.
Adaptadores
Ejemplos
Configuración de canales
Spring Integration se basa en canales, lugares en donde se consumen o envian mensajes. Estos canales pueden ser colas JMS u otros medios, como clases propias. La siguiente definición de canales se usa en los ejemplos que siguen.
<integration:channel id="QueueChanneIn"/>
<jms:message-driven-channel-adapter connection-factory="PruebaQueueConnectionFactory" destination-name="jms/Queue-in" destination-resolver="jmsDestinationResolver" channel="QueueChanneIn" acknowledge="auto" concurrent-consumers="1"/>
<integration:channel id="QueueChanneOut1"/> <jms:outbound-channel-adapter jms-template="jmsQueueTemplateOut1" channel="QueueChanneOut1"/>
<integration:channel id="QueueChanneOut2"/> <jms:outbound-channel-adapter jms-template="jmsQueueTemplateOut2" channel="QueueChanneOut2"/>
stdout-channel-adapter
Podemos consumir un mensaje de una cola y mostrarlo por consola. Para esto es necesario configurar un stdout-channel-adapter, el cual se encargará de procesar los mensajes. Luego, se crea un bridge que asocia un canal de entrada con este adaptador.
<stream:stdout-channel-adapter id="stdout" append-newline="true"/>
<integration:bridge id="echo" input-channel="QueueChanneIn" output-channel="stdout"/>
recipient-list-router
Podemos consumir un mensaje de una cola y enviarlo a una lista fija de canales de destino. En este ejemplo creamos un recipient-list-router, el cual consume mensajes de un canal de entrada y los envia a dos canales de destino distintos. Entonces, cada mensaje que llegue al canal de entrada será derivado a dos canales de destino.
<integration:recipient-list-router input-channel="QueueChanneIn" apply-sequence="true">
<integration:recipient channel="QueueChanneOut1"/>
<integration:recipient channel="QueueChanneOut2"/>
</integration:recipient-list-router>
header-value-router
Podemos consumir un mensaje de una cola y enviarlo a una cola especifica dependiendo del valor de un atributo del header del mensaje. De esta manera, configuramos un header-value-router, el cual contiene el canal de entrada y el nombre del atributo del encabezado que se comprobará. Luego, se realiza el mapeo entre los posibles valores de este encabezado y algún canal de destino. Si llega un mensaje que coincida este mapeo, será enviado a ese canal de destino.
<integration:header-value-router input-channel="QueueChanneIn"
header-name="springintegration_jms_type">
<integration:mapping value="Out1" channel="QueueChanneOut1"/>
<integration:mapping value="Out2" channel="QueueChanneOut2"/>
</integration:header-value-router>
router
Podemos consumir un mensaje de una cola y enviarlo a una lista de colas de salida utilizando un pojo para determinar a que colas enviarlo. En este ejemplo, creamos un router que será implementado por la clase "MultiDestino". Esta clase devuelve una lista de nombres de canales hacia donde se derivará el mensaje.
<integration:router input-channel="QueueChanneIn" ref="multiDestino"/>
<bean id="multiDestino" class="com.dosideas.springintegration.MultiDestino"/>
public class MultiDestino {
@Router
public List<String> resolverChannel(GenericMessage message) throws JMSException {
List<String> list = new ArrayList<String>();
if(message.getHeaders().get("springintegration_jms_type").equals("Out1")) {
System.out.println(message.getHeaders().get("springintegration_jms_type"));
list.add("QueueChanneOut1");
}
else if(message.getHeaders().get("springintegration_jms_type").equals("Out2")) {
System.out.println(message.getHeaders().get("springintegration_jms_type"));
list.add("QueueChanneOut2");
}
else if(message.getHeaders().get("springintegration_jms_type").equals("Multi")) {
System.out.println(message.getHeaders().get("springintegration_jms_type"));
list.add("QueueChanneOut1");
list.add("QueueChanneOut2");
}
return list; }
}
