1. 集成环境
Spring采用2.5.6版本,ActiveMQ使用的是5.4.2,从apache站点可以下载。本文是将Spring集成ActiveMQ来发送和接收JMS消息。
2. 集成步骤
将下载的ActiveMQ解压缩后文件夹如下
activemq-all-5.4.2.jar是activemq的所有的类jar包。lib下面是模块分解后的jar包。将lib下面的
- /lib/activation-1.1.jar
- /lib/activemq-camel-5.4.2.jar
- /lib/activemq-console-5.4.2.jar
- /lib/activemq-core-5.4.2.jar
- /lib/activemq-jaas-5.4.2.jar
- /lib/activemq-pool-5.4.2.jar
- /lib/activemq-protobuf-1.1.jar
- /lib/activemq-spring-5.4.2.jar
- /lib/activemq-web-5.4.2.jar
- /lib/activation-1.1.jar
- /lib/activemq-camel-5.4.2.jar
- /lib/activemq-console-5.4.2.jar
- /lib/activemq-core-5.4.2.jar
- /lib/activemq-jaas-5.4.2.jar
- /lib/activemq-pool-5.4.2.jar
- /lib/activemq-protobuf-1.1.jar
- /lib/activemq-spring-5.4.2.jar
- /lib/activemq-web-5.4.2.jar
/lib/activation-1.1.jar /lib/activemq-camel-5.4.2.jar /lib/activemq-console-5.4.2.jar /lib/activemq-core-5.4.2.jar /lib/activemq-jaas-5.4.2.jar /lib/activemq-pool-5.4.2.jar /lib/activemq-protobuf-1.1.jar /lib/activemq-spring-5.4.2.jar /lib/activemq-web-5.4.2.jar
文件全部拷贝到项目中。
而Spring项目所需要的jar包如下
- /lib/spring-beans-2.5.6.jar
- /lib/spring-context-2.5.6.jar
- /lib/spring-context-support-2.5.6.jar
- /lib/spring-core-2.5.6.jar
- /lib/spring-jms-2.5.6.jar
- /lib/spring-tx.jar
- /lib/spring-beans-2.5.6.jar
- /lib/spring-context-2.5.6.jar
- /lib/spring-context-support-2.5.6.jar
- /lib/spring-core-2.5.6.jar
- /lib/spring-jms-2.5.6.jar
- /lib/spring-tx.jar
/lib/spring-beans-2.5.6.jar /lib/spring-context-2.5.6.jar /lib/spring-context-support-2.5.6.jar /lib/spring-core-2.5.6.jar /lib/spring-jms-2.5.6.jar /lib/spring-tx.jar
当然还需要一些其他的jar文件
- /lib/geronimo-j2ee-management_1.1_spec-1.0.1.jar
- /lib/jms-1.1.jar
- /lib/log4j-1.2.15.jar
- /lib/slf4j-api-1.6.1.jar
- /lib/slf4j-nop-1.6.1.jar
- /lib/geronimo-j2ee-management_1.1_spec-1.0.1.jar
- /lib/jms-1.1.jar
- /lib/log4j-1.2.15.jar
- /lib/slf4j-api-1.6.1.jar
- /lib/slf4j-nop-1.6.1.jar
/lib/geronimo-j2ee-management_1.1_spec-1.0.1.jar /lib/jms-1.1.jar /lib/log4j-1.2.15.jar /lib/slf4j-api-1.6.1.jar /lib/slf4j-nop-1.6.1.jar
项目的依赖jar都准备好后就可以写配置文件了。
Spring配置文件
配置文件内容如下
- <?xml version="1.0" encoding="UTF-8"?>
- <beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="http://www.springframework.org/schema/beans
- http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
- http://www.springframework.org/schema/context
- http://www.springframework.org/schema/context/spring-context-2.5.xsd"
- default-autowire="byName">
- <!-- 配置connectionFactory -->
- <bean id="jmsFactory" class="org.apache.activemq.pool.PooledConnectionFactory"
- destroy-method="stop">
- <property name="connectionFactory">
- <bean class="org.apache.activemq.ActiveMQConnectionFactory">
- <property name="brokerURL">
- <value>tcp://127.0.0.1:61616</value>
- </property>
- </bean>
- </property>
- <property name="maxConnections" value="100"></property>
- </bean>
- <!-- Spring JMS Template -->
- <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
- <property name="connectionFactory">
- <ref local="jmsFactory" />
- </property>
- <property name="defaultDestinationName" value="subject" />
- <!-- 区别它采用的模式为false是p2p为true是订阅 -->
- <property name="pubSubDomain" value="true" />
- </bean>
- <!-- 发送消息的目的地(一个队列) -->
- <bean id="destination" class="org.apache.activemq.command.ActiveMQTopic">
- <!-- 设置消息队列的名字 -->
- <constructor-arg index="0" value="subject" />
- </bean>
- <!-- 消息监听 -->
- <bean id="listenerContainer"
- class="org.springframework.jms.listener.DefaultMessageListenerContainer">
- <property name="concurrentConsumers" value="10" />
- <property name="connectionFactory" ref="jmsFactory" />
- <property name="destinationName" value="subject" />
- <property name="messageListener" ref="messageReceiver" />
- <property name="pubSubNoLocal" value="false"></property>
- </bean>
- <bean id="messageReceiver"
- class="com.liuyan.jms.consumer.ProxyJMSConsumer">
- <property name="jmsTemplate" ref="jmsTemplate"></property>
- </bean>
- </beans>
- <?xml version="1.0" encoding="UTF-8"?>
- <beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="http://www.springframework.org/schema/beans
- http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
- http://www.springframework.org/schema/context
- http://www.springframework.org/schema/context/spring-context-2.5.xsd"
- default-autowire="byName">
- <!-- 配置connectionFactory -->
- <bean id="jmsFactory" class="org.apache.activemq.pool.PooledConnectionFactory"
- destroy-method="stop">
- <property name="connectionFactory">
- <bean class="org.apache.activemq.ActiveMQConnectionFactory">
- <property name="brokerURL">
- <value>tcp://127.0.0.1:61616</value>
- </property>
- </bean>
- </property>
- <property name="maxConnections" value="100"></property>
- </bean>
- <!-- Spring JMS Template -->
- <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
- <property name="connectionFactory">
- <ref local="jmsFactory" />
- </property>
- <property name="defaultDestinationName" value="subject" />
- <!-- 区别它采用的模式为false是p2p为true是订阅 -->
- <property name="pubSubDomain" value="true" />
- </bean>
- <!-- 发送消息的目的地(一个队列) -->
- <bean id="destination" class="org.apache.activemq.command.ActiveMQTopic">
- <!-- 设置消息队列的名字 -->
- <constructor-arg index="0" value="subject" />
- </bean>
- <!-- 消息监听 -->
- <bean id="listenerContainer"
- class="org.springframework.jms.listener.DefaultMessageListenerContainer">
- <property name="concurrentConsumers" value="10" />
- <property name="connectionFactory" ref="jmsFactory" />
- <property name="destinationName" value="subject" />
- <property name="messageListener" ref="messageReceiver" />
- <property name="pubSubNoLocal" value="false"></property>
- </bean>
- <bean id="messageReceiver"
- class="com.liuyan.jms.consumer.ProxyJMSConsumer">
- <property name="jmsTemplate" ref="jmsTemplate"></property>
- </bean>
- </beans>
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd" default-autowire="byName"> <!-- 配置connectionFactory --> <bean id="jmsFactory" class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop"> <property name="connectionFactory"> <bean class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL"> <value>tcp://127.0.0.1:61616</value> </property> </bean> </property> <property name="maxConnections" value="100"></property> </bean> <!-- Spring JMS Template --> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <property name="connectionFactory"> <ref local="jmsFactory" /> </property> <property name="defaultDestinationName" value="subject" /> <!-- 区别它采用的模式为false是p2p为true是订阅 --> <property name="pubSubDomain" value="true" /> </bean> <!-- 发送消息的目的地(一个队列) --> <bean id="destination" class="org.apache.activemq.command.ActiveMQTopic"> <!-- 设置消息队列的名字 --> <constructor-arg index="0" value="subject" /> </bean> <!-- 消息监听 --> <bean id="listenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="concurrentConsumers" value="10" /> <property name="connectionFactory" ref="jmsFactory" /> <property name="destinationName" value="subject" /> <property name="messageListener" ref="messageReceiver" /> <property name="pubSubNoLocal" value="false"></property> </bean> <bean id="messageReceiver" class="com.liuyan.jms.consumer.ProxyJMSConsumer"> <property name="jmsTemplate" ref="jmsTemplate"></property> </bean> </beans>
编写代码
消息发送者:这里面消息生产者并没有在Spring配置文件中进行配置,这里仅仅使用了Spring中的JMS模板和消息目的而已。
- public class HelloSender {
- /**
- * @param args
- */
- public static void main(String[] args) {
- ApplicationContext applicationContext = new ClassPathXmlApplicationContext(
- new String[] { "classpath:/spring/applicationContext-jms.xml" });
- JmsTemplate template = (JmsTemplate) applicationContext
- .getBean("jmsTemplate");
- Destination destination = (Destination) applicationContext
- .getBean("destination");
- template.send(destination, new MessageCreator() {
- public Message createMessage(Session session) throws JMSException {
- return session
- .createTextMessage("发送消息:Hello ActiveMQ Text Message!");
- }
- });
- System.out.println("成功发送了一条JMS消息");
- }
- }
- public class HelloSender {
- /**
- * @param args
- */
- public static void main(String[] args) {
- ApplicationContext applicationContext = new ClassPathXmlApplicationContext(
- new String[] { "classpath:/spring/applicationContext-jms.xml" });
- JmsTemplate template = (JmsTemplate) applicationContext
- .getBean("jmsTemplate");
- Destination destination = (Destination) applicationContext
- .getBean("destination");
- template.send(destination, new MessageCreator() {
- public Message createMessage(Session session) throws JMSException {
- return session
- .createTextMessage("发送消息:Hello ActiveMQ Text Message!");
- }
- });
- System.out.println("成功发送了一条JMS消息");
- }
- }
public class HelloSender { /** * @param args */ public static void main(String[] args) { ApplicationContext applicationContext = new ClassPathXmlApplicationContext( new String[] { "classpath:/spring/applicationContext-jms.xml" }); JmsTemplate template = (JmsTemplate) applicationContext .getBean("jmsTemplate"); Destination destination = (Destination) applicationContext .getBean("destination"); template.send(destination, new MessageCreator() { public Message createMessage(Session session) throws JMSException { return session .createTextMessage("发送消息:Hello ActiveMQ Text Message!"); } }); System.out.println("成功发送了一条JMS消息"); } }
消息接收
- /**
- * JMS消费者
- *
- *
- * <p>
- * 消息题的内容定义
- * <p>
- * 消息对象 接收消息对象后: 接收到的消息体* <p>
- */
- public class ProxyJMSConsumer {
- public ProxyJMSConsumer() {
- }
- private JmsTemplate jmsTemplate;
- public JmsTemplate getJmsTemplate() {
- return jmsTemplate;
- }
- public void setJmsTemplate(JmsTemplate jmsTemplate) {
- this.jmsTemplate = jmsTemplate;
- }
- /**
- * 监听到消息目的有消息后自动调用onMessage(Message message)方法
- */
- public void recive() {
- ApplicationContext applicationContext = new ClassPathXmlApplicationContext(
- new String[] { "classpath:/spring/applicationContext-jms.xml" });
- Destination destination = (Destination) applicationContext
- .getBean("destination");
- while (true) {
- try {
- TextMessage txtmsg = (TextMessage) jmsTemplate
- .receive(destination);
- if (null != txtmsg) {
- System.out.println("[DB Proxy] " + txtmsg);
- System.out.println("[DB Proxy] 收到消息内容为: "
- + txtmsg.getText());
- } else
- break;
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- }
- }
- /**
- * JMS消费者
- *
- *
- * <p>
- * 消息题的内容定义
- * <p>
- * 消息对象 接收消息对象后: 接收到的消息体* <p>
- */
- public class ProxyJMSConsumer {
- public ProxyJMSConsumer() {
- }
- private JmsTemplate jmsTemplate;
- public JmsTemplate getJmsTemplate() {
- return jmsTemplate;
- }
- public void setJmsTemplate(JmsTemplate jmsTemplate) {
- this.jmsTemplate = jmsTemplate;
- }
- /**
- * 监听到消息目的有消息后自动调用onMessage(Message message)方法
- */
- public void recive() {
- ApplicationContext applicationContext = new ClassPathXmlApplicationContext(
- new String[] { "classpath:/spring/applicationContext-jms.xml" });
- Destination destination = (Destination) applicationContext
- .getBean("destination");
- while (true) {
- try {
- TextMessage txtmsg = (TextMessage) jmsTemplate
- .receive(destination);
- if (null != txtmsg) {
- System.out.println("[DB Proxy] " + txtmsg);
- System.out.println("[DB Proxy] 收到消息内容为: "
- + txtmsg.getText());
- } else
- break;
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- }
- }
/** * JMS消费者 * * * <p> * 消息题的内容定义 * <p> * 消息对象 接收消息对象后: 接收到的消息体* <p> */ public class ProxyJMSConsumer { public ProxyJMSConsumer() { } private JmsTemplate jmsTemplate; public JmsTemplate getJmsTemplate() { return jmsTemplate; } public void setJmsTemplate(JmsTemplate jmsTemplate) { this.jmsTemplate = jmsTemplate; } /** * 监听到消息目的有消息后自动调用onMessage(Message message)方法 */ public void recive() { ApplicationContext applicationContext = new ClassPathXmlApplicationContext( new String[] { "classpath:/spring/applicationContext-jms.xml" }); Destination destination = (Destination) applicationContext .getBean("destination"); while (true) { try { TextMessage txtmsg = (TextMessage) jmsTemplate .receive(destination); if (null != txtmsg) { System.out.println("[DB Proxy] " + txtmsg); System.out.println("[DB Proxy] 收到消息内容为: " + txtmsg.getText()); } else break; } catch (Exception e) { e.printStackTrace(); } } } }
这里边也是并不是直接使用Spring来初始化建立消息消费者实例,而是在此消费者注入了JMS模板而已。
写一个main入口,初始化消息消费者
- public class JMSTest {
- /**
- * @param args
- */
- public static void main(String[] args) {
- ApplicationContext applicationContext = new ClassPathXmlApplicationContext(
- new String[] { "classpath:/spring/applicationContext-jms.xml" });
- ProxyJMSConsumer proxyJMSConsumer = (ProxyJMSConsumer) applicationContext
- .getBean("messageReceiver");
- System.out.println("初始化消息消费者");
- }
- }
- public class JMSTest {
- /**
- * @param args
- */
- public static void main(String[] args) {
- ApplicationContext applicationContext = new ClassPathXmlApplicationContext(
- new String[] { "classpath:/spring/applicationContext-jms.xml" });
- ProxyJMSConsumer proxyJMSConsumer = (ProxyJMSConsumer) applicationContext
- .getBean("messageReceiver");
- System.out.println("初始化消息消费者");
- }
- }
public class JMSTest { /** * @param args */ public static void main(String[] args) { ApplicationContext applicationContext = new ClassPathXmlApplicationContext( new String[] { "classpath:/spring/applicationContext-jms.xml" }); ProxyJMSConsumer proxyJMSConsumer = (ProxyJMSConsumer) applicationContext .getBean("messageReceiver"); System.out.println("初始化消息消费者"); } }
使用的时候先开启ActiveMQ服务,默认是占用了61616端口。之后开启测试程序,开启2个消息消费者监听。之后再运行消息生产者的代码后,消息就可以被消息消费者接收到了。
相关推荐
Spring 集成 ActiveMQ 配置 Spring 集成 ActiveMQ 配置是指将 Spring 框架与 ActiveMQ 消息队列集成,以实现基于 JMS(Java Message Service)的消息传递。ActiveMQ 是 Apache 软件基金会的一个开源的消息队列系统...
在Spring框架中集成ActiveMQ,我们可以创建一个高效的、可扩展的系统,利用消息队列来解耦生产者和消费者,提高系统的响应速度和可靠性。以下将详细介绍如何进行Spring与ActiveMQ的集成,并提供一些关键知识点。 1....
- 结合Spring Boot的自动配置能力,可以极大地简化ActiveMQ的集成过程,只需少量配置就能快速启动和运行。 7. **监控和管理**: - ActiveMQ提供了Web控制台,可以通过浏览器进行监控和管理,查看队列状态、消息...
当我们需要在Spring应用中集成ActiveMQ时,就需要进行相应的配置。本文将深入讲解ActiveMQ与Spring的整合配置方案。 首先,我们需要在项目中引入ActiveMQ的相关依赖。这通常通过在`pom.xml`文件中添加Maven依赖来...
以上就是Spring集成ActiveMQ的基本流程,涉及Queue和Topic的创建、持久化到MySQL以及消息的发送与接收。这个测试Demo涵盖了消息中间件的核心功能,可以帮助你理解并实践消息传递系统在实际项目中的应用。
在Spring框架中,我们可以通过使用Spring的JMS模块来配置ActiveMQ。这个过程涉及到以下几个关键点: 1. **JMS配置**:在Spring的配置文件中,我们需要定义一个`ConnectionFactory`,它是与消息代理(如ActiveMQ)...
spring集成activeMQ框架 配置方式(内含三种常见的消息接受监听方式的配置)JMS 配置测试等等
Spring提供了`spring-jms`模块,它包含了一组丰富的API和配置选项,使得在Spring应用中集成ActiveMQ变得简单。通过使用`JmsTemplate`类,我们可以方便地发送和接收消息。 1. **配置ActiveMQ**:在开始之前,我们...
在Spring集成ActiveMQ时,通常会采用Spring的配置文件形式来配置消息工厂(ConnectionFactory)、消息队列目的地(Destination)、消息监听容器(MessageListenerContainer)等。这样的配置方式可以让Spring管理...
本篇将深入讲解如何在Spring环境中配置和使用ActiveMQ。 首先,我们需要了解Spring与ActiveMQ集成的基本概念。Spring框架提供了一套完整的JMS(Java Message Service)支持,可以方便地与各种消息队列进行整合,...
本篇将深入探讨Spring与ActiveMQ的集成及其配置过程。 首先,理解Spring与ActiveMQ集成的基本概念至关重要。Spring的`Spring Integration`模块提供了与多种消息中间件集成的API,其中包括ActiveMQ。通过这些API,...
Spring作为Java领域的主流框架,与ActiveMQ的集成使得这种消息中间件的使用更加便捷。本文将详细探讨Spring与ActiveMQ的整合过程,以及相关的知识点。 1. **Spring框架**:Spring是Java开发中的一个全功能框架,...
在Spring Boot中集成ActiveMQ,我们可以利用Spring的`@EnableJms`注解来启用JMS支持,并通过配置ActiveMQ服务器的URL、用户名和密码等信息,实现消息的发送和接收。这将极大地提升系统的异步处理能力和可扩展性。 ...
在Spring Boot中集成ActiveMQ非常简便,因为Spring Boot提供了`spring-boot-starter-activemq`启动器,该启动器包含了自动配置的支持。首先,我们需要在项目中添加相应的依赖: ```xml <groupId>org.spring...
接下来,**Spring与ActiveMQ的集成**:在Spring应用中配置ActiveMQ,通常需要在Spring配置文件中定义`JmsTemplate`和`DefaultMessageListenerContainer`。`JmsTemplate`用于发送消息,而`...
- ` applicationContext.xml`:Spring的配置文件,配置ActiveMQ的相关组件。 - `MessageProducer`:生产消息的类,通常会使用JMS Template发送消息到队列或主题。 - `MessageConsumer`:消费消息的类,通过实现...