如何配置Spring Integration控制总线以返回Bean状态查询结果？

要让控制总线返回状态查询（比如isRunning()）的结果，需要调整配置并使用正确的调用方式，具体步骤如下：

1. 修改控制总线配置，添加回复超时 #

默认控制总线未显式设置回复超时，会导致sendAndReceive方法无限挂起。修改配置为控制总线添加replyTimeout参数：

@Configuration
public class ControlBus {
    @Bean
    public IntegrationFlow controlBusFlow() {
        return IntegrationFlows.from(controlChannel())
                // 根据实际场景调整超时时间
                .controlBus(controlBusSpec -> controlBusSpec.replyTimeout(5000))
                .get();
    }

    @Bean
    public MessageChannel controlChannel() {
        return MessageChannels.direct().get();
    }
}

2. 使用正确的调用方式获取结果 #

方式一：使用MessagingTemplate.sendAndReceive #

通过该方法发送请求并直接接收响应结果：

MessagingTemplate messagingTemplate = new MessagingTemplate();
messagingTemplate.setReceiveTimeout(5000); // 与控制总线回复超时对应

Message<?> response = messagingTemplate.sendAndReceive(controlChannel, 
        new GenericMessage<>("@myInbound.isRunning()"));

if (response != null) {
    Boolean isRunning = (Boolean) response.getPayload();
    // 处理查询到的运行状态
}

方式二：定义MessagingGateway接口（更优雅） #

通过网关接口封装控制总线调用，简化业务代码：

// 网关接口，指定默认请求通道为控制总线通道
@MessagingGateway(defaultRequestChannel = "controlChannel")
public interface ControlBusGateway {
    // 设置请求和回复超时时间
    @Gateway(requestTimeout = 5000, replyTimeout = 5000)
    Object executeControlCommand(String command);
}

在业务代码中注入网关，直接调用即可获取结果：

@Autowired
private ControlBusGateway controlBusGateway;

// 查询组件运行状态
Boolean isRunning = (Boolean) controlBusGateway.executeControlCommand("@myInbound.isRunning()");

// 启动/停止组件同样可用网关调用
controlBusGateway.executeControlCommand("@myInbound.start()");
controlBusGateway.executeControlCommand("@myInbound.stop()");

注意事项 #

• 确保目标Bean（如myInbound）的方法为public权限，否则SpEL表达式无法正常调用
• 超时时间需根据实际业务场景调整，避免过短导致超时或过长引发不必要的等待

内容的提问来源于stack exchange，提问作者Marc Tarin