在使用 junit 测试含回调参数的方法时，需借助异步协调机制（如 completablefuture）捕获回调执行结果，从而对回调内部逻辑进行断言验证。
在集成测试或单元测试中，当被测方法接收一个回调（如 SoapActionCallback）作为参数，并在内部异步或延迟触发其 doWithMessage() 方法时，传统同步断言无法直接覆盖回调体内的逻辑——因为测试主线程往往在回调执行前就已结束。此时，推荐采用 CompletableFuture 作为线程安全的信号机制，将回调的执行“桥接”回测试主线程。
核心思路是：在回调创建前初始化一个 CompletableFuture，在回调体中调用 complete() 或 completeExceptionally() 传入实际参数或异常；随后在测试主流程中通过 get(timeout, unit) 阻塞等待结果，并进行断言。
以下是一个可直接复用的示例：
@Test
public void testMarshallWithSoapCallback() throws Exception {
// 准备测试依赖（如 mock template）
SoapTemplate template = mock(SoapTemplate.class);
// 注意：此处假设 marshall 方法实际会触发回调（真实场景需确保 template 行为符合预期）
final CompletableFuture<MyMessageClass> callbackFuture = new CompletableFuture<>();
JAXBElement<MyCustomObject> result = (JAXBElement<MyCustomObject>) template.marshall(
"some string",
new SoapActionCallback("some string") {
@Override
public void doWithMessage(MyMessageClass message) {
// ✅ 回调触发时，立即将 message 提交至 future
callbackFuture.complete(message);
}
}
);
// 等待回调完成（建议设置合理超时，避免测试永久挂起）
MyMessageClass actualMessage = callbackFuture.get(5, TimeUnit.SECONDS);
// ✅ 对回调中处理的 message 进行断言
assertNotNull(actualMessage);
assertThat(actualMessage.getHeader().getAction()).isEqualTo("some string");
// 其他业务相关断言...
}⚠️ 注意事项：
- 超时设置必须合理：get(5, SECONDS) 可防止因回调未触发导致测试无限等待；若回调本应立即执行，200–500ms 足够；若涉及网络/IO，需按实际场景调整。
- 异常处理不可忽略：若回调中可能抛出异常，应在 doWithMessage 内捕获并调用 callbackFuture.completeExceptionally(e)，测试中用 assertThrows() 验证。
- 避免过度依赖真实模板：生产代码中 template.marshall(...) 往往涉及 SOAP 通信，单元测试应 mock 该 template 并手动触发回调（例如：callback.doWithMessage(mockMessage)），以实现纯单元测试；上述示例中若使用真实 template，则更偏向集成测试。
- 线程安全性：CompletableFuture 本身线程安全，适用于多线程回调场景，无需额外同步。
总结：CompletableFuture 是协调回调测试的轻量、标准且 JDK 原生支持的方案。它将“被动等待回调”转化为主动“拉取结果”，使 JUnit 测试能精准覆盖 doWithMessage 中的每行业务逻辑，显著提升测试覆盖率与可维护性。
