JMS（Jboss Messaging）的一点使用心得（二）使用Spring

Spring对JMS支持得非常好，使用起来也很方便；下面是使用Spring的方法。

准备工作：
想要运行Messaging客户端，需要几个包，请参见< http://labs.jboss.com/file-access/default/members/jbossmessaging/freezone/docs/userguide-1.4.0.SP1/html/installation.html>
1．配置JMS ConnectionFactory
<jee:jndi-lookup id="jmsConnectionFactory" jndi-name="ConnectionFactory">
<jee:environment>
java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory
java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces
java.naming.provider.url=localhost:1099
</jee:environment>
</jee:jndi-lookup>

2．配置发送JMS的JmsTemplate
<bean id="jmsTemplate" lazy-init="true" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="jmsConnectionFactory" />
<property name="defaultDestinationName" value="A" />
</bean>

3．配置JMS的接收器
<bean id="messageListener" class="jms.receiver.SimpleMessageListener" />

该Class必须实现javax.jms.MessageListener接口

4．配置JMS ListenerContainer
<bean id="listenerContainerQueue" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="concurrentConsumers" value="1" />
<property name="connectionFactory" ref="jmsConnectionFactory" />
<property name="destinationName" value="A" />
<property name="messageListener" ref="messageListener" />
<property name="exceptionListener" ref="exceptionListener" />
</bean>

5．如果需要的话，配置JMS ExceptionListener
<bean id="exceptionListener" class="jms.receiver.SimpleExceptionListener" />
同理，该Class必须实现javax.jms.ExceptionListener接口

6．发送Jms消息
String strTest = "JmsTest";
BeanFactory factory = new ClassPathXmlApplicationContext("applicationContext_Sender.xml");
JmsTemplate template = (JmsTemplate) factory.getBean("jmsTemplate");
template.convertAndSend(strTest);
System.out.println(strTest);

7．接收Jms消息
BeanFactory factory = new ClassPathXmlApplicationContext("applicationContext_Receiver.xml");
只需要初始化配置文件就可以接收了