首先,我在github上找到了一个不错的demo,这里放给大家一起看下:
确实可以实现功能,但是当我在8161默认的admin端口进行queue查询时,发现并没有我们的github-queue,虽然不太清楚具体的原因,但是解决方式倒是找到了,下面贴一下自己的实现:
pox.xml:
- <!-- ActiveMQ -->
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-jms</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.activemq</groupId>
- <artifactId>activemq-all</artifactId>
- <version>5.13.2</version>
- </dependency>
application.properties:
- spring.activemq.in-memory=true
- spring.activemq.pooled=false
接下来就是jms的配置了,首先是ActiveMQ4Config文件:
- @EnableJms
- @Configuration
- public class ActiveMQ4Config {
- @Bean
- public Queue queue() {
- return new ActiveMQQueue("github-queue");
- }
- @Bean
- public ActiveMQConnectionFactory activeMQConnectionFactory (){
- ActiveMQConnectionFactory activeMQConnectionFactory =
- new ActiveMQConnectionFactory(
- ActiveMQConnectionFactory.DEFAULT_USER,
- ActiveMQConnectionFactory.DEFAULT_PASSWORD,
- // "tcp://192.168.0.100:61616");
- ActiveMQConnectionFactory.DEFAULT_BROKER_URL);
- return activeMQConnectionFactory;
- }
- }
注释掉的那行,可以用来指定activemq的broker地址。
接下来的Producer和Consumer与github上一样:
- @Component
- public class Producer implements CommandLineRunner{
- @Autowired
- private JmsMessagingTemplate jmsMessagingTemplate;
- @Autowired
- private Queue queue;
- @Override
- public void run(String... args) throws Exception {
- send("this message is send on begining!");
- System.out.println("Message was sent to the Queue");
- }
- public void send(String msg) {
- this.jmsMessagingTemplate.convertAndSend(this.queue, msg);
- }
- }
- @Component
- public class Consumer {
- @JmsListener(destination = "github-queue")
- public void receiveQueue(String text) {
- System.out.println(text);
- }
- }
这样一来就完成了配置,而且在8161默认admin进行查询时,是能够查询到我们的github-queue这个队列的。
具体的测试,可以自己进行,这里不再贴测试用例了。
相关推荐
在本文中,我们将深入探讨如何使用SpringBoot、ActiveMQ和MQTT来实现消息的发送与接收。这是一个典型的分布式系统中的消息通信场景,其中SpringBoot作为应用程序框架,ActiveMQ作为消息中间件,而MQTT(Message ...
本项目基于Spring这一平台,整合流行的开源消息队列中间件ActiveMQ,实现一个向ActiveMQ添加和读取消息的功能。并比较了两种模式:生产者-消费者模式和发布-订阅模式的区别。 包含的特性如下: 1.开启activeMQ,访问...
springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot...
标题 "jms Spring+ActiveMQ 5.4.2" 涉及的是Java消息服务(JMS)在Spring框架中的应用,以及ActiveMQ作为消息代理的使用。在这个主题下,我们将深入探讨JMS的基本概念、Spring对JMS的支持以及ActiveMQ 5.4.2版本的...
在Spring Boot应用中整合ActiveMQ和WebSocket,可以创建一个实时通信系统,使后端服务能够高效地推送消息到前端客户端。以下将详细解释这个过程的关键知识点: 1. **ActiveMQ**:Apache ActiveMQ是一个开源的消息...
在Java开发中,Spring框架是极为重要的应用基础,而ActiveMQ作为Apache出品的一款开源消息中间件,常被用于实现应用间的异步通信和解耦。本实例代码工程"Spring+ActiveMQ整合实例代码工程"正是结合两者,展示了如何...
在本示例项目"spring-boot-activemq-demo"中,我们关注的是如何将Spring Boot与Apache ActiveMQ集成,以实现高效的消息传递功能。ActiveMQ是Apache软件基金会的一个开源项目,它是Java消息服务(JMS)的实现,提供了...
在IT行业中,Spring Boot、MyBatis和ActiveMQ是三个非常重要的组件,分别用于简化Spring应用的初始化,处理持久化操作以及实现消息队列。本文将深入探讨如何将这三个技术整合到一个项目中,以便构建高效、可扩展的...
在微服务架构中,Spring Boot常作为服务的起点,开发者可以快速创建独立的、生产级别的基于Spring的应用。面试时可能会涉及Spring Boot的自动配置、起步依赖、Actuator监控以及如何与外部配置中心集成等内容。 再者...
Spring Boot 是一个流行的Java开发框架,...通过以上步骤,你可以在Spring Boot项目中轻松集成并使用ActiveMQ,实现消息的高效传输和处理。这为构建分布式系统、解耦组件间的依赖以及实现异步任务执行提供了强大支持。
在 Spring Boot 中整合 ActiveMQ,可以使用 Spring 的 JmsTemplate 或者 @JmsListener 注解来发送和接收消息,实现应用间的异步通信和解耦。 整合以上技术的过程通常包括以下步骤: - 添加对应库的依赖,如 spring...
将Spring Boot与ActiveMQ集成可以提供强大的消息处理能力,使应用能够解耦组件,提高可扩展性和容错性。 本文将详细讲解如何使用Spring Boot与内置的ActiveMQ进行集成,以及如何通过代码实现这一过程。 首先,我们...
本教程将详细介绍如何在Spring Boot项目中集成ActiveMQ,实现消息接收的Demo。 首先,我们需要在Spring Boot项目中引入ActiveMQ的相关依赖。在`pom.xml`文件中添加以下Maven依赖: ```xml <groupId>org.spring...
本项目"jmsKata: 弹簧靴 + activemq"就是针对这一主题进行的一次深度实践,旨在帮助开发者更好地理解和应用Java消息服务(Java Message Service,简称JMS)以及Apache ActiveMQ。 首先,我们要了解JMS。JMS是Java...
Dubbo 可以与 Spring 集成,实现服务的声明式调用。 3. **Zookeeper**: ZooKeeper 是一个分布式的,开放源码的分布式应用程序协调服务,它是集群的管理者,监视着集群中各个节点的状态根据节点提交的反馈进行下...
本项目基于Springboot和ActiveMQ实现了一种分布式事务解决方案,它利用了“本地事件表”和ActiveMQ来协调跨服务的数据操作。接下来,我们将深入探讨这个方案的各个组成部分以及它们如何协同工作。 首先,Springboot...
当我们需要在Spring Boot应用中集成ActiveMQ时,我们可以实现高效、异步的通信机制,提高系统的可扩展性和解耦性。 首先,让我们详细探讨一下Spring Boot与ActiveMQ的集成过程: 1. **配置ActiveMQ** - 在`...
ActiveMQ 是Apache出品的一款消息中间件,基于Java消息服务(JMS)。它允许应用程序之间通过异步消息传递进行通信,提高系统的可扩展性和解耦度。在微服务架构中,ActiveMQ常被用于服务间的通讯。 5. **Redis**: ...
在这个项目中,我们将探讨如何将Spring Boot与Apache ActiveMQ、DataJPA和Ehcache进行集成,以构建一个功能丰富的应用程序。 首先,ActiveMQ是Apache出品的一款开源消息中间件,它遵循Java Message Service (JMS) ...
1. **添加依赖**:在`pom.xml`文件中引入ActiveMQ的Spring Boot starter依赖: ```xml <groupId>org.springframework.boot <artifactId>spring-boot-starter-activemq ``` 2. **配置ActiveMQ**:在`...