JMS Apache ActiveMQ使用(2)
下面就进行程序开发，没得说，当然是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，在连接错误时把消息放入缓存队列中，连接成功后再发送。