applicationContext.xml
- <!--创建连接工厂 -->
- <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
- <property name="brokerURL" value="tcp://localhost:61616"></property>
- </bean>
- <!-- 声明ActiveMQ消息目标,目标可以是一个队列,也可以是一个主题ActiveMQTopic -->
- <bean id="destinationOne" class="org.apache.activemq.command.ActiveMQQueue">
- <constructor-arg index="0" value="testQueOne"></constructor-arg>
- </bean>
- <!-- 设置 消息目的地 start -->
- <bean id="jmsTemplateOne" class="org.springframework.jms.core.JmsTemplate">
- <property name="connectionFactory" ref="connectionFactory"></property>
- <property name="defaultDestination" ref="destinationOne"></property>
- <property name="receiveTimeout" value="6000"></property>
- </bean>
- <!-- 设置 消息目的地 end -->
- <!-- 配置生产者 start -->
- <bean id="senderOne" class="com.dly.avtivemqtest.SenderOne">
- <property name="jmsTemplateOne" ref="jmsTemplateOne"></property>
- </bean>
- <!-- 配置生产者 end -->
- <!-- 配置消费者 start -->
- <bean id="receiverOne" class="com.dly.avtivemqtest.ReceiverOne">
- <!-- <property name="jmsTemplate" ref="jmsTemplate"></property> -->
- </bean>
- <!-- 配置消费者 end -->
- <!-- 消息监听器 -->
- <bean id="consumerMessageListenerOfOne" class="com.dly.avtivemqtest.ReceiverOne" />
- <!-- 消息监听容器 消息接收监听器用于异步接收消息 -->
- <bean id="jmsContainerOne" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
- <property name="connectionFactory" ref="connectionFactory" />
- <property name="destination" ref="destinationOne" />
- <property name="messageListener" ref="consumerMessageListenerOfOne" />
- </bean>
- lt;/beans>
SenderOne.java
- public class SenderOne {
- private JmsTemplate jmsTemplateOne;
- public JmsTemplate getJmsTemplateOne() {
- return jmsTemplateOne;
- }
- public void setJmsTemplateOne(JmsTemplate jmsTemplateOne) {
- this.jmsTemplateOne = jmsTemplateOne;
- }
- //测试的
- public void sendInfo(final String messageRecord,final String flag) {
- jmsTemplateOne.send(new MessageCreator() {
- public Message createMessage(Session session) throws JMSException {
- TextMessage message = session.createTextMessage();
- return message;
- }
- });
- }
- }
ReceiverOne.java
- public class ReceiverOne implements MessageListener {
- //测试方法
- public void onMessage(Message message, Session session) {
- //这里我们知道生产者发送的就是一个纯文本消息,所以这里可以直接进行强制转换
- TextMessage textMsg = (TextMessage) message;
- try {
- String endStr = textMsg.getText();
- Integer endInt = Integer.parseInt(endStr);
- System.out.println("消息:==="+endInt);
- } catch (Exception e) {
- e.printStackTrace();
- System.out.println("异常信息是:===:" + e.getMessage());
- }
- }
- }
JMSTest.java
- public class JMSTest {
- public static void main(String[] args) {
- ApplicationContext context = new ClassPathXmlApplicationContext("resources/applicationContext.xml");
- SenderOne sender = (SenderOne) context.getBean("senderOne");
- sender.sendInfo("10","2");
- }
- }
相关推荐
而Spring框架,作为一个Java平台的全功能模块化解决方案,提供了与ActiveMQ集成的能力,让开发者能够轻松地在Spring应用中使用消息队列。本篇将深入探讨Spring与ActiveMQ的集成及其配置过程。 首先,理解Spring与...
消息队列:ActiveMQ:ActiveMQ的Spring集成.docx
3. **Spring配置**:集成ActiveMQ到Spring MVC需要在Spring的配置文件(如`applicationContext.xml`)中声明一个`ConnectionFactory`和`Destination`。`ConnectionFactory`用于创建连接到消息队列的连接,`...
标题中的“ActiveMQ与Spring集成实例之使用Maven构建”是指在Java开发环境中,通过Maven构建工具将Apache ActiveMQ消息中间件与Spring框架整合在一起的实际操作案例。这个主题涵盖了几大关键知识点: 1. **Apache ...
总的来说,集成ActiveMQ和Spring可以简化消息传递的复杂性,提高应用程序的可扩展性和解耦性。通过XML配置,我们可以灵活地管理消息生产和消费,实现异步通信,提高系统的响应速度和并发处理能力。在实际项目中,...
ActiveMQ和Spring的集成是企业级Java应用中常见的消息中间件解决方案,用于实现解耦、异步处理和系统间的通信。在本示例中,我们将深入探讨如何将这两个组件结合在一起,以创建一个高效且可扩展的应用架构。 首先,...
在Spring框架中集成ActiveMQ,我们可以创建一个高效的、可扩展的系统,利用消息队列来解耦生产者和消费者,提高系统的响应速度和可靠性。以下将详细介绍如何进行Spring与ActiveMQ的集成,并提供一些关键知识点。 1....
本文将深入探讨ActiveMQ 5.5.1版本与Spring框架的集成,以及如何利用Spring的模板模式简化ActiveMQ的使用。 一、ActiveMQ基础介绍 ActiveMQ是Apache软件基金会下的一个项目,遵循JMS(Java消息服务)规范,支持多种...
**ActiveMQ与Spring集成实例详解** ActiveMQ是Apache软件基金会下的一个开源项目,它是一个功能丰富的Java消息服务(JMS)提供商,支持多种协议,并且能够处理大量的并发消息传输。而Spring框架则是一个广泛使用的...
通过以上步骤,你已经成功地将ActiveMQ与Spring集成,并实现了基本的消息收发功能。在实际项目中,你可能需要根据需求调整配置,例如设置消息的持久化、事务支持、消息优先级等高级特性。此外,ActiveMQ还提供了管理...
《ActiveMQ与Spring整合实战教程》 在Java企业级应用中,消息中间件扮演着至关重要的角色,它能够实现应用间的解耦,提高系统的可扩展性和可靠性。ActiveMQ作为Apache基金会的一个开源项目,是Java消息服务(JMS)...
**ActiveMQ与Spring集成实例——使用消息转换器** 在企业级应用开发中,消息队列(Message Queue,MQ)作为一种解耦和异步处理的重要工具,被广泛应用。Apache ActiveMQ 是一个开源的消息中间件,它支持多种消息...
Spring 集成 ActiveMQ 配置 Spring 集成 ActiveMQ 配置是指将 Spring 框架与 ActiveMQ 消息队列集成,以实现基于 JMS(Java Message Service)的消息传递。ActiveMQ 是 Apache 软件基金会的一个开源的消息队列系统...
**ActiveMQ与Spring整合详解** ...通过这个项目,你可以了解到如何在Spring应用中集成并使用ActiveMQ,以及如何设计消息的生产和消费流程。理解并熟练运用这些知识,对于构建高可用、高性能的企业级应用至关重要。
标题 "activemq spring" 指涉的是Apache ActiveMQ集成到Spring框架中的主题,这是一个在企业级Java应用中常见的消息中间件集成实践。ActiveMQ是Apache软件基金会开发的一个开源消息代理,它遵循开放消息中间件协议...
当我们需要在Spring应用中集成ActiveMQ时,就需要进行相应的配置。本文将深入讲解ActiveMQ与Spring的整合配置方案。 首先,我们需要在项目中引入ActiveMQ的相关依赖。这通常通过在`pom.xml`文件中添加Maven依赖来...
- 结合Spring Boot的自动配置能力,可以极大地简化ActiveMQ的集成过程,只需少量配置就能快速启动和运行。 7. **监控和管理**: - ActiveMQ提供了Web控制台,可以通过浏览器进行监控和管理,查看队列状态、消息...