En esta entrada vamos a ver como configurar (de forma rápida), como configurar colas con Spring y un gestor de colas, como es el caso de Apache ActiveMQ, para enviar y recibir mensajes. Para ello, podéis descargar:
- La versión 5.7.0 de ActiveMQ
- Tomcat 7
Os creáis un proyecto Maven con la siguiente configuración:
En el pom.xml, la dependencia a Spring y al core de ActiveMQ:
<?xml version="1.0"?> <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/maven-v4_0_0.xsd"> <artifactId>spring-activemq-sample</artifactId> <modelVersion>4.0.0</modelVersion> <packaging>war</packaging> <groupId>papidal</groupId> <version>1.0</version> <properties> <releaseCandidate>1</releaseCandidate> <spring.version>3.1.1.RELEASE</spring.version> <java.version>1.5</java.version> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <maven.javadoc.reporting.version>2.7</maven.javadoc.reporting.version> <commons.logging.version>1.1.1</commons.logging.version> <log4j.version>1.2.16</log4j.version> <context.path>spring-activemq-sample</context.path> </properties> <build> <resources> <resource> <directory>src/main/resources</directory> <filtering>true</filtering> </resource> </resources> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-war-plugin</artifactId> <configuration> <warName>${context.path}</warName> </configuration> </plugin> </plugins> </build> <dependencies> <dependency> <groupId>log4j</groupId> <artifactId>log4j</artifactId> <version>${log4j.version}</version> </dependency> <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-core</artifactId> <version>5.7.0</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jms</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jms</artifactId> <version>3.1.0.RELEASE</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-core</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-beans</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-aop</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-aspects</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-asm</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-expression</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-web</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-webmvc</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>javax.servlet</groupId> <artifactId>servlet-api</artifactId> <version>2.4</version> </dependency> </dependencies> </project>
Un contexto, context.xml, en el que estarán vuestras colas de entrada y salida, así como la conexión al gestor de colas:
<?xml version="1.0" encoding="UTF-8"?> <Context> <!-- Conexión ActiveMQ --> <Resource name="jms/mqConnectionFactory" auth="Container" type="org.apache.activemq.ActiveMQConnectionFactory" description="JMS Connection Factory" factory="org.apache.activemq.jndi.JNDIReferenceFactory" brokerURL="tcp://localhost:61616" /> <!-- Cola 1 --> <Resource name="jms/testQueueOne" auth="Container" type="org.apache.activemq.command.ActiveMQQueue" factory="org.apache.activemq.jndi.JNDIReferenceFactory" physicalName="TestQueueOne"/> <!-- Cola 2 --> <Resource name="jms/testQueueTwo" auth="Container" type="org.apache.activemq.command.ActiveMQQueue" factory="org.apache.activemq.jndi.JNDIReferenceFactory" physicalName="TestQueueTwo"/> </Context>
El resto de configuración, en spring-config.xml
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:jee="http://www.springframework.org/schema/jee" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.0.xsd"> <!-- Recursos jndi --> <jee:jndi-lookup id="mqConnectionFactory" jndi-name="java:comp/env/jms/mqConnectionFactory" /> <jee:jndi-lookup id="testQueueOne" jndi-name="java:comp/env/jms/testQueueOne" /> <jee:jndi-lookup id="testQueueTwo" jndi-name="java:comp/env/jms/testQueueTwo" /> <!-- Clase que recibe los mensajes --> <bean id="testMessageListener" class="papidal.TestMessageListener"> <property name="testMessageSender" ref ="testMessageSender" /> </bean> <bean id="poiMessageListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="connectionFactory" ref ="mqConnectionFactory" /> <property name="destination" ref ="testQueueOne"/> <property name="messageListener" ref ="testMessageListener"/> <property name="concurrentConsumers" value="2" /> </bean> <!-- Clase que envía los mensajes --> <bean id="testMessageSender" class="papidal.TestMessageSender"> <property name="jmsTemplate" ref="jmsTemplate"/> <property name="testQueue" ref="testQueueTwo"/> </bean> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <property name="connectionFactory" ref="mqConnectionFactory" /> </bean> </beans>
En el web.xml, indicáis dónde tenemos la configuración de spring:
<?xml version="1.0" encoding="UTF-8"?> <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" id="WebApp_ID" version="2.5"> <!-- Fichero de configuración de spring --> <context-param> <param-name>contextConfigLocation</param-name> <param-value> /WEB-INF/config/spring-config.xml </param-value> </context-param> <!-- Cargamos el contexto de Spring --> <listener> <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> </listener> </web-app>
La clase que escucha en la cola 1, los mensaje que llegan:
package papidal; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.TextMessage; import org.apache.log4j.Logger; public class TestMessageListener implements MessageListener { private TestMessageSender messageSender_i; private static final Logger logger_c = Logger.getLogger(TestMessageListener.class); //Escucha los mensajes public void onMessage(Message message) { logger_c.info("Recibo mensaje de la cola [" + message +"]"); if (message instanceof TextMessage) { try { String msgText = ((TextMessage) message).getText(); logger_c.debug("Mensaje recibido: " + msgText); messageSender_i.sendMessage(msgText); } catch (JMSException jmsEx_p) { String errMsg = "Error obteniendo el mensaje"; logger_c.error(errMsg, jmsEx_p); } } else { String errMsg = "El mensaje no es del tipo TextMessage"; logger_c.error(errMsg); throw new RuntimeException(errMsg); } } public void setTestMessageSender(TestMessageSender messageSender_p) { this.messageSender_i = messageSender_p; } }
La clase que usamos para enviar los mensajes recibidos hacia la cola 2:
package papidal; import javax.jms.JMSException; import javax.jms.Queue; import org.apache.log4j.Logger; import org.springframework.jms.core.JmsTemplate; import org.springframework.stereotype.Service; // Enviamos mensajes a una cola @Service public class TestMessageSender { private JmsTemplate jmsTemplate_i; private Queue testQueue_i; private static final Logger logger_c = Logger .getLogger(TestMessageSender.class); // Envio del mensaje public void sendMessage(String message_p) throws JMSException { logger_c.debug("Ponemos el mensaje en la cola[" + testQueue_i.toString() + "] Mensaje[" + message_p + "]"); jmsTemplate_i.convertAndSend(testQueue_i, message_p); } public void setJmsTemplate(JmsTemplate tmpl) { this.jmsTemplate_i = tmpl; } public void setTestQueue(Queue queue) { this.testQueue_i = queue; } }
Levantáis el gestor de colas:
"D:\apache-activemq-5.7.0\bin\activemq.bat"
Para administrar:
Simplemente con levantar el servidor ya veremos la cola 1 (en mi caso, un Tomcat 7) con 2 consumidores.
Le damos a "send To", metemos cualquier cosa (típicamente un xml) y vemos que por la
consola de Tomcat hemos recibido el mensaje correctamente, que hemos enviado
por la cola 1 y que lo hemos a su vez enviado a la cola 2.
En el ActiveMQ podemos
verlo también (fijaros en la columna de encolados y desencolados. Como la cola
para enviar mensajes es la dos, y nosotros escuchamos sólo la 1, la cola 2 no
tiene consumidores activos ya que sólo la usamos para enviar mensajes. Si algún
modulo quiere escucharla, no hay problema).
Acordaros de darle a F5 para
refrescar la pantalla ;)
A partir de aquí, se pueden definir canales, jugar con el xpath para aceptar o descartar mensajes en función del identificador del envoltorio, usar jaxb para hacer marshall/unmarshall, definir el encoding del parseo de xml a clases Java y viceversa, ...
