`
sunbin
  • 浏览: 352423 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类
最新评论

转:spring boot + ActiveMQ 实现消息服务

 
阅读更多

首先,我在github上找到了一个不错的demo,这里放给大家一起看下:

https://github.com/spring-projects/spring-boot/tree/master/spring-boot-samples/spring-boot-sample-activemq

 

确实可以实现功能,但是当我在8161默认的admin端口进行queue查询时,发现并没有我们的github-queue,虽然不太清楚具体的原因,但是解决方式倒是找到了,下面贴一下自己的实现:

pox.xml:

Java代码  收藏代码
  1. <!-- ActiveMQ -->  
  2.         <dependency>  
  3.             <groupId>org.springframework</groupId>  
  4.             <artifactId>spring-jms</artifactId>  
  5.         </dependency>  
  6.         <dependency>  
  7.             <groupId>org.apache.activemq</groupId>  
  8.             <artifactId>activemq-all</artifactId>  
  9.             <version>5.13.2</version>  
  10.         </dependency>  

application.properties:

Java代码  收藏代码
  1. spring.activemq.in-memory=true  
  2. spring.activemq.pooled=false  

 

 

接下来就是jms的配置了,首先是ActiveMQ4Config文件:

Java代码  收藏代码
  1. @EnableJms  
  2. @Configuration  
  3. public class ActiveMQ4Config {  
  4.   
  5.     @Bean  
  6.     public Queue queue() {  
  7.         return new ActiveMQQueue("github-queue");  
  8.     }  
  9.   
  10.     @Bean  
  11.     public ActiveMQConnectionFactory activeMQConnectionFactory (){  
  12.         ActiveMQConnectionFactory activeMQConnectionFactory =  
  13.                 new ActiveMQConnectionFactory(  
  14.                         ActiveMQConnectionFactory.DEFAULT_USER,  
  15.                         ActiveMQConnectionFactory.DEFAULT_PASSWORD,  
  16. //                        "tcp://192.168.0.100:61616");  
  17.                         ActiveMQConnectionFactory.DEFAULT_BROKER_URL);  
  18.         return activeMQConnectionFactory;  
  19.     }  
  20.   
  21. }  

注释掉的那行,可以用来指定activemq的broker地址。

 

接下来的Producer和Consumer与github上一样:

Java代码  收藏代码
  1. @Component  
  2. public class Producer implements CommandLineRunner{  
  3.   
  4.     @Autowired  
  5.     private JmsMessagingTemplate jmsMessagingTemplate;  
  6.   
  7.     @Autowired  
  8.     private Queue queue;  
  9.   
  10.     @Override  
  11.     public void run(String... args) throws Exception {  
  12.         send("this message is send on begining!");  
  13.         System.out.println("Message was sent to the Queue");  
  14.     }  
  15.   
  16.     public void send(String msg) {  
  17.         this.jmsMessagingTemplate.convertAndSend(this.queue, msg);  
  18.     }  
  19.   
  20. }  
Java代码  收藏代码
  1. @Component  
  2. public class Consumer {  
  3.   
  4.     @JmsListener(destination = "github-queue")  
  5.     public void receiveQueue(String text) {  
  6.         System.out.println(text);  
  7.     }  
  8.   
  9. }  

 

这样一来就完成了配置,而且在8161默认admin进行查询时,是能够查询到我们的github-queue这个队列的。

具体的测试,可以自己进行,这里不再贴测试用例了。

分享到:
评论

相关推荐

    SpringBoot+ActiveMq+MQTT实现消息的发送和接收

    在本文中,我们将深入探讨如何使用SpringBoot、ActiveMQ和MQTT来实现消息的发送与接收。这是一个典型的分布式系统中的消息通信场景,其中SpringBoot作为应用程序框架,ActiveMQ作为消息中间件,而MQTT(Message ...

    Spring boot+ActiveMQ整合消息队列实现发布订阅、生产者消费者模型(适合开发人员了解学习ActiveMQ机制)

    本项目基于Spring这一平台,整合流行的开源消息队列中间件ActiveMQ,实现一个向ActiveMQ添加和读取消息的功能。并比较了两种模式:生产者-消费者模式和发布-订阅模式的区别。 包含的特性如下: 1.开启activeMQ,访问...

    springboot-nettysocketio +netty+activeMq在线客服系统

    springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot...

    jms Spring+ActiveMQ 5.4.2

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

    SpringBoot整合ActiveMQ+websocket.docx

    在Spring Boot应用中整合ActiveMQ和WebSocket,可以创建一个实时通信系统,使后端服务能够高效地推送消息到前端客户端。以下将详细解释这个过程的关键知识点: 1. **ActiveMQ**:Apache ActiveMQ是一个开源的消息...

    Spring+ActiveMQ整合实例代码工程

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

    spring-boot-activemq-demo

    在本示例项目"spring-boot-activemq-demo"中,我们关注的是如何将Spring Boot与Apache ActiveMQ集成,以实现高效的消息传递功能。ActiveMQ是Apache软件基金会的一个开源项目,它是Java消息服务(JMS)的实现,提供了...

    springboot整合mybatis+activemq(activemq可以去官网下载 )

    在IT行业中,Spring Boot、MyBatis和ActiveMQ是三个非常重要的组件,分别用于简化Spring应用的初始化,处理持久化操作以及实现消息队列。本文将深入探讨如何将这三个技术整合到一个项目中,以便构建高效、可扩展的...

    微服务架构面试题系列:Dubbo+Spring Boot+Spring Cloud.zip

    在微服务架构中,Spring Boot常作为服务的起点,开发者可以快速创建独立的、生产级别的基于Spring的应用。面试时可能会涉及Spring Boot的自动配置、起步依赖、Actuator监控以及如何与外部配置中心集成等内容。 再者...

    spring boot activemq整合例子

    Spring Boot 是一个流行的Java开发框架,...通过以上步骤,你可以在Spring Boot项目中轻松集成并使用ActiveMQ,实现消息的高效传输和处理。这为构建分布式系统、解耦组件间的依赖以及实现异步任务执行提供了强大支持。

    Spring Boot整合ActiveMQ

    在 Spring Boot 中整合 ActiveMQ,可以使用 Spring 的 JmsTemplate 或者 @JmsListener 注解来发送和接收消息,实现应用间的异步通信和解耦。 整合以上技术的过程通常包括以下步骤: - 添加对应库的依赖,如 spring...

    Spring boot 和内置ActiveMQ集成例子.zip

    将Spring Boot与ActiveMQ集成可以提供强大的消息处理能力,使应用能够解耦组件,提高可扩展性和容错性。 本文将详细讲解如何使用Spring Boot与内置的ActiveMQ进行集成,以及如何通过代码实现这一过程。 首先,我们...

    springboot集成activemq实现消息接收demo

    本教程将详细介绍如何在Spring Boot项目中集成ActiveMQ,实现消息接收的Demo。 首先,我们需要在Spring Boot项目中引入ActiveMQ的相关依赖。在`pom.xml`文件中添加以下Maven依赖: ```xml &lt;groupId&gt;org.spring...

    jmsKata:弹簧靴 + activemq

    本项目"jmsKata: 弹簧靴 + activemq"就是针对这一主题进行的一次深度实践,旨在帮助开发者更好地理解和应用Java消息服务(Java Message Service,简称JMS)以及Apache ActiveMQ。 首先,我们要了解JMS。JMS是Java...

    spring boot+dubbo+zookeeper+redis+activitmq

    Dubbo 可以与 Spring 集成,实现服务的声明式调用。 3. **Zookeeper**: ZooKeeper 是一个分布式的,开放源码的分布式应用程序协调服务,它是集群的管理者,监视着集群中各个节点的状态根据节点提交的反馈进行下...

    基于Springboot+ActiveMQ事务==本地事件表+activemq.zip

    本项目基于Springboot和ActiveMQ实现了一种分布式事务解决方案,它利用了“本地事件表”和ActiveMQ来协调跨服务的数据操作。接下来,我们将深入探讨这个方案的各个组成部分以及它们如何协同工作。 首先,Springboot...

    Springboot ActiveMQ 集成.rar

    当我们需要在Spring Boot应用中集成ActiveMQ时,我们可以实现高效、异步的通信机制,提高系统的可扩展性和解耦性。 首先,让我们详细探讨一下Spring Boot与ActiveMQ的集成过程: 1. **配置ActiveMQ** - 在`...

    spring,mybatis,hibernate,activemq,redis,dubbo的集成

    ActiveMQ 是Apache出品的一款消息中间件,基于Java消息服务(JMS)。它允许应用程序之间通过异步消息传递进行通信,提高系统的可扩展性和解耦度。在微服务架构中,ActiveMQ常被用于服务间的通讯。 5. **Redis**: ...

    spring boot 集成activemq Datajpa Ehcache

    在这个项目中,我们将探讨如何将Spring Boot与Apache ActiveMQ、DataJPA和Ehcache进行集成,以构建一个功能丰富的应用程序。 首先,ActiveMQ是Apache出品的一款开源消息中间件,它遵循Java Message Service (JMS) ...

    SpringBoot快速玩转ActiveMQ消息队列

    1. **添加依赖**:在`pom.xml`文件中引入ActiveMQ的Spring Boot starter依赖: ```xml &lt;groupId&gt;org.springframework.boot &lt;artifactId&gt;spring-boot-starter-activemq ``` 2. **配置ActiveMQ**:在`...

Global site tag (gtag.js) - Google Analytics