问题一:为什么要整合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。
分享到:
相关推荐
Spring和ActiveMQ整合的完整实例
详细内容: SpringJMS整合ActiveMQ.doc 详细说明文档 apache-activemq-5.8.0-bin.zip ActiveMQ安装包 JMSTest.rar MyEclipse8.5下web工程
Spring集成ActiveMQ配置
spring集成ActiveMQ的配置过程
JMS_MQ系统之Spring中嵌入ActiveMQ,JMS_MQ系统之Spring中嵌入ActiveMQ
spring整合使用activemq,代码主要是介绍如何使用spring整合使用activemq,可以直接拿过去使用
源码为web工程,整合了Spring,SpringMVC、ActiveMQ,启动后,index页面输入消息,控制台输出消息。
spring boot 集成activemq Datajpa Ehcache 里面有详细的例子
spring整合activemq的maven工程 activemq+spring+maven project
spring3.0整合了activemQ和jms可以发送信息和接收消息
Spring+ActiveMQ active基本例子 注解的完整实例,包含jar包
Spring boot 和内置ActiveMQ集成例子,通过代码学习Spring boot 和内置ActiveMQ集成。
结合博客提供spring+activeMQ的demo源码
此实例基于Spring+JMS+ActiveMQ+Tomcat,注解的完整实例,包含jar包
本章我将通过spring jms和activemq实现单Web项目服务器间异步访问和多Web项目服务器间异步访问。 一. 简介 1. 什么是Apache ActiveMq Apache ActiveMq是最流行和最强大的开源消息和集成服务器。同时Apache ActiveMq...
spring boot activemq集成示例,包含queue和topic消息的发送、接收,连接池的支持。
activemq服务器使用的zookeeper replicable 的方式进行负载均衡以及容灾,客户端使用spring进行配置
Spring Boot 做的一个简单的增删改查,前台页面整合Thymeleaf模板,数据源druid,声明式事务,整合redis,并开启redis事务,整合ActiveMQ
activemq消息队列 maven项目 包括普通版jmstest 和spring版jmsspring