本章节主要内容:
主要从以下几个方面讲解:
mybatis和spring boot整合、redis(单机版)和spring boot整合、redis(集群)和spring boot整合、httpclient和spring boot整合、rabbitMQ/active MQ和spring boot整合。
欢迎访问凯哥个人博客网站:www.kaigejava.com
欢迎关注凯哥公众号:凯哥Java(kaigejava)
接下来我们学习第二小节:spring boot整合redis开启缓存
本节主要内容:
1:spring boot整合active mq方案一
方案一是简单的,生产者和消费者都在同一个应用项目中。
一:active mq相关
1:active mq下载:
2:启动
在bin文件夹下有64和32位找到自己系统响应的文件夹打开。凯哥使用的是64位的

双击activemq.bat批处理就启动了。
启动如下图:
二:spring boot中应用active mq
2.1:在pom.xml文件中添加mq相关的依赖。
org.springframework.boot
spring-boot-starter-activemq
org.apache.activemq
activemq-pool
2.2:MQ配置类
注:必须使用@Configuration 或者是spring 其他注解。这样该类才可以被spring管理。
setBrokerURL是添加url的
完整代码如下:
package com.kaigejava.springconfig.mq;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.pool.PooledConnectionFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jms.connection.SingleConnectionFactory;
import org.springframework.jms.core.JmsTemplate;
@Configuration
public class ActiveMQConfig {
@Bean
public ActiveMQConnectionFactory targetConnectionFactory(){
ActiveMQConnectionFactory targetConnectionFactory = new ActiveMQConnectionFactory();
targetConnectionFactory.setBrokerURL("tcp://localhost:61616");
return targetConnectionFactory;
}
@Bean
public SingleConnectionFactory connectionFactory( PooledConnectionFactory targetConnectionFactory){
SingleConnectionFactory connectionFactory = new SingleConnectionFactory();
connectionFactory.setTargetConnectionFactory(targetConnectionFactory);
return connectionFactory;
}
@Bean
public PooledConnectionFactory pooledConnectionFactory(ActiveMQConnectionFactory targetConnectionFactory){
PooledConnectionFactory pooledConnectionFactory = new PooledConnectionFactory();
pooledConnectionFactory.setConnectionFactory(targetConnectionFactory);
pooledConnectionFactory.setMaxConnections(10);
return pooledConnectionFactory;
}
@Bean
public JmsTemplate jmsTemplate(SingleConnectionFactory connectionFactory){
JmsTemplate jmsTemplate = new JmsTemplate();
jmsTemplate.setConnectionFactory(connectionFactory);
return jmsTemplate;
}
}
2.3:生产者配置:

这里记录日志时候使用的MQ生产者。
/**
*
* @ClassName: Producer
* @Description: 后台通过MQ记录日志的生成者
* @author 凯哥Java
*
*
*/
@Service("adminLogProducer")
public class AdminLogProducer {
@Autowired // 也可以注入JmsTemplate,JmsMessagingTemplate对JmsTemplate进行了封装
private JmsMessagingTemplate jmsTemplate;
// 发送消息,destination是发送到的队列,message是待发送的消息
public void sendMessage(Destination destination, final String message){
jmsTemplate.convertAndSend(destination, message);
}
}
2.4:消费者:消费者进行消费处理。
2.5:在service层使用:
使用步骤:
2.5.1:注入mq生产者
2.5.2:准备准备发射的数据
2.5.3:创建一个目标并指定消费者
Destination destination = new ActiveMQQueue("adminLogConsumerQuenue.loggingClassName");
2.5.4:调用生产者的方法进行发送
adminLogProducer.sendMessage(destination,sendmsg);
2.6:生产者发送类:
至此spring boot整合active MQ方案一完成。
本系列教程其他文章:
spring boot框架学习学前掌握之重要注解(1)-sprng的java配置方式
spring boot框架学习学前掌握之重要注解(2)-通过java的配置方式进行配置spring.
boot框架学习学前掌握之重要注解(3)-通过注解方式读取外部资源配置文件
spring boot框架学习学前掌握之重要注解(4)-通过注解方式读取外部资源配置文件2
boot框架学习1-认识spring boot和快速入门
spring boot框架学习2-spring boot核心(1)
spring boot框架学习3-spring boot核心(2)
spring boot框架学习4-spring boot核心(3)
spring boot框架学习5-spring boot的web开发(1)
spring boot框架学习6-spring boot的web开发(2)
spring boot框架学习7-spring boot的web开发(3)-自定义消息转换器
spring boot框架学习8-【干货】spring boot的web开发(4)-自定义拦截器处理权限
spring boot框架学习9-spring boot的web开发(5)-错误解决及跳转页面
spring boot框架学习10-spring boot持久化数据
spring boot框架学习11-spring boot整合redis
相关推荐
Spring Boot 基于 Active MQ 实现整合 JMS Spring Boot 是一个基于 Java 的框架,Active MQ 是一个开源的消息队列系统,JMS(Java Message Service)是 Java 平台上的一种消息服务规范。今天,我们将介绍如何使用 ...
在IT行业中,Spring Boot是一个非常流行的微服务框架,它简化了Spring应用的初始搭建以及开发过程。而ActiveMQ则是Apache出品的一款开源的消息中间件,它实现了多种消息协议,如OpenWire、AMQP、STOMP等,是Java消息...
ActiveMQ是Apache开发的一款开源消息中间件,而Spring框架则广泛应用于Java后端开发,提供了一整套强大的企业级应用解决方案。当我们需要在Spring应用中集成ActiveMQ时,就需要进行相应的配置。本文将深入讲解...
通过Spring Boot学习Apache Camel Framework通过Spring Boot学习Apache Camel Framework。 使用Active MQ,Kafka和REST API实施EI体系结构模式。 企业集成非常复杂。 微服务和云的发展使企业整合变得更加复杂。 您...
使用Swagger和Active MQ的Spring Boot Server。 概述 这是一个使用SpringBoot框架在Java中构建启用了swagger的服务器的示例。 与Active MQ集成,如 将swagger集成到SpringBoot的底层库是 作为一个简单的Java应用...
在实际应用中,ActiveMQ不仅可以作为消息传递的基础,还可以与其他技术如Spring Boot、Spring Cloud Stream等进行深度集成,构建复杂的企业级消息处理系统。理解并熟练掌握ActiveMQ的启动和测试方法,对于开发高效、...
<groupId>org.springframework.boot <artifactId>spring-boot-maven-plugin <directory>src/main/resources <filtering>true ``` 这里,我们使用 Resources 和 Filter 来指定资源文件夹和过滤...
- 基于嵌入式Tomcat的Spring Boot应用 **3.2 Flowable 支持的运行容器** Flowable支持的容器包括: - Apache Tomcat 7.0 / 8.0 / 9.0 - Oracle WebLogic Server 12c (12R1,12R2) (仅限企业版) **小结** 可以看出...
AplicaçãoCadastro de Produtos-Leroy ...界面Gráficapara consulta direta ao banco de dados(H2)铁线虫Sprint Boot2 Spring数据H2-SGBD嵌入式Active MQ 5(嵌入式Message Broker) 昂首阔步Apache POIArquitetur