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，在连接错误时把消息放入缓存队列中，连接成功后再发送。