JMS Apache ActiveMQ使用(2)
2013-09-27 15:41
441 查看
下面就进行程序开发,没得说,当然是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,在连接错误时把消息放入缓存队列中,连接成功后再发送。
使用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,在连接错误时把消息放入缓存队列中,连接成功后再发送。
相关文章推荐
- 使用apache的activemq集合JMS处理异步消息
- JMS Apache ActiveMQ使用(1)
- JMS Apache ActiveMQ使用(1)
- JMS Apache ActiveMQ使用(3)
- JMS Apache ActiveMQ(消息中间件)使用攻略
- Apache apusic---ActiveMQ中间件在JMS1.1、J2EE中的使用
- Java ActiveMQ 理解JMS 和 ActiveMQ基本使用(一)
- ActiveMQ使用spring JmsTemplate发送消息(一)
- 【Java消息中间件】Java消息中间件( 第4章 使用activemq - spring jms演示 )
- 使用Apache ActiveMQ
- ActiveMQ使用spring JmsTemplate发送消息(一)
- JMS_使用ActiveMQ实现消息的发送和接收
- 使用activeMQ实现jms
- Apache ActiveMQ消息中间件的基本使用
- JMS之ActiveMQ(含与Spring集成使用)
- Java ActiveMQ 讲解(一)理解JMS 和 ActiveMQ基本使用
- JMS - ActiveMQ的简单使用
- ActiveMQ使用spring JmsTemplate发送消息(一)
- 遇见JMS[1] —— activeMQ的简单使用
- Spring JMS 和 ActiveMQ 基本使用(二)