本文详解在使用Resilience4J CircuitBreaker 包裹远程服务调用时，如何确保JUnit测试能成功捕获被调用方法的入参——关键在于避免熔断器拦截真实调用，需为测试单独配置始终处于CLOSED状态的熔断器实例。
本文详解在使用resilience4j `circuitbreaker` 包裹远程服务调用时，如何确保junit测试能成功捕获被调用方法的入参——关键在于避免熔断器拦截真实调用，需为测试单独配置始终处于closed状态的熔断器实例。
在集成Resilience4J熔断器（如CircuitBreaker）的业务逻辑中，customerService.save(person) 方法看似简单，但其内部通过 circuitBreaker.run(...) 执行 personClient.sendPerson(person)。这导致标准Mockito测试失效：熔断器可能因初始状态（如OPEN或HALF_OPEN）直接跳过函数执行，从而不触发personClient.sendPerson()，造成verify()失败——即“Wanted but not invoked”错误。
根本原因并非ArgumentCaptor失效，而是sendPerson()根本未被调用。CircuitBreaker.run()仅在熔断器处于CLOSED状态时才会执行第一个参数（Supplier
✅ 正确解法：为测试提供一个可控、始终开放的熔断器实例，而非复用生产配置或@Mock空实现。
推荐实践：使用CircuitBreakerRegistry创建测试专用熔断器
@SpringBootTest
class CustomerServiceImplTest {
@Autowired
private CircuitBreakerRegistry circuitBreakerRegistry; // 注入真实Registry
@InjectMocks
private CustomerServiceImpl customerService;
@Mock
private PersonClient personClient;
private CircuitBreaker testCircuitBreaker;
@BeforeEach
void setUp() {
// 创建独立的测试熔断器（名称需与代码中create("circuitBreaker")一致）
testCircuitBreaker = circuitBreakerRegistry.circuitBreaker("circuitBreaker");
// 强制置为CLOSED状态，确保每次调用都穿透执行
testCircuitBreaker.transitionToClosedState();
// 将测试熔断器注入目标服务（若service中通过@Autowired注入，需用ReflectionTestUtils）
ReflectionTestUtils.setField(customerService, "circuitBreaker", testCircuitBreaker);
}
@Test
void savePerson() {
Person person = new Person("Alice", 20);
// 配置mock行为（注意：返回值应匹配实际方法签名，如ResponseEntity>）
when(personClient.sendPerson(any(Person.class)))
.thenReturn(ResponseEntity.ok().build());
customerService.save(person);
// ✅ 现在verify可成功：sendPerson已被实际调用
verify(personClient).sendPerson(argThat(p ->
"Alice".equals(p.getName()) && 20 == p.getAge()
));
// 或配合ArgumentCaptor进行更灵活断言
ArgumentCaptor<person> captor = ArgumentCaptor.forClass(Person.class);
verify(personClient).sendPerson(captor.capture());
assertThat(captor.getValue().getName()).isEqualTo("Alice");
assertThat(captor.getValue().getAge()).isEqualTo(20);
}
}</person>
关键注意事项：
- 勿@Mock CircuitBreaker：@Mock会生成无行为的空对象，run()调用不会执行sendPerson，fallback也未必触发（取决于Mock配置），导致测试不可靠。
- 熔断器名称必须匹配：circuitBreakerRegistry.circuitBreaker("xxx") 中的xxx必须与生产代码中factory.create("xxx")的名称完全一致（本例为"circuitBreaker"）。
- transitionToClosedState()是核心：它重置熔断器状态，确保首次调用即穿透。也可在@BeforeEach中调用reset()后再transitionToClosedState()以彻底清除历史统计。
- 依赖注入方式适配：若CircuitBreaker通过构造器注入，应在@BeforeEach中重建CustomerServiceImpl实例并传入testCircuitBreaker；若为字段注入（如本例），使用ReflectionTestUtils.setField()安全替换。
- 避免静态/全局状态污染：每个测试用例应独立管理熔断器状态，@BeforeEach中初始化可保证隔离性。
通过上述方案，你既能保留熔断逻辑的真实语义，又能让单元测试精准验证参数传递与服务交互行为，真正实现“可测即可靠”。
