如何测试Spring Integration Transformer？求当前标准测试方法

问题描述 #

你具备Spring开发基础，刚接触Spring Integration，已编写如下转换器：

@Transformer(inputChannel = "signering", outputChannel = "validering")

测试时配置了通道注入：

@Autowired
MessageChannel signering;

@Autowired
PollableChannel validering;

调用signering.send(msg.build())后，消息直接流向真实的validering下游Bean，无法通过validering.receive()拦截输出消息，且网上多为旧XML配置的测试示例，需要当前基于注解的正确测试方案。

方法1：用@MockMessageChannel替换真实输出通道 #

Spring Integration Test模块提供了专门的测试工具，可直接替换生产通道为测试用可拦截通道：

1. 确保引入spring-integration-test依赖
2. 在测试类中替换目标通道：

@SpringBootTest
@Import(TestChannelInterceptorConfiguration.class)
public class TransformerTest {

    @Autowired
    MessageChannel signering;

    @MockMessageChannel("validering")
    private PollableChannel testValidering;

    @Test
    void testTransformer() {
        // 构建测试消息
        Message<String> msg = MessageBuilder.withPayload("test payload").build();
        signering.send(msg);

        // 从测试通道接收消息（指定超时避免异步场景空返回）
        Message<?> receivedMsg = testValidering.receive(1000);
        assertNotNull(receivedMsg);
        // 验证转换结果
        assertEquals("expected transformed payload", receivedMsg.getPayload());
    }
}

原理：@MockMessageChannel会自动覆盖同名生产通道，所有发往validering的消息都会路由到测试通道，方便拦截验证。

方法2：通过通道拦截器捕获消息 #

无需替换原有通道，添加拦截器即可捕获消息：

@SpringBootTest
public class TransformerTest {

    @Autowired
    MessageChannel signering;

    @Autowired
    MessageChannel validering;

    private final List<Message<?>> capturedMessages = new ArrayList<>();

    @BeforeEach
    void setup() {
        // 给目标通道添加拦截器
        ((AbstractMessageChannel) validering).addInterceptor(new ChannelInterceptor() {
            @Override
            public Message<?> preSend(Message<?> message, MessageChannel channel) {
                capturedMessages.add(message);
                return message; // 允许消息继续流向真实下游，返回null可阻断流程
            }
        });
    }

    @Test
    void testTransformer() {
        Message<String> msg = MessageBuilder.withPayload("test payload").build();
        signering.send(msg);

        // 从捕获列表获取消息
        assertFalse(capturedMessages.isEmpty());
        Message<?> receivedMsg = capturedMessages.get(0);
        assertEquals("expected transformed payload", receivedMsg.getPayload());
    }
}

方法3：用@SpringIntegrationTest简化测试 #

该注解会自动配置测试组件，将订阅型通道（如DirectChannel）包装为可轮询通道：

@SpringBootTest
@SpringIntegrationTest
public class TransformerTest {

    @Autowired
    MessageChannel signering;

    @Autowired
    @Qualifier("validering")
    private PollableChannel testValidering;

    @Test
    void testTransformer() {
        Message<String> msg = MessageBuilder.withPayload("test payload").build();
        signering.send(msg);

        Message<?> receivedMsg = testValidering.receive(1000);
        assertNotNull(receivedMsg);
        // 执行验证逻辑
    }
}

关键注意点 #

• 测试类需用@SpringBootTest（或对应Spring上下文注解）加载正确的应用上下文
• 使用@MockMessageChannel时，测试上下文会优先加载测试定义的通道，覆盖生产Bean
• receive()建议指定超时时间，避免异步处理导致的空返回

内容的提问来源于stack exchange，提问作者Torvald Baade Bringsvor