Spring-Cloud-Aws

1、概览 消息确认是 MQ 系统中的一种标准机制，它向 Message Broker 发出信号，表明消息已被消费，不应再次传递。在亚马逊的 SQS（Simple Queue Servic）中，确认是通过删除队列中的信息来执行的。 本文将带你了解 Spring Cloud AWS SQS v3 中开箱即提供的三种确认模式： ON_SUCCESS、MANUAL 和 ALWAYS。 本文将利用 Spring Cloud AWS SQS V3 入门文章 中的环境和测试设置，使用事件驱动场景来说明用例。 2、依赖 首先，导入 Spring Cloud AWS BOM，以确保 pom.xml 中的所有依赖项相互兼容： <dependencyManagement> <dependencies> <dependency> <groupId>io.awspring.cloud</groupId> <artifactId>spring-cloud-aws</artifactId> <version>3.1.0</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> 还要添加 Core 和 SQS starter 依赖： <dependency> <groupId>io.awspring.cloud</groupId> <artifactId>spring-cloud-aws-starter-sqs</artifactId> </dependency> <dependency> <groupId>io.awspring.cloud</groupId> <artifactId>spring-cloud-aws-starter</artifactId> </dependency> 最后，添加测试所需的依赖，即带有 JUnit 5 的 LocalStack 和 TestContainers、用于验证异步消息消费的 awaitility 库，以及用于处理断言的 AssertJ：

1、概览 Spring Cloud AWS 是一个旨在简化与 AWS 服务交互的项目。SQS（Simple Queue Service）是 AWS 的一种解决方案，用于以可扩展的方式发送和接收异步消息。 本文将带你了解针对于 Spring Cloud AWS 3.0 完全重写的 Spring Cloud AWS SQS Integration。 该框架为处理 SQS 队列提供了熟悉的 Spring 抽象，如 SqsTemplate 和 @SqsListener 注解。 本文以一个事件驱动的场景为例，介绍了如何发送和接收消息。并展示使用 Testcontainers（一种管理一次性 Docker 容器的工具）和 LocalStack（可在本地模拟类似 AWS 的环境，用于测试）设置集成测试的策略。 2、依赖 Spring Cloud AWS BOM 可确保项目之间的版本兼容。它声明了包括 Spring Boot 在内的许多依赖项的版本。 添加 Spring Cloud AWS BOM 到 pom.xml： <dependencyManagement> <dependencies> <dependency> <groupId>io.awspring.cloud</groupId> <artifactId>spring-cloud-aws</artifactId> <version>3.0.4</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> 我们需要的主要依赖关系是 SQS Starter，它包含项目中所有与 SQS 相关的类。SQS Integration 不依赖于 Spring Boot，可在任何标准 Java 应用中独立使用：