Spring整和ActiveMQ

问题一：为什么要整合ActiveMQ？

      传统的JDBC代码在处理连接、语句、结果集和异常时是多么冗长和繁杂你一定不会忘记，传统的JMS继承了JDBC的“关荣传统”。发送一个简单的消息，要几行代码呢？请仔细数数吧。

	public void sendMessage() throws JMSException {
		ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
		"tcp://localhost:61616");
		Connection connection = null;
		Session session=null;
		try {
			
			connection = (Connection) connectionFactory.createConnection();//创建连接
			session = (Session) connection.createSession(false,
					Session.AUTO_ACKNOWLEDGE);//创建会话
			Destination destination = session.createQueue("myQueue");
			MessageProducer producer = session.createProducer(destination);
			TextMessage message = session.createTextMessage(expectedBody);
			message.setStringProperty("headname", "remoteB");
			producer.send(message);
			connection.close();
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			try {
				if(session!=null){
					session.close();
				}
				if(connection!=null){
					connection=null;
				}
			} catch (Exception e) {
				
			}
		}
	}

 

传统接受消息而是类似的代码，其实我们的目的就是发送和接受消息。幸运的是Spring为我们提供了大量的模板。项目一期用的较多的是JdbCTemplate，spring也为我们提供了JMSTemplate模板。

 

问题二：JMSTemplate模板该如何配置呢？

类似于jdbcTemplate，首先要配置一个ConnectionFactory，我们采用ActiveMQ5.2作为消息服务器。之后要开始配置JmsTemplate模板了。最后是配置消息目标了。消息分为队列和主题两大类，因此要配置两个消息目标了。

 

<!-- ActiveMQ -->
    
    <!-- 配置JMS连接工厂 -->  
    <bean id="JmsConnectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">  
    	<property name="brokerURL" value="tcp://localhost:61616"/>  
    </bean>  
    <!-- 配置JMS模版 -->  
    <bean id="JmsTemplate" class="org.springframework.jms.core.JmsTemplate">  
    	<property name="connectionFactory" ref="JmsConnectionFactory"/>  
    </bean>  
    <!-- 发送消息的目的地（队列） -->  
    <bean id="QueueDestination" class="org.apache.activemq.command.ActiveMQQueue">  
    	<!-- 设置消息队列的名字 -->  
    	<constructor-arg index="0" value="HelloWorldQueue"/>  
    </bean>
    <!-- 发送消息的目的地（主题） -->  
    <bean id="TopicDestination" class="org.apache.activemq.command.ActiveMQTopic">  
    	<!-- 设置消息主题的名字 -->  
    	<constructor-arg index="0" value="FlexTopic"/>  
    </bean>   

 

问题三：如何使用JmsTemplate发送消息呢?

spring的beanfactory得到一个jmsTemplate的实例和消息目标的实例，发送消息，够简单的吧。看看代码：

JmsTemplate template = (JmsTemplate) SpringContext.getBean("JmsTemplate");
			ActiveMQTopic destination=(ActiveMQTopic)SpringContext.getBean("TopicDestination");
			template.send((javax.jms.Destination) destination, new MessageCreator(){
				public Message createMessage(Session session) throws JMSException {
					return session.createTextMessage("hello");
				}
				
			});

 问题四：上面的代码能不能在简单些？

很多时候，发送消息的目标都是默认的，因此是不是可以在jmsTemplate中设置一个默认的消息目标呢？答案是肯定的。

 <!-- 配置JMS模版 -->  
    <bean id="JmsTemplate" class="org.springframework.jms.core.JmsTemplate">  
    	<property name="connectionFactory" ref="JmsConnectionFactory"/>
    	<property name="defaultDestination" ref="TopicDestination"></property>
    </bean> 

 

发送消息的时候，不指定目标，spring就会调用默认的目标了。

JmsTemplate template = (JmsTemplate) SpringContext.getBean("JmsTemplate");
			template.send( new MessageCreator(){
				public Message createMessage(Session session) throws JMSException {
					return session.createTextMessage("hello");
				}
			});

 

问题四：jmsTemplate怎么接受信息？

 

jmsTemplate接收消息十分的简单，只需要调用template.receive()方法，receive方法是同步的，默认情况下，对receive()方法的调用会造成阻塞，知道消息到达目标----如果必要，永远等下去。为了避免对消息内容等待，可以配置jmsTemplate时，通过设置receiveTimeout属性来指定接收消息超时时间。下面的配置将接收消息的超时时间设置为一分钟（60000毫秒）。

 <!-- 配置JMS模版 -->  
    <bean id="JmsTemplate" class="org.springframework.jms.core.JmsTemplate">  
    	<property name="connectionFactory" ref="JmsConnectionFactory"/>
    	<property name="defaultDestination" ref="TopicDestination"></property>
    	<property name="receiveTimeout" value="60000"></property>
    </bean>  

 

 template.receive()会从默认目标接收消息，如果你希望指定一个目标，可以传一个目标。如：template.receive("myQueue").

同步接收消息并不是spring唯一的选择，消息监听器可以实现异步（下篇文章将会介绍消息驱动）。

 

问题五：怎么自动将消息转化为Java对象？

 

转化器在很多组件中都是必不缺少的东西。Spring挺过MessageConverter接口提供了对消息转换的支持。

public class MyMessageConverter implements MessageConverter {
	@Override
	public Object fromMessage(Message arg0) throws JMSException,
			MessageConversionException {
		// TODO Auto-generated method stub
		return null;
	}
	@Override
	public Message toMessage(Object arg0, Session arg1) throws JMSException,
			MessageConversionException {
		// TODO Auto-generated method stub
		return null;
	}
}

 

MessageConverter接口的两个方法简单明了。在发送端toMessage会将java对象转化为消息，在接收端fromMessage会将消息转化为java对象。

下面的代码简单的实现了MessageConverter的两个接口。

public class MyMessageConverter implements MessageConverter {
	@Override
	public Object fromMessage(Message message) throws JMSException,
			MessageConversionException {
		if(!(message instanceof MapMessage)){
			throw new MessageConversionException("Messae is not MapMessage");
		}
		MapMessage mapMessage=(MapMessage)message;
		MessageObj messageObj=new MessageObj();
		messageObj.setId(mapMessage.getString("id"));
		messageObj.setInfo(mapMessage.getString("info"));
		return messageObj;
	}
	@Override
	public Message toMessage(Object obj, Session session) throws JMSException,
			MessageConversionException {
		if(!(obj instanceof MessageObj)){
			throw new MessageConversionException("obj is not MessageObj");
		}
		MessageObj messageObj=(MessageObj)obj;
		MapMessage mapMessage=session.createMapMessage();
		mapMessage.setString("id", messageObj.getId());
		mapMessage.setString("info", messageObj.getInfo());
		return mapMessage;
	}
}

 

此时，发送和接收消息要换成template.convertAndSend(message);template.receiveAndConvert();

可是jmsTemplate如何知道消息转换器呢？需要在配置jmsTemplate的时候，加上messageConverter属性。

 <!-- 配置JMS模版 -->  
    <bean id="JmsTemplate" class="org.springframework.jms.core.JmsTemplate">  
    	<property name="connectionFactory" ref="JmsConnectionFactory"/>
    	<property name="defaultDestination" ref="TopicDestination"></property>
    	<property name="receiveTimeout" value="60000"></property>
    	<property name="messageConverter" ref="messageObj"></property>
    </bean>  

 messageObj是要转化的java对象的bean的id。

评论

1 楼 zhengyong7232 2013-07-02  

请问搞过mq的ssl 单向连接吗？我按官网的配置，配好后，客户端测试程序不信任我的连接，必须让我导入证书，可是导入证书的话，就是双向的了。 。。