JMS Apache ActiveMQ使用(2)

zzgzyyz

下面就进行程序开发，没得说，当然是spring了
使用spring开发JMS比较简单，直接使用的是JmsTemplate，需要几个相关对象。

ConnectionFactory：创建与ActiveMQ连接的工厂类
Destination：目标Topic或Queue
MessageConverter：在Java POJO和JMS Message进行转换

关于JMS的其他接口如Session，MessageProducer/MessageConsumer都是在JmsTemplate内部处理，不需要开发关注具体细节。
首先配置分别针对Topic和Queue的JmsTemplate(其实发送和接受消息代码中不需要关心是Topic还是Queue，JMS 1.1标准对于两者在客户端的处理已经可以通用了)
spring-jms.xml

<?xml version="1.0" encoding="GBK"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN 2.0//EN"
"http://www.springframework.org/dtd/spring-beans-2.0.dtd">
<beans>
<bean id="jmsFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="failover:(tcp://localhost:61616)"/>
<property name="transportListener">
<bean class="com.viva.server.message.jms.JmsTransportListener"/>
</property>
</bean>
<bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg value="Huzl.queue"></constructor-arg>
</bean>
<bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">
<constructor-arg value="Huzl.topic"></constructor-arg>
</bean>
<bean id="messageConvert" class="com.viva.server.message.jms.VivaMessageConvert"/>
<bean id="queueTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="jmsFactory" />
<property name="defaultDestination" ref="queueDestination"/>
<property name="messageConverter" ref="messageConvert"/>
</bean>
<bean id="topicTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="jmsFactory" />
<property name="defaultDestination" ref="topicDestination"/>
<property name="messageConverter" ref="messageConvert"/>
</bean>
</beans>

VivaMessageConvert.java代码，使用的是JMS的MapMessage，而VivaUserRegisterMessage类是业务中用到的POJO，代码就不贴出来了。

import org.springframework.jms.support.converter.MessageConversionException;
import org.springframework.jms.support.converter.MessageConverter;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.Session;
import java.util.Date;
/**
* User: bloodwolf_china
* Date: 2008-6-24
* Time: 15:20:42
* Descript:
*/
public class VivaMessageConvert implements MessageConverter {
public Message toMessage(Object object, Session session) throws JMSException, MessageConversionException {
MapMessage msg = session.createMapMessage();
VivaUserRegisterMessage registerMessage = (VivaUserRegisterMessage) object;
msg.setLong("RegisterTime",registerMessage.getRegisterTime().getTime());
msg.setInt("UserId",registerMessage.getUserId());
msg.setString("Tel",registerMessage.getTel());
return msg;  
}
public Object fromMessage(Message message) throws JMSException, MessageConversionException {
MapMessage msg = (MapMessage) message;
VivaUserRegisterMessage registerMessage = new VivaUserRegisterMessage();
registerMessage.setRegisterTime(new Date(msg.getLong("RegisterTime")));
registerMessage.setUserId(msg.getInt("UserId"));
registerMessage.setTel(msg.getString("Tel"));
return registerMessage;
}
}

到这儿客户端发送消息的准备工作已经完成了，可以从spring取得queueTemplate/topicTemplat发送JMS Message了
注意其中brokerURL的值为"failover:(tcp://localhost:61616)",其中failover关键字表示客户端与ActiveMQ Server的连接中断后(如Server重新启动)，客户端会自动重新连接，不需要在我们的代码中处理了。但是有个麻烦就是使用JmsTemplate发送消息时，当前的线程也会被wait直到重新连接ActiveMQ服务器成功，这种情况可能会导致线程被耗尽的危险。所以可以配置一个TransportListener，在连接错误时把消息放入缓存队列中，连接成功后再发送。