1、简介 本文将带你了解如何测试启用了定时任务（@EnableScheduling）的 Spring 应用，以及如何在测试过程中禁用定时任务。
2、示例 首先来看一个示例，假设我们有一个系统，允许公司的代表向客户发送通知。其中一些通知是时间敏感的，应该立即发送，但有些通知应该等到下一个工作日再发送。因此，我们需要一个机制来定期尝试发送这些通知：
public class DelayedNotificationScheduler { private NotificationService notificationService; @Scheduled(fixedDelayString = "${notification.send.out.delay}", initialDelayString = "${notification.send.out.initial.delay}") public void attemptSendingOutDelayedNotifications() { notificationService.sendOutDelayedNotifications(); } } attemptSendingOutDelayedNotifications() 方法上添加了 @Scheduled 注解。当 initialDelayString 配置的时间过去后，该方法将被首次调用。执行结束后，Spring 会在 fixedDelayString 参数配置的时间过后再次调用该方法。该方法本身将实际逻辑委托给了 NotificationService。
当然，我们还需要开启调度功能。为此，需要在 @Configuration 类上添加 @EnableScheduling 注解。
3、集成测试中定时任务的问题 首先，为通知应用编写一个基本的集成测试：
@SpringBootTest( classes = { ApplicationConfig.class, SchedulerTestConfiguration.class }, properties = { "notification.send.out.delay: 10", "notification.send.out.initial.delay: 0" } ) public class DelayedNotificationSchedulerIntegrationTest { @Autowired private Clock testClock; @Autowired private NotificationRepository repository; @Autowired private DelayedNotificationScheduler scheduler; @Test public void whenTimeIsOverNotificationSendOutTime_thenItShouldBeSent() { ZonedDateTime fiveMinutesAgo = ZonedDateTime.
1、概览 本文将带你了解如何测试 Spring Application Event，以及如何使用 Spring Modulith 的测试库。
2、Application Event Spring 提供了 Application Event（观察者设计模式），允许组件在保持松散耦合的同时相互通信。我们可以使用 ApplicationEventPublisher Bean 发布内部事件，这些事件都是纯 Java 对象，所有已注册的监听器（Listener）都会收到通知。
例如，当成功创建 Order 时，OrderService 组件可以发布 OrderCompletedEvent：
@Service public class OrderService { private final ApplicationEventPublisher eventPublisher; // 构造函数 public void placeOrder(String customerId, String... productIds) { Order order = new Order(customerId, Arrays.asList(productIds)); // 验证和下单的业务逻辑 OrderCompletedEvent event = new OrderCompletedEvent(savedOrder.id(), savedOrder.customerId(), savedOrder.timestamp()); eventPublisher.publishEvent(event); } } 把 OrderCompletedEvent 对象作为应用事件发布，不同模块中监听这些事件的组件会收到通知。
假设 LoyaltyPointsService 会对这些事件做出反应，以奖励下单客户积分。要实现这一点，可以使用 Spring 的 @EventListener 注解：
1、简介 本文将带你了解 Spring 中 @Transactional 和 @Async 注解之间的兼容性。
2、 了解 @Transactional 和 @Async @Transactional 注解是 Spring 提供的声明式事务注解。可以让多个业务方法在同一个事务中执行，只有所有方法都正常执行完毕后事务才会提交。如果任何一个方法在调用过程中抛出了异常，那么事务就会回滚。
@Async 注解用于执行异步任务，如果从一个线程调用 @Async 方法或类，Spring 会使用另一个线程来运行该方法，从而提高执行效率。
在有些情况下，我们需要在代码中同时使用 @Transactional 和 @Async 来保业务数据的一致性以及性能。
3、@Transactional 能和 @Async 一起用吗？ 异步 和 事务 如果使用不当，可能会带来数据不一致等问题。
关于这一点，需要充分了解 Spring 的事务上下文和上下文之间的数据传播。
3.1、创建示例应用 本文使用银行的转账功能来说明事务和异步代码的使用。简而言之，是一个转账的场景，从一个账户中扣除资金并将其添加到另一个账户。
我们可以把它想象成数据库操作，比如 select 相关账户并 update 其资金余额：
public void transfer(Long depositorId, Long favoredId, BigDecimal amount) { Account depositorAccount = accountRepository.findById(depositorId) .orElseThrow(IllegalArgumentException::new); Account favoredAccount = accountRepository.findById(favoredId) .orElseThrow(IllegalArgumentException::new); depositorAccount.setBalance(depositorAccount.getBalance().subtract(amount)); favoredAccount.setBalance(favoredAccount.getBalance().add(amount)); accountRepository.save(depositorAccount); accountRepository.save(favoredAccount); } 首先使用 findById() 查找相关账户，如果给定 ID 的账户不存在，则抛出 IllegalArgumentException 异常。
1、概览 本文将带你了解如何在 Spring 中使用运行时参数创建一个 Prototype Scope Bean。
在 Spring 中，有许多不同的 Bean Scope，默认的 Scope 是 Singleton（单例）。Singleton Scope 的 Bean 将始终产生相同的对象。
如果每次都需要从容器中获得一个新实例，可以使用 Pototype Scope Bean。然而，在大多数情况下，如果我们想要从一个 Singleton Bean 实例化 Pototype Bean，或者将动态参数传递给 Pototype Bean，可能会遇到一些问题。
2、使用动态参数创建 Prototype Bean 有时，我们需要在每次初始化时将动态参数作为输入来初始化 Spring Bean。通过 Spring，可以使用多种方法为 Prototype Bean 分配不同的动态参数。
首先，创建一个 Prototype Bean Employee ：
public class Employee { private String name; public Employee(String name) { this.name = name; } public void printName() { System.out.println(name); } } 为 Employee Prototype Bean 创建一个配置：
1、概览 本文将带你了解如何根据自定义属性动态注册 Bean。
主要是学习 BeanDefinitionRegistryPostProcessor 接口，以及如何使用它将 Bean 添加到 Application Context 中。
2、设置 创建一个简单的 Spring Boot 应用。
首先，定义一个要动态注册的 Bean。然后，提供一个属性来决定如何注册 Bean。最后，定义一个配置类，它将根据自定义属性注册 Bean。
2.1、依赖 添加 Maven 依赖：
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> <version>3.2.3</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <version>3.2.3</version> <scope>test</scope> </dependency> 添加 spring-boot-starter 和 spring-boot-starter-test 依赖。
2.2、Bean 类 接下来，根据自定义 application properties 定义要注册的 ApiClient：
public class ApiClient { private String name; private String url; private String key; // Getter、Setter 和构造函数 public String getConnectionProperties() { return "Connecting to " + name + " at " + url; } } 假设我们希望根据提供的属性使用这个 Bean 连接到不同的 API。我们不想为每个 API 创建类定义，而是希望动态地为每个 API 定义属性并注册该 Bean。
1、概览 缓存数据意味着我们的应用无需访问速度较慢的存储层，从而提高了性能和响应速度。我们可以使用任何内存实现库（如 Caffeine）来实现缓存。
虽然这样做可以提高数据检索的性能，但如果应用部署在多个副本上，那么实例之间就无法共享缓存。为了解决这个问题，可以引入一个分布式缓存层，所有实例都可以访问它。
本文将带你了解如何在 Spring 中使用 Spring 的缓存支持（spring-cache）实现两级缓存，以及在本地缓存层缓存失效时如何调用分布式缓存层。
2、示例 Spring Boot 应用 创建一个简单的应用，调用数据库获取一些数据。
2.1、Maven 依赖 首先，添加 spring-boot-starter-web 依赖：
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> <version>3.1.5</version> </dependency> 2.2、实现 Service 实现一个 Spring Service，从 Repository 中获取数据。
首先，创建 Customer 实体类：
public class Customer implements Serializable { private String id; private String name; private String email; // 标准 Getter / Setter } 然后，实现 CustomerService 类和 getCustomer 方法：
@Service public class CustomerService { private final CustomerRepository customerRepository; public Customer getCustomer(String id) { return customerRepository.
1、简介 Servlet Filter（过滤器）为拦截和处理传入的请求提供了强大的机制。
本文将会带你了解在 Servlet Filter 中无缝获取 Spring Bean 的各种方法，这种需求在 Spring Web 应用中很常见。
2、Servlet Filter 中 @Autowired 的限制 Spring 的依赖注入机制 @Autowired，是一种方便的方式来将依赖注入到由 Spring 管理的组件中。但它无法与 Servlet Filter 完美配合。这是因为 Servlet Filter 是由 Servlet 容器初始化的，通常是在 Spring 的 ApplicationContext 完全加载和初始化之前 。
因此，当容器实例化 Servlet Filter 时 ，Spring Context 可能尚未可用，从而导致在尝试使用 @Autowired 注解时 ，依赖为 null 或未初始化。
3、项目设置 创建一个通用的 LoggingService，它将自动装配到 Filter 中：
@Service public class LoggingService { private final Logger logger = LoggerFactory.getLogger(this.getClass()); public void log(String message,String url){ logger.info("Logging Request {} for URI : {}",message,url); } } 然后，创建 Filter，拦截传入的 HTTP 请求，并使用 LoggingService 依赖记录 HTTP 方法和 URI 的详细信息：
1、概览 Aspect-Oriented Programming（面向切面编程，简称 AOP）是一种范式，它能让我们在整个应用中隔离事务管理或日志记录等交叉问题，而不会干扰业务逻辑。
本文将带你了解如何在 Spring 中使用 AOP 记录执行日志。
2、不使用 AOP 记录日志 通常，我们会在方法的开始和结束处输出日志。这样，就能跟踪应用的执行流程。此外，还可以捕获传递给特定方法的值及其返回值。
示例如下：
public String greet(String name) { logger.debug(">> greet() - {}", name); String result = String.format("Hello %s", name); logger.debug("<< greet() - {}", result); return result; } 尽管上面的实现看起来是一个标准的解决方案，但日志语句在代码中增加了复杂性。
如果没有日志记录，只需要一行代码就可以完成：
public String greet(String name) { return String.format("Hello %s", name); } 3、面向切面（AOP）编程 顾名思义，面向切面的编程（Aspect-Oriented Programming）侧重于切面，而不是对象和类。我们可以使用 AOP 编程为特定应用实现额外功能，而无需修改其当前实现。
3.1、AOP 概念 在深入学习之前，让我们先从高层次来了解一下 AOP 的基本概念。
切面（Aspect）：横切关注点或我们希望在整个应用中应用的功能。 连接点（Join Point）：应用流程中我们希望应用切面的点。 Advice：在特定连接点应执行的操作。 Pointcut：应在其中应用某一切面的连接点集合。 另外，Spring AOP 仅支持方法执行的连接点。可以考虑使用 AspectJ 等编译时库为字段、构造函数、静态初始化器等创建切面。
1、概览 本文将带你了解如何在 Spring WebClient 中自定义 JSON 的反序列化（Deserialization）。
2、为什么需要自定义反序列化？ Spring WebFlux 模块中的 Spring WebClient 通过 Encoder 和 Decoder 组件处理序列化和反序列化。编码器（Encoder）和解码器（Decoder）是表示读取和写入内容的接口。默认情况下，spring-core 模块提供 byte[]、ByteBuffer、DataBuffer、Resource 和 String 编码器和解码器实现。
Jackson 是一个 JSON 库，它通过 ObjectMapper 将 Java 对象序列化为 JSON，并将 JSON 字符串反序列化为 Java 对象。ObjectMapper 包含内置的配置选项，可以使用 Deserialization Feature 进行开启或关闭。
当 Jackson 库提供的默认行为无法满足我们的特定需求时，就有必要定制反序列化过程。为了在序列化和反序列化过程中修改行为，ObjectMapper 提供了一系列配置选项供我们设置。因此，我们需要将这个自定义的 ObjectMapper 注册到 Spring WebClient 中，以便在序列化和反序列化中使用。
3、如何自定义 ObjectMapper？ 自定义 ObjectMapper 可以在全局应用程序级别与 WebClient 关联，也可以与特定请求关联。
以一个获取客户订单详细信息的 GET 端点为例。
OrderResponse Model 如下：
{ "orderId": "a1b2c3d4-e5f6-4a5b-8c9d-0123456789ab", "address": [ "123 Main St", "Apt 456", "Cityville" ], "orderNotes": [ "Special request: Handle with care", "Gift wrapping required" ], "orderDateTime": "2024-01-20T12:34:56" } 对于上述响应的一些反序列化规则如下：
1、简介 gRPC 是一个高性能的开源 RPC 框架，最初由谷歌开发。它有助于消除样板代码，并在数据中心内外连接多语言服务。该 API 基于 Protocol Buffer，它提供了一个 protoc 编译器，用于生成不同支持的语言的代码。
我们可以将 gRPC 视为 REST、SOAP 或 GraphQL 的替代品，它建立在 HTTP/2 的基础上，可以使用多路复用或流式连接等功能。
本文将带你了解如何使用 Spring Boot 实现 gRPC 服务提供者和消费者。
2、面临的问题 首先，Spring Boot 并不直接支持 gRPC。它只支持 Protocol Buffer，允许我们实现基于 protobuf 的 REST 服务。因此，需要通过使用第三方库来加入 gRPC：
平台相关的编译器：protoc 编译器是平台相关的。因此，如果在构建过程中需要生成存根（Stub），构建过程会变得更加复杂且容易出错。 依赖： 需要在 Spring Boot 应用中添加兼容的依赖。不幸的是，Java 的 protoc 添加了 javax.annotation.Generated 注解（Issues），这迫使我们需要添加一个依赖项来编译旧的 Java EE 注解库。 服务器运行时：gRPC 服务提供者需要在服务器中运行。gRPC for Java 项目提供了一个 shaded Netty，我们需要将其包含在 Spring Boot 应用中，或者用 Spring Boot 已经提供的服务器来代替。 消息传输： Spring Boot 提供了不同的客户端，如 RestClient（阻塞）或 WebClient（非阻塞），但遗憾的是，这些客户端无法配置和用于 gRPC，因为 gRPC 在阻塞和非阻塞调用中都使用了 自定义 transport 技术。 配置： 由于 gRPC 使用了自己的技术，我们需要配置属性以按照 Spring Boot 的方式对其进行配置。 3、示例项目 幸运的是，可以使用第三方 Spring Boot Starter 来应对这些挑战，例如 LogNet 或 grpc ecosystem project。这两个 Starter 都很容易整合，但后者同时支持提供者和消费者以及许多其他集成功能，因此本文选择了后者。
