使用Spring Boot集成中间件：基础篇

使用Spring Boot集成中间件：Redis基础讲解

在现代应用开发中，中间件在构建高效、可扩展的系统方面起着至关重要的作用。而Spring Boot作为一种快速开发框架，提供了丰富的集成中间件的能力，使得我们能够轻松地将各种中间件引入到我们的应用程序中。本文将重点介绍如何使用Spring Boot集成Redis中间件，并提供一个简单的案例来说明其用法。

  1. 引入依赖
    首先，我们需要在pom.xml文件中引入Spring Boot与Redis的依赖项。在dependencies节点下添加以下代码：
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
  1. 配置Redis连接
    在application.properties文件中配置Redis的连接信息。以下是一个示例配置：
spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.password=your_password (如果有密码的话)
  1. 创建RedisRepository
    接下来，我们将创建一个简单的RedisRepository接口，用于定义与Redis交互的操作。可以根据实际需求添加更多的方法。
import org.springframework.data.repository.CrudRepository;public interface RedisRepository extends CrudRepository<String, String> {// 这里可以添加自定义的Redis操作方法
}
  1. 使用Redis
    在我们的应用程序中使用RedisRepository来执行Redis操作。以下是一个示例：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.CommandLineRunner;@SpringBootApplication
public class MyApplication implements CommandLineRunner {@Autowiredprivate RedisRepository redisRepository;public static void main(String[] args) {SpringApplication.run(MyApplication.class, args);}@Overridepublic void run(String... args) throws Exception {// 保存数据到RedisredisRepository.save("key", "value");// 从Redis中获取数据String value = redisRepository.findById("key").orElse(null);System.out.println("Value: " + value);}
}

在上述示例中，我们通过redisRepository.save("key", "value")将键值对保存到Redis中，并通过redisRepository.findById("key")从Redis中获取该键的值。

  1. 运行应用程序
    现在，我们可以运行我们的Spring Boot应用程序，并观察控制台输出。如果一切正常，你将能够看到从Redis中获取的值。

使用Spring Boot集成中间件：RabbitMQ基础篇

在分布式系统开发中，消息队列是一种常用的中间件技术，用于解耦和异步处理不同组件之间的通信。RabbitMQ是一个流行的开源消息队列中间件，提供了可靠的消息传递机制。本文将介绍如何使用Spring Boot集成RabbitMQ，并提供一个简单的案例来说明其用法。

  1. 引入依赖
    首先，在pom.xml文件中引入Spring Boot与RabbitMQ的依赖项。在dependencies节点下添加以下代码：
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
  1. 配置RabbitMQ连接
    在application.properties文件中配置RabbitMQ的连接信息。以下是一个示例配置：
spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
  1. 创建消息生产者和消费者
    接下来，我们将创建一个简单的消息生产者和消费者。首先，创建消息生产者MessageProducer：
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.CommandLineRunner;
import org.springframework.context.annotation.Bean;@SpringBootApplication
public class MyApplication implements CommandLineRunner {@Autowiredprivate RabbitTemplate rabbitTemplate;@Beanpublic Queue queue() {return new Queue("myQueue");}public static void main(String[] args) {SpringApplication.run(MyApplication.class, args);}@Overridepublic void run(String... args) throws Exception {rabbitTemplate.convertAndSend("myQueue", "Hello, RabbitMQ!");}
}

然后，创建消息消费者MessageConsumer：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
public class MessageConsumer {@RabbitListener(queues = "myQueue")public void handleMessage(String message) {System.out.println("Received message: " + message);}
}

在上述示例中，MessageProducer通过rabbitTemplate.convertAndSend("myQueue", "Hello, RabbitMQ!")将消息发送到名为myQueue的队列中，而MessageConsumer使用@RabbitListener注解监听myQueue队列，并在接收到消息时进行处理。

  1. 运行应用程序
    现在，我们可以运行我们的Spring Boot应用程序，并观察控制台输出。如果一切正常，你将能够看到消费者接收到由生产者发送的消息。

使用Spring Boot集成中间件：Kafka基础篇

Kafka是一个高性能的分布式消息队列系统，被广泛应用于大规模数据处理和实时流处理场景。在Spring Boot应用程序中，我们可以通过集成Kafka中间件来实现高效的消息传递和处理。本文将介绍如何使用Spring Boot集成Kafka，并提供一个简单的案例来说明其用法。

  1. 引入依赖
    首先，在pom.xml文件中引入Spring Boot与Kafka的依赖项。在dependencies节点下添加以下代码：
<dependency><groupId>org.springframework.kafka</groupId><artifactId>spring-kafka</artifactId>
</dependency>
  1. 配置Kafka连接
    在application.properties文件中配置Kafka的连接信息。以下是一个示例配置：
spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=myGroup
spring.kafka.consumer.auto-offset-reset=earliest
  1. 创建消息生产者和消费者
    接下来，我们将创建一个简单的消息生产者和消费者。首先，创建消息生产者MessageProducer：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.CommandLineRunner;
import org.springframework.kafka.core.KafkaTemplate;@SpringBootApplication
public class MyApplication implements CommandLineRunner {@Autowiredprivate KafkaTemplate<String, String> kafkaTemplate;public static void main(String[] args) {SpringApplication.run(MyApplication.class, args);}@Overridepublic void run(String... args) throws Exception {String topic = "myTopic";String message = "Hello, Kafka!";kafkaTemplate.send(topic, message);}
}

然后，创建消息消费者MessageConsumer：

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;@Component
public class MessageConsumer {@KafkaListener(topics = "myTopic", groupId = "myGroup")public void handleMessage(String message) {System.out.println("Received message: " + message);}
}

在上述示例中，MessageProducer通过kafkaTemplate.send(topic, message)将消息发送到名为myTopic的主题中，而MessageConsumer使用@KafkaListener注解监听myTopic主题，并在接收到消息时进行处理。

  1. 运行应用程序
    现在，我们可以运行我们的Spring Boot应用程序，并观察控制台输出。如果一切正常，你将能够看到消费者接收到由生产者发送的消息。

使用Spring Boot集成中间件：Elasticsearch基础篇

Elasticsearch是一个开源的分布式搜索引擎和分析引擎，它被广泛应用于实时搜索、日志分析、安全分析和大数据分析等领域。在Spring Boot应用程序中，我们可以使用Spring Data Elasticsearch模块来集成Elasticsearch中间件，实现数据的索引、搜索和分析。下面是关于如何在Spring Boot中使用Elasticsearch的讲解：

  1. 引入依赖
    首先，在pom.xml文件中引入Spring Boot与Elasticsearch的依赖项。在dependencies节点下添加以下代码：
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
  1. 配置Elasticsearch连接
    在application.properties文件中配置Elasticsearch的连接信息。以下是一个示例配置：
spring.data.elasticsearch.cluster-nodes=localhost:9200
  1. 创建实体类
    接下来，我们需要创建一个实体类，用于映射到Elasticsearch中的索引和文档。以下是一个示例：
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;@Document(indexName = "myindex", type = "mytype")
public class MyEntity {@Idprivate String id;private String name;// Getters and setters}

在上述示例中，@Document注解指定了索引名和类型名，@Id注解表示该字段为文档的唯一标识。

  1. 创建数据访问接口
    然后，我们需要创建一个数据访问接口，继承自Spring Data Elasticsearch提供的ElasticsearchRepository接口。例如：
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;public interface MyEntityRepository extends ElasticsearchRepository<MyEntity, String> {// 自定义查询方法}

在上述示例中，MyEntityRepository继承自ElasticsearchRepository，并指定了实体类和标识字段的类型。

  1. 使用Elasticsearch操作数据
    现在，我们可以在业务逻辑中使用MyEntityRepository接口中定义的方法来操作Elasticsearch中的数据。例如：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class MyService {@Autowiredprivate MyEntityRepository repository;public void saveEntity(MyEntity entity) {repository.save(entity);}public Iterable<MyEntity> searchEntities(String keyword) {// 使用repository的查询方法进行搜索操作return repository.findByName(keyword);}// 其他操作方法}

在上述示例中，我们通过自动注入MyEntityRepository来使用Elasticsearch的数据访问方法，如保存数据和进行搜索操作。

使用Spring Boot集成中间件：Quartz基础篇

Quartz是一个功能强大的作业调度框架，可以在指定的时间间隔内执行任务。在Spring Boot应用程序中，我们可以使用Quartz中间件来实现任务调度和定时任务的管理。下面是关于如何在Spring Boot中使用Quartz的讲解：

  1. 引入依赖
    首先，在pom.xml文件中引入Spring Boot与Quartz的依赖项。在dependencies节点下添加以下代码：
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-quartz</artifactId>
</dependency>
  1. 创建定时任务
    接下来，我们需要创建一个定时任务类，实现Job接口，并重写execute方法。例如：
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;public class MyJob implements Job {@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {// 定时任务的具体逻辑System.out.println("定时任务执行了！");}
}

在上述示例中，我们定义了一个MyJob类，实现了Job接口，并在execute方法中编写了定时任务的逻辑。

  1. 配置定时任务
    在Spring Boot中，可以通过在application.properties文件中配置定时任务的调度规则。以下是一个示例：
spring.quartz.job-store-type=jdbc
spring.quartz.jdbc.initialize-schema=always
spring.quartz.properties.org.quartz.scheduler.instanceName = MyScheduler
spring.quartz.properties.org.quartz.scheduler.instanceId = AUTO
spring.quartz.properties.org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
spring.quartz.properties.org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
spring.quartz.properties.org.quartz.jobStore.tablePrefix = QRTZ_
spring.quartz.properties.org.quartz.jobStore.isClustered = false
spring.quartz.properties.org.quartz.jobStore.dataSource = myDataSource
spring.quartz.properties.org.quartz.dataSource.myDataSource.driver = com.mysql.jdbc.Driver
spring.quartz.properties.org.quartz.dataSource.myDataSource.URL = jdbc:mysql://localhost:3306/quartz
spring.quartz.properties.org.quartz.dataSource.myDataSource.user = root
spring.quartz.properties.org.quartz.dataSource.myDataSource.password = 123456
spring.quartz.properties.org.quartz.dataSource.myDataSource.maxConnections = 5

在上述示例中，我们使用JDBC作业存储类型，并配置了与数据库相关的属性，如驱动程序、数据库连接URL、用户名和密码等。

  1. 配置定时任务调度器
    接下来，我们需要配置定时任务调度器。可以创建一个配置类，使用@Configuration注解，并实现SchedulingConfigurer接口。例如：
import org.quartz.*;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;@Configuration
public class QuartzConfig implements SchedulingConfigurer {@Overridepublic void configureTasks(ScheduledTaskRegistrar taskRegistrar) {taskRegistrar.setScheduler(quartzScheduler());}@Beanpublic Scheduler quartzScheduler() {try {SchedulerFactory schedulerFactory = new StdSchedulerFactory();Scheduler scheduler = schedulerFactory.getScheduler();scheduler.start();return scheduler;} catch (SchedulerException e) {throw new RuntimeException("无法启动定时任务调度器", e);}}
}

在上述示例中，我们通过StdSchedulerFactory创建了一个Scheduler实例，并在quartzScheduler方法中启动了调度器。

  1. 启动定时任务
    最后，我们可以在需要调度定时任务的地方使用@Scheduled注解来标记方法。例如：
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;@Component
public class MyScheduledTasks {@Scheduled(cron = "0 0/1 * * * ?") // 每分钟执行一次public void myTask() {System.out.println("定时任务执行了！");}
}

在上述示例中，我们使用@Scheduled注解来标记myTask方法，指定了定时任务的触发规则。
谢谢观看!

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/612455.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

在 Windows IIS 生成证书签名请求（CSR）

在 Windows IIS 生成证书签名请求（CSR）

本操作方法将逐步指导您生成证书签名请求&#xff08;CSR&#xff09;。 这些过程已在Windows 10的IIS 10上进行了测试&#xff0c;但也将在IIS 7.x和8.x中运行。 启动IIS管理器。 Start 开始 IIS管理器。 另外一种快速的方法是打开 运行 命令&#xff0c;然后键入 inetmgr 并…
阅读更多...
深度学习算法应用实战 | 利用 CLIP 模型进行“零样本图像分类”

深度学习算法应用实战 | 利用 CLIP 模型进行“零样本图像分类”

文章目录 1. 零样本图像分类简介1.1 什么是零样本图像分类?1.2 通俗一点的解释 2. 模型原理图3. 环境配置4. 代码实战5. Gradio前端页面5.1 什么是 Gradio ? 6 进阶操作7. 总结 1. 零样本图像分类简介 1.1 什么是零样本图像分类? “零样本图像分类”&#xff08;Zero-shot …
阅读更多...
解决org.apache.jasper.JasperException异常！

解决org.apache.jasper.JasperException异常！

解决org.apache.jasper.JasperException异常&#xff01; 大家好&#xff0c;我是免费搭建查券返利机器人赚佣金就用微赚淘客系统3.0的小编&#xff0c;也是冬天不穿秋裤&#xff0c;天冷也要风度的程序猿&#xff01;今天&#xff0c;我们将一同面对在Java Web开发中常见的问题…
阅读更多...
C++获取内存使用情况

C++获取内存使用情况

在程序编程过程中&#xff0c;为了防止出现内存泄漏情况出现&#xff0c;需要持续关注内存程序内存占用情况。如下方式实现获取当前进程内存使用情况&#xff1a; linux&#xff1a; void my_top(string path, bool flag) {if(flag){FILE* read_top fopen("/proc/self/…
阅读更多...
debian 12 zabbix 6.0LTS部署

debian 12 zabbix 6.0LTS部署

数据库要求 数据库版本不对&#xff0c;zabbix-server启动不起来 MySQL/Percona8.0.XRequired if MySQL (or Percona) is used as Zabbix backend database. InnoDB engine is required. We recommend using the MariaDB Connector/C library for building server/proxy.Maria…
阅读更多...
使用GPT大模型调用工具链

使用GPT大模型调用工具链

本文特指openai使用sdk的方式调用工具链。 安装openai pip install openai export OPENAI_API_KEY"YOUR OPENAI KEY" 定义工具函数 from openai import OpenAI import jsonclient OpenAI() #工具函数 def get_current_weather(location, unit"fahrenheit&q…
阅读更多...
使用懒加载 + 零拷贝后，程序的秒开率提升至99.99%

使用懒加载 + 零拷贝后，程序的秒开率提升至99.99%

目录 一、5秒钟加载一个页面的真相二、优化四步走1、“懒加载”2、线上显示 就读取一个文件&#xff0c;为什么会慢呢&#xff1f; 三、先从上帝视角&#xff0c;了解一下啥子是IO流四、写个栗子&#xff0c;测试一下1、通过字符输入流FileReader读取2、通过缓冲流BufferedRea…
阅读更多...
Spark---RDD序列化

Spark---RDD序列化

文章目录 1 什么是序列化2.RDD中的闭包检查3.Kryo 序列化框架 1 什么是序列化 序列化是指 将对象的状态信息转换为可以存储或传输的形式的过程。 在序列化期间&#xff0c;对象将其当前状态写入到临时或持久性存储区。以后&#xff0c;可以通过从存储区中读取或反序列化对象的…
阅读更多...
⭐Unity LeapMotion与手的相关开发

⭐Unity LeapMotion与手的相关开发

LeapMotion 官方文档中文翻译帮助手册教程 Hand 一个Hand手对象表示了一个跟踪的手&#xff0c;一个手总是包含5个手指以及相关属性如&#xff1a;Direction,PalmPosition,和Basis(orientation). lamPosition :手掌中心到Leap设备原点以毫米测量的距离 PalmVelocity :手掌移…
阅读更多...
YOLOv8改进 | 检测头篇 | 利用DynamicHead增加辅助检测头针对性检测(四头版本)

YOLOv8改进 | 检测头篇 | 利用DynamicHead增加辅助检测头针对性检测(四头版本)

一、本文介绍 本文给大家带来的改进机制是针对性的改进，针对于小目标检测增加P2层，针对于大目标检测增加P6层利用DynamicHead(原版本一比一复现，全网独一份，不同于网上魔改版本)进行检测，其中我们增加P2层其拥有更高的分辨率，这使得模型能够更好地捕捉到小尺寸目标的细节…
阅读更多...
docker启动mongo

docker启动mongo

用户名&#xff1a;root 密码&#xff1a;123456 version: 3.1 services:mongo:image: mongo:7container_name: mongorestart: alwaysports:- 27017:27017volumes:- /opt/data/mongo:/data/dbenvironment:TZ: Asia/ShanghaiMONGO_INITDB_ROOT_USERNAME: rootMONGO_INITDB_ROO…
阅读更多...
若依前后端分离版使用mybatis-plus实践教程

若依前后端分离版使用mybatis-plus实践教程

1、根目录得pom加入依赖 <properties><mybatis-plus.version>3.5.1</mybatis-plus.version> </properties> <dependencies><!-- mp配置--><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus…
阅读更多...
微服务治理：什么是微服务生命周期管理 (MLM)？

微服务治理：什么是微服务生命周期管理 (MLM)？

微服务生命周期管理 (MLM) 指的是管理微服务整个生命周期的各种流程和工具&#xff0c;从其最初的设计和开发到最终的停用。它类似于软件开发生命周期 (SDLC)&#xff0c;但专门针对微服务架构的独特需求进行定制。 以下分解了 MLM 中的关键阶段及其含义&#xff1a; 1. 设计…
阅读更多...
第10.2节-简历匹配性和表现力自查

第10.2节-简历匹配性和表现力自查

(点击即可收听) 多次投递简历却没有得到回复时&#xff0c;我们应该对自己的简历进行检查和评估&#xff0c;对比那些优秀的简历 找到自己的不足之处并进行修改。 优秀的简历是反复修改出来的&#xff0c;对于每一个需要靠简历找工作的求职者而言&#xff0c;没有完美的简历&am…
阅读更多...
【GoLang入门教程】Go语言几种标准库介绍(六)

【GoLang入门教程】Go语言几种标准库介绍(六)

文章目录 前言几种库Net库 (网络库&#xff0c;支持 Socket、HTTP、邮件、RPC、SMTP 等)重要的子包和功能&#xff1a;示例 OS库&#xff08;操作系统平台不依赖平台操作封装&#xff09;主要功能&#xff1a;示例 path库(兼容各操作系统的路径操作实用函数)常用函数&#xff1…
阅读更多...
wagtail的数据模型和渲染

wagtail的数据模型和渲染

文章目录 前言页面数据模型数据库字段部分搜索部分编辑面板基础面板结构化面板父页面/子页面类型规则页面URLs自定义页面模型的URL模式获取页面实例的URL 模板渲染为页面模型添加模板模板上下文自定义模板上下文更改模板动态选择模板Ajax 模板 内联模型在多个页面类型之间重用内…
阅读更多...
Hadoop之mapreduce参数大全-6

Hadoop之mapreduce参数大全-6

126.指定 Map 任务运行的节点标签表达式 mapreduce.map.node-label-expression 是 Hadoop MapReduce 框架中的一个配置属性&#xff0c;用于指定 Map 任务运行的节点标签表达式。节点标签是在 Hadoop 集群中为节点分配的用户定义的标签&#xff0c;可用于将 Map 任务限制在特定…
阅读更多...
Baumer工业相机堡盟工业相机如何通过NEOAPI SDK实现相机图像转换由Mono10转换为Mono8（C++）

Baumer工业相机堡盟工业相机如何通过NEOAPI SDK实现相机图像转换由Mono10转换为Mono8（C++）

Baumer工业相机堡盟工业相机如何通过NEOAPI SDK实现相机图像转换由Mono10转换为Mono8&#xff08;C&#xff09; Baumer工业相机Baumer工业相机的Mono10转换为Mono8图的技术背景在NEOAPI SDK里实现相机图像由Mono10转换为Mono8格式 工业相机通过NEOAPI SDK实现相机图像转换的优…
阅读更多...
Java入门高频考查基础知识1

Java入门高频考查基础知识1

Java语言是一种广泛应用于软件开发的高级编程语言&#xff0c;最初由Sun Microsystems于1995年发布。 以下是Java语言的一些特点和用途&#xff1a; 1. 跨平台性&#xff1a; Java是一种跨平台的编程语言&#xff0c;一次编写&#xff0c;到处运行&#xff08;Write Once, Run …
阅读更多...
在ubuntu上检查内存使用情况的九种方法

在ubuntu上检查内存使用情况的九种方法

在 Ubuntu 中&#xff0c;可以通过 GUI(图形用户界面)和命令行使用多种方法来监视系统的内存使用情况&#xff0c;监视 Ubuntu 服务器上的内存使用情况并不复杂&#xff1b;了解已使用和可用的内存量对于故障排除和优化服务器性能至关重要&#xff0c;因为内存对系统 I/O 速度至…
阅读更多...
最新文章

Copyright @ 2022~2023