`
coach
  • 浏览: 386664 次
  • 性别: Icon_minigender_2
  • 来自: 印度
社区版块
存档分类
最新评论

通过spring开发ActiveMQ简单应用

阅读更多
使用spring的支持类开发JMS程序可以简化代码,确保开发质量。以下是使用ActiveMQ作为JMS实现的示例。

首先需要确保如下类库,这里使用maven的pom:

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-jms</artifactId>
    <version>2.5.6</version>
</dependency>
<dependency>
    <groupId>org.apache.xbean</groupId>
    <artifactId>xbean-spring</artifactId>
    <version>3.5</version>
</dependency>
<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-core</artifactId>
    <version>5.2.0</version>
</dependency>


编写消息生产者的代码:

@Component
public class MyMessageProducer {
    @Resource(name = "Queue")
    private Destination destination;

    @Autowired
    private JmsTemplate jmsTemplate;

    public void sendMessage(final String message) {
        this.jmsTemplate.send(this.destination, new MessageCreator() {
            @Override
            public Message createMessage(Session session) throws JMSException {
                TextMessage textMessage = session.createTextMessage();
                textMessage.setText(message);
                return textMessage;
            }
        });
    }
}

有关生产者部分spring的配置文件内容:

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:amq="http://activemq.apache.org/schema/core" xmlns:lang="http://www.springframework.org/schema/lang"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx" xmlns:util="http://www.springframework.org/schema/util"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
     http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd
     http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-2.5.xsd
     http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd
     http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd
     http://www.springframework.org/schema/lang http://www.springframework.org/schema/lang/spring-lang-2.5.xsd
     http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">

    <context:annotation-config />
    <context:component-scan base-package="activemq.demo.spring" />

    <bean id="jmsFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL">
            <value>tcp://localhost:61616</value>
        </property>
    </bean>

    <bean id="myJmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="jmsFactory" />
    </bean>
    <amq:queue name="Queue" physicalName="example.D" />

这样,执行发送代码,在activemq的admin界面中可以观察到发送成功的消息。

异步接收的代码:

public class MyMessageConsumer implements MessageListener {

    @Override
    public void onMessage(Message message) {
        TextMessage textMessage = (TextMessage) message;
        try {
            System.out.println(">>>>>>>"+textMessage.getText());
//            throw new RuntimeException(">>>>>>>>>>test error");
        } catch (JMSException e) {
            throw new RuntimeException(e);
        }
    }

}

有关异步接收代码的spring配置:

     <bean id="myMessageConsumer" class="activemq.demo.spring.MyMessageConsumer" />
    <bean id="jmsContainer"
        class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="jmsFactory" />
        <property name="destination" ref="Queue" />
        <property name="messageListener" ref="myMessageConsumer" />
        <property name="sessionTransacted" value="true"/>
    </bean>


这样,就实现了基于spring和activemq的JMS的同步发送和异步提交。如果将MyMessageConsumer的抛出异常部分取消注释,则接收信息后,spring捕获到该异常并自动回滚事务。通过activemq的admin界面会监控到消息依然留在队列中。
分享到:
评论

相关推荐

    Spring和ActiveMQ整合的完整实例

    在IT行业中,Spring框架是Java应用开发中的一个关键组件,它提供了一个全面的编程和配置模型,用于构建灵活、可维护的应用程序。而ActiveMQ则是Apache软件基金会的一个开源项目,它是Java消息服务(JMS)的实现,...

    Spring整合ActiveMQ简单实例

    通过以上步骤,我们就成功地将 Spring 与 ActiveMQ 整合起来,实现了简单的消息发送和接收功能。在实际应用中,还可以根据需求进行更复杂的配置,如事务支持、消息确认机制、持久化等,以满足不同场景下的业务需求。

    spring使用activeMQ实现消息发送

    在IT行业中,Spring框架是Java应用开发的基石,而ActiveMQ则是Apache组织开发的一款开源的消息中间件,用于处理异步通信和消息队列。本文将深入探讨如何在Spring环境中使用ActiveMQ来实现消息的发送与接收,以提高...

    spring整合Activemq源码

    - **使用JmsTemplate**:Spring提供的JmsTemplate类是发送和接收消息的便捷工具,可以通过它来发送简单或预定义的消息,同时处理消息的监听和回调。 - **消息生产者**:在SpringMVC的控制器中,我们可以创建一个...

    Spring集成ActiveMQ配置

    6. **Missian ActiveMQ-JMS简单实例**:这可能是一个具体的项目实例,它展示了如何在Spring应用中使用ActiveMQ实现异步RPC(远程过程调用)。在这种模式下,一个服务通过消息将请求发送到队列,另一端的服务监听队列...

    spring+activemq

    而ActiveMQ则是Apache软件基金会开发的一个开源消息代理,它实现了Java消息服务(JMS)规范,用于处理应用程序之间的异步通信。 标题“spring+activemq”暗示了我们将探讨如何将Spring框架与ActiveMQ集成,以便利用...

    spring整合activemq的maven工程

    通过以上步骤,我们就成功地整合了Spring、ActiveMQ和Maven,构建了一个能够发送和接收消息的简单示例。在实际项目中,可能还需要考虑更多因素,比如错误处理、负载均衡、消息持久化等,但这些基础知识已经为你开启...

    Spring和ActiveMQ的整合实例源码

    在IT行业中,Spring框架是Java应用开发的基石,它提供了丰富的功能来简化应用程序的构建,包括依赖注入、AOP(面向切面编程)以及各种模块如数据访问、Web支持等。而ActiveMQ则是Apache软件基金会的一个开源项目,是...

    spring配置activemq详解

    在IT行业中,Spring框架是Java应用开发中的基石,它提供了丰富的功能来简化应用程序的构建。而ActiveMQ则是Apache出品的一款开源消息中间件,遵循JMS(Java Message Service)规范,用于处理应用程序之间的异步通信...

    jms Spring+ActiveMQ 5.4.2

    标题 "jms Spring+ActiveMQ 5.4.2" 涉及的是Java消息服务(JMS)在Spring框架中的应用,以及ActiveMQ作为消息代理的使用。在这个主题下,我们将深入探讨JMS的基本概念、Spring对JMS的支持以及ActiveMQ 5.4.2版本的...

    spring 与ACTIVEMQ整合

    在IT行业中,Spring框架是Java领域最常用的轻量级应用框架之一,而ActiveMQ则是Apache组织开发的一款开源消息中间件,常用于实现应用程序间的异步通信。本文将深入探讨如何将Spring与ActiveMQ进行整合,以提升系统的...

    spring2 activemq5 tomcat6构建jms

    标题“spring2 activemq5 tomcat6构建jms”涉及了几个关键的Java技术,主要集中在企业级应用开发中的消息传递系统。首先,我们来深入理解这些技术及其相互关系。 Spring框架是Java应用程序开发的一个核心工具,尤其...

    Spring-ActiveMQ-jar

    Spring框架是Java开发中的一个流行选择,它提供了一个全面的应用程序开发模型,简化了企业级Java应用程序的构建。Spring通过其`spring-jms`模块提供了对Java消息服务(JMS)的支持,包括ActiveMQ。这允许开发者使用...

    Spring与ActiveMQ整合完整案例

    在IT行业中,Spring框架是Java领域最常用的轻量级应用框架之一,而ActiveMQ则是Apache组织提供的一个开源消息中间件,常用于实现应用程序之间的异步通信。本案例将详细讲解如何将Spring与ActiveMQ整合,以提升系统的...

    Spring整合activemq

    在IT行业中,Spring框架是Java应用开发的基石,它提供了丰富的功能来简化应用程序的构建,包括依赖注入、AOP(面向切面编程)以及多种模块,如数据访问、Web服务等。而Apache ActiveMQ则是非常流行的开源消息中间件...

    spring + activemq 消息sample

    首先,**Spring框架** 是一个广泛使用的Java企业级应用开发框架,它提供了依赖注入(Dependency Injection, DI)和面向切面编程(Aspect-Oriented Programming, AOP)等核心特性,简化了复杂的应用程序设计。通过...

    Spring+ActiveMQ的整合

    Spring框架作为Java领域最流行的开发框架之一,提供了强大的依赖注入和面向切面编程功能,而ActiveMQ则是Apache软件基金会的一个开源消息中间件,实现了Java Message Service (JMS) 规范,用于在应用程序之间高效、...

    Spring+ActiveMQ整合实例代码工程

    在Java开发中,Spring框架是极为重要的应用基础,而ActiveMQ作为Apache出品的一款开源消息中间件,常被用于实现应用间的异步通信和解耦。本实例代码工程"Spring+ActiveMQ整合实例代码工程"正是结合两者,展示了如何...

    Spring+ActiveMQ实现,基于Maven

    在企业级应用开发中,Spring框架与ActiveMQ的结合使用是一种常见的消息中间件解决方案,用于实现应用程序间的异步通信和解耦。本项目基于Maven构建,提供了对Topic的实现,同时也支持轻松切换到Queue模式。 **...

    Spring与ActiveMQ完整实例源码下载 Maven 版.zip

    在Java开发领域,Spring框架和ActiveMQ是两个非常重要的组件。Spring作为一款强大的企业级应用框架,提供了一系列的工具和服务,方便开发者构建复杂的应用系统;而ActiveMQ则是Apache软件基金会的一个开源项目,它是...

Global site tag (gtag.js) - Google Analytics