下面就进行程序开发,没得说,当然是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,在连接错误时把消息放入缓存队列中,连接成功后再发送。
分享到:
相关推荐
Apache ActiveMQ JMS实现
ApacheCamel-JMS-ActiveMQ Apache Camel JMS ActiveMQ 使用样例 1.从本地读取信息推送到MQ中 2.从MQ中读取信息保存到本地
Apache ActiveMQ教程 JMS 整合Tomcat
详细内容: SpringJMS整合ActiveMQ.doc 详细说明文档 apache-activemq-5.8.0-bin.zip ActiveMQ安装包 JMSTest.rar MyEclipse8.5下web工程
<a href=http://activemq.apache.org/version-5-getting-started.html >http://activemq.apache.org/version-5-getting-started.html</a> <a href=http://java.sun.com/j2ee/1.4/docs/tutorial/doc/index.html>...
同时Apache ActiveMq是速度快,支持多种跨语言客户端和协议,同时配有易于使用的企业集成模式和优秀的特性,并且支持JMS1.1和J2EE1.4。具体特性见官网:http://activemq.apache.org/ 2. 什么是JMS JMS的全称是Java ...
activemq, Apache ActiveMQ镜像 欢迎来到 Apache ActiveMQis是一个高性能的Apache 2.0许可以消息代理和 JMS 1.1实现。正在启动要帮助你入门,请尝试以下链接:入门http://activemq.apache.org/version-
JMS与SPRING的整合实例(基于Apache ActiveMQ) 定义JMS连接工厂 定义JMS Template 定义消息目的地 定义接收监听器 定义一个JMS话题 定义消费者(接收端) 定义发布者 JAVA核心代码一般由三个部分组成: 监听器...
Apache ActiveMQ是Apache软件基金会的一个开源项目,是一个基于消息的通信中间件。ActiveMQ是JMS的一个具体实现,支持JMS的两种消息模型。ActiveMQ使用AMQP协议集成多平台应用,使用STOMP协议通过websockets在Web...
ActiveMQ 是Apache出品,最流行的,能力强劲的开源jms服务器。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的...
type="org.apache.activemq.command.ActiveMQQueue" description="My Message Queue" factory="org.apache.activemq.jndi.JNDIReferenceFactory" physicalName="MyMessageQueue"/> 说明:...
Apache ActiveMQ是Apache软件基金会所研发的开放源代码消息中间件;由于ActiveMQ是一个纯Java程序,因此只需要操作系统支持Java虚拟机,ActiveMQ便可执行。
SUN JMS 教程 APACHE ACTIVEMQ 教程
ActiveMQ是Apache下的开源项目,完全支持JMS1.1和J2EE1.4规范的JMS Provider实现。 特点: 1、支持多种语言编写客户端 2、对spring的支持,很容易和spring整合 3、支持多种传输协议:TCP,SSL,NIO,UDP等 4、支持...
使用者/订户,它是充当接收者的客户端应用程序或JMS客户端。 消息,即消息或数据。 队列,这是客户端接收到的消息被排队并一个接一个地发送。 主题,即客户端接收到的消息被分发到每个连接的客户端。 Java消
ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的...
最全的基于spring mvc的JMS+activeMQ实现的消息中间件代码例子,源程序和apache-activemq-5.10.0-bin.zip
在Spring中安装ActiveMQ www.activemq.org apache-activemq-4.1.0-incubator.zip ,incubator.jar复制到lib中 启动ActiveMQ的脚本:运行刚下载的文件/bin/activemq.bat. 这样就可以使用ActiveMQ进行中介服务了。