Spring Boot 消息队列与异步处理

Ne0inhk

— 7 min read
Spring Boot 消息队列与异步处理

Spring Boot 消息队列与异步处理

在这里插入图片描述
28.1 学习目标与重点提示

学习目标：掌握Spring Boot消息队列与异步处理的核心概念与使用方法，包括消息队列的定义与特点、异步处理的定义与特点、Spring Boot与消息队列的集成、Spring Boot的实际应用场景，学会在实际开发中处理消息队列与异步处理问题。
重点：消息队列的定义与特点、异步处理的定义与特点、Spring Boot与消息队列的集成、Spring Boot的实际应用场景。

28.2 消息队列与异步处理概述

消息队列与异步处理是Java开发中的重要组件。

28.2.1 消息队列的定义

定义：消息队列是一种用于在不同应用程序之间传递消息的中间件，允许应用程序异步处理消息。
作用：

  • 提高应用程序的性能。
  • 提高应用程序的可靠性。
  • 实现应用程序之间的解耦。

常见的消息队列：

  • RabbitMQ：RabbitMQ是一种开源的消息队列。
  • ActiveMQ：ActiveMQ是一种开源的消息队列。
  • Kafka：Kafka是一种开源的消息队列。
  • Redis：Redis是一种开源的内存数据库，支持消息队列。

✅ 结论：消息队列是一种用于在不同应用程序之间传递消息的中间件，作用是提高应用程序的性能、可靠性、实现应用程序之间的解耦。

28.2.2 异步处理的定义

定义：异步处理是指应用程序在处理请求时，不阻塞主线程，而是将请求发送到消息队列，由其他线程或进程处理。
作用：

  • 提高应用程序的响应速度。
  • 提高应用程序的吞吐量。
  • 提高应用程序的可扩展性。

✅ 结论：异步处理是指应用程序在处理请求时，不阻塞主线程，作用是提高应用程序的响应速度、吞吐量、可扩展性。

28.3 Spring Boot与消息队列的集成

Spring Boot与消息队列的集成是Java开发中的重要内容。

28.3.1 集成RabbitMQ的步骤

定义：集成RabbitMQ的步骤是指使用Spring Boot与RabbitMQ集成的方法。
步骤：

  1. 创建Spring Boot项目。
  2. 添加所需的依赖。
  3. 配置RabbitMQ。
  4. 创建消息生产者。
  5. 创建消息消费者。
  6. 测试应用。

示例：
pom.xml文件中的依赖：

<dependencies><!-- Web依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- RabbitMQ依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency><!-- 测试依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies>

application.properties文件中的配置：

# 服务器端口 server.port=8080 # RabbitMQ连接信息 spring.rabbitmq.host=localhost spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.password=guest

消息生产者类：

importorg.springframework.amqp.rabbit.core.RabbitTemplate;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.stereotype.Component;@ComponentpublicclassProductMessageProducer{@AutowiredprivateRabbitTemplate rabbitTemplate;privatestaticfinalStringEXCHANGE_NAME="product-exchange";privatestaticfinalStringROUTING_KEY="product-routing-key";publicvoidsendProductMessage(String message){ rabbitTemplate.convertAndSend(EXCHANGE_NAME,ROUTING_KEY, message);System.out.println("消息已发送："+ message);}}

消息消费者类：

importorg.springframework.amqp.rabbit.annotation.RabbitListener;importorg.springframework.stereotype.Component;@ComponentpublicclassProductMessageConsumer{@RabbitListener(queues ="product-queue")publicvoidreceiveProductMessage(String message){System.out.println("消息已接收："+ message);// 处理消息的业务逻辑processProductMessage(message);}privatevoidprocessProductMessage(String message){// 模拟处理消息的业务逻辑try{Thread.sleep(2000);System.out.println("消息处理完成："+ message);}catch(InterruptedException e){ e.printStackTrace();}}}

RabbitMQ配置类：

importorg.springframework.amqp.core.Binding;importorg.springframework.amqp.core.BindingBuilder;importorg.springframework.amqp.core.DirectExchange;importorg.springframework.amqp.core.Queue;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;@ConfigurationpublicclassRabbitMQConfig{@BeanpublicDirectExchangeproductExchange(){returnnewDirectExchange("product-exchange");}@BeanpublicQueueproductQueue(){returnnewQueue("product-queue");}@BeanpublicBindingproductBinding(Queue productQueue,DirectExchange productExchange){returnBindingBuilder.bind(productQueue).to(productExchange).with("product-routing-key");}}

控制器类：

importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.web.bind.annotation.*;@RestController@RequestMapping("/api/products")publicclassProductController{@AutowiredprivateProductMessageProducer productMessageProducer;@PostMapping("/send")publicStringsendProductMessage(@RequestBodyString message){ productMessageProducer.sendProductMessage(message);return"消息已发送";}}

应用启动类：

importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplicationpublicclassRabbitMQApplication{publicstaticvoidmain(String[] args){SpringApplication.run(RabbitMQApplication.class, args);}}

测试类：

importorg.junit.jupiter.api.Test;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.boot.test.context.SpringBootTest;importorg.springframework.boot.test.web.client.TestRestTemplate;importorg.springframework.boot.web.server.LocalServerPort;importstaticorg.assertj.core.api.Assertions.assertThat;@SpringBootTest(webEnvironment =SpringBootTest.WebEnvironment.RANDOM_PORT)classRabbitMQApplicationTests{@LocalServerPortprivateint port;@AutowiredprivateTestRestTemplate restTemplate;@TestvoidcontextLoads(){}@TestvoidtestSendProductMessage(){String message ="Hello, RabbitMQ!";String response = restTemplate.postForObject("http://localhost:"+ port +"/api/products/send", message,String.class);assertThat(response).contains("消息已发送");}}

✅ 结论：集成RabbitMQ的步骤包括创建Spring Boot项目、添加所需的依赖、配置RabbitMQ、创建消息生产者、创建消息消费者、测试应用。

28.4 Spring Boot的实际应用场景

在实际开发中，Spring Boot消息队列与异步处理的应用场景非常广泛，如：

  • 实现产品信息的异步处理。
  • 实现用户信息的异步处理。
  • 实现订单信息的异步处理。
  • 实现支付信息的异步处理。

示例：

importorg.springframework.amqp.rabbit.core.RabbitTemplate;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.stereotype.Component;@ComponentclassProductMessageProducer{@AutowiredprivateRabbitTemplate rabbitTemplate;privatestaticfinalStringEXCHANGE_NAME="product-exchange";privatestaticfinalStringROUTING_KEY="product-routing-key";publicvoidsendProductMessage(String message){ rabbitTemplate.convertAndSend(EXCHANGE_NAME,ROUTING_KEY, message);System.out.println("消息已发送："+ message);}}importorg.springframework.amqp.rabbit.annotation.RabbitListener;importorg.springframework.stereotype.Component;@ComponentclassProductMessageConsumer{@RabbitListener(queues ="product-queue")publicvoidreceiveProductMessage(String message){System.out.println("消息已接收："+ message);processProductMessage(message);}privatevoidprocessProductMessage(String message){try{Thread.sleep(2000);System.out.println("消息处理完成："+ message);}catch(InterruptedException e){ e.printStackTrace();}}}importorg.springframework.amqp.core.Binding;importorg.springframework.amqp.core.BindingBuilder;importorg.springframework.amqp.core.DirectExchange;importorg.springframework.amqp.core.Queue;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;@ConfigurationclassRabbitMQConfig{@BeanpublicDirectExchangeproductExchange(){returnnewDirectExchange("product-exchange");}@BeanpublicQueueproductQueue(){returnnewQueue("product-queue");}@BeanpublicBindingproductBinding(Queue productQueue,DirectExchange productExchange){returnBindingBuilder.bind(productQueue).to(productExchange).with("product-routing-key");}}importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.web.bind.annotation.*;@RestController@RequestMapping("/api/products")classProductController{@AutowiredprivateProductMessageProducer productMessageProducer;@PostMapping("/send")publicStringsendProductMessage(@RequestBodyString message){ productMessageProducer.sendProductMessage(message);return"消息已发送";}}@SpringBootApplicationpublicclassRabbitMQApplication{publicstaticvoidmain(String[] args){SpringApplication.run(RabbitMQApplication.class, args);}}// 测试类@SpringBootTest(webEnvironment =SpringBootTest.WebEnvironment.RANDOM_PORT)classRabbitMQApplicationTests{@LocalServerPortprivateint port;@AutowiredprivateTestRestTemplate restTemplate;@TestvoidcontextLoads(){}@TestvoidtestSendProductMessage(){String message ="Hello, RabbitMQ!";String response = restTemplate.postForObject("http://localhost:"+ port +"/api/products/send", message,String.class);assertThat(response).contains("消息已发送");}}

输出结果：

  • 访问http://localhost:8080/api/products/send，发送消息“Hello, RabbitMQ!”。
  • 控制台输出：消息已发送：Hello, RabbitMQ!。
  • 消费者控制台输出：消息已接收：Hello, RabbitMQ!，2秒后输出：消息处理完成：Hello, RabbitMQ!。

✅ 结论：在实际开发中，Spring Boot消息队列与异步处理的应用场景非常广泛，需要根据实际问题选择合适的消息队列和异步处理方法。

总结

本章我们学习了Spring Boot消息队列与异步处理，包括消息队列的定义与特点、异步处理的定义与特点、Spring Boot与消息队列的集成、Spring Boot的实际应用场景，学会了在实际开发中处理消息队列与异步处理问题。其中，消息队列的定义与特点、异步处理的定义与特点、Spring Boot与消息队列的集成、Spring Boot的实际应用场景是本章的重点内容。从下一章开始，我们将学习Spring Boot的其他组件、微服务等内容。

Read more

当Python遇见高德：基于PyQt与JS API构建桌面三维地形图应用实战

当Python遇见高德：基于PyQt与JS API构建桌面三维地形图应用实战

摘要： 地图技术作为数字化世界的基石，其应用早已超越了传统的导航和位置服务。对于开发者而言，如何将强大的地图能力集成到不同形态的应用中，是一个充满挑战与机遇的课题。本文将详细阐述一个独特的实践案例：如何利用Python的PyQt5框架，结合高德开放平台强大的JavaScript API 2.1Beta，从零开始构建一个功能丰富的桌面端地图浏览器。项目不仅实现了二维、三维、卫星、地形等多种地图样式的动态切换，还集成了地点搜索（POI）、实时标记等核心功能。本文将深入探讨技术选型、架构设计、核心功能实现、Python与JavaScript双向通信机制，并在此基础上拓展实现“点击获取坐标与地址（逆地理编码）”及“路线规划”等高级功能，旨在为开发者提供一个将Web地图技术无缝融入桌面应用的完整解决方案，展现高德开放平台在跨技术栈融合应用中的卓越潜力。 一、 引言：为何选择在桌面端构建地图应用？ 在移动互联网和Web应用大行其道的今天，探讨桌面地图应用的开发似乎有些“复古”。然而，在特定业务场景下，桌面应用依然拥有不可替代的优势。例如，在专业地理信息系统（GIS）、行业数据监控中心、复杂的

By Ne0inhk

【Python】tavily 库： 与 Tavily 搜索 API 交互的工具

Python 的 tavily 库（tavily-python）是一个用于与 Tavily 搜索 API 交互的 Python 包装器，旨在为 AI 代理和大型语言模型（LLMs）提供实时、准确的 Web 搜索和内容提取功能。它由 Tavily AI 开发，支持同步和异步客户端，适合集成到 Python 应用程序中以增强搜索、问答和内容爬取能力。以下是对 tavily 库的详细介绍，内容以中文输出，结构清晰有序，涵盖定义、安装、核心功能、使用方法、性能、适用场景、注意事项及最佳实践，基于官方文档和相关资源（如 Tavily Docs 和 tavily-python · PyPI）。 1. 什么是

By Ne0inhk

C++初学者的学习进程（指针）

对于C++新手来说，指针无疑是入门路上的“拦路虎”。很多人刚接触时会被“*”“&”搞得晕头转向，甚至觉得指针“反人类”。但实际上，指针的核心逻辑非常简单——它就是一个“存储内存地址的变量”。今天这篇文章，我们就从最基础的概念开始，一步步拆解C++指针的基础知识，搭配大量可直接运行的代码示例，让你彻底搞懂指针的本 一、先搞懂核心：指针到底是什么？ 在讲解指针之前，我们先回顾一个基础概念：变量在内存中的存储。 当我们在C++中定义一个变量（比如int a = 10;）时，计算机会在内存中开辟一块“存储空间”来存放这个变量的值（10）。而这块存储空间有一个唯一的“编号”，这个编号就是内存地址（类似我们的身份证号，唯一标识一块内存区域）。 而指针，本质上就是一个专门用来存储内存地址的变量。普通变量存储的是“数据本身”（比如a存储10），指针变量存储的是“数据所在的内存地址”（比如指针p存储a的地址）。 用一个通俗的比喻理解： * 普通变量（

By Ne0inhk
【C++：红黑树】深入理解红黑树的平衡之道：从原理、变色、旋转到完整实现代码

【C++：红黑树】深入理解红黑树的平衡之道：从原理、变色、旋转到完整实现代码

🔥艾莉丝努力练剑：个人主页 ❄专栏传送门：《C语言》、《数据结构与算法》、C/C++干货分享&学习过程记录、Linux操作系统编程详解、笔试/面试常见算法：从基础到进阶、测试开发要点全知道 ⭐️为天地立心，为生民立命，为往圣继绝学，为万世开太平 🎬艾莉丝的简介： 🎬艾莉丝的C++专栏简介： 目录 C++的两个参考文档 1  ~>  初识红黑树：概念熟悉 2 ~>  了解红黑树规则 2.1  红黑树的四条规则 2.1.1  红黑树规则 2.1.2  结合图示，体会红黑树规则 2.1.3  结合图例，理解红黑树的路径数量问题：NIL

By Ne0inhk