如何验证org.springframework.integration.dsl.IntegrationFlow中处理器执行顺序？

当然有可行的测试技术来验证处理器的执行顺序，以下是几种实用方案：

1. 自定义Mock处理器记录执行顺序 #

这是最直接的方式，通过替换真实处理器为Mock实现，记录每个处理器的调用顺序：

• 实现一个带名称和执行顺序列表的MockHandler，每次执行时将自身名称加入列表
• 构建测试用的IntegrationFlow，替换原有的handler1、handler2、handler3为Mock实例
• 发送测试消息到输入通道，最后断言执行顺序列表严格匹配handler1 -> handler2 -> handler3

示例代码：

@Test
void testHandlerExecutionOrder() {
    List<String> executionOrder = Collections.synchronizedList(new ArrayList<>());

    MockHandler mockHandler1 = new MockHandler("handler1", executionOrder);
    MockHandler mockHandler2 = new MockHandler("handler2", executionOrder);
    MockHandler mockHandler3 = new MockHandler("handler3", executionOrder);

    // 构建测试用的IntegrationFlow
    IntegrationFlow testFlow = IntegrationFlows.from(PUBLISH_DATA)
            .enrichHeaders(h -> h.header("replyChannel", "nullChannel"))
            .handle((p, h) -> GenericTransformer.transform(p))
            .handle(mockHandler1)
            .handle(mockHandler2)
            .handle(mockHandler3)
            .get();

    // 注册并启动测试Flow
    this.applicationContext.registerBean("testPublishData", IntegrationFlow.class, () -> testFlow);
    IntegrationFlowContext flowContext = this.applicationContext.getBean(IntegrationFlowContext.class);
    flowContext.registration(testFlow).register();

    // 发送测试消息
    MessageChannel inputChannel = this.applicationContext.getBean(PUBLISH_DATA, MessageChannel.class);
    inputChannel.send(MessageBuilder.withPayload("test").build());

    // 断言执行顺序符合预期
    assertThat(executionOrder).containsExactly("handler1", "handler2", "handler3");
}

// 自定义Mock处理器
static class MockHandler implements GenericHandler<Object> {
    private final String name;
    private final List<String> executionOrder;

    MockHandler(String name, List<String> executionOrder) {
        this.name = name;
        this.executionOrder = executionOrder;
    }

    @Override
    public Object handle(Object payload, MessageHeaders headers) {
        executionOrder.add(name);
        return payload;
    }
}

2. 利用Spring Integration测试框架跟踪消息轨迹 #

借助Spring Integration提供的测试工具，可以更优雅地跟踪消息流转：

• 使用MockIntegrationContext将真实处理器替换为代理，在代理中添加跟踪逻辑
• 可以通过自定义消息头（如execution-step）记录当前执行的处理器名称
• 最终验证消息经过的处理器顺序是否符合预期

3. 日志断言（适合快速验证） #

如果处理器本身带有唯一标识的日志输出，可以通过捕获日志来验证顺序：

• 确保每个handler执行时输出唯一的日志（如log.info("Executing [handler1]")）
• 使用日志框架的测试工具（如Logback的ListAppender）收集测试期间的日志
• 断言日志条目出现的顺序严格对应handler1 -> handler2 -> handler3

内容的提问来源于stack exchange，提问作者Ivan Karotki