如何在Spring Integration中向流发送消息？手动投递至输入通道

核心思路 #

Spring Integration的消息通道（MessageChannel）原生提供send()方法用于投递消息，只需获取目标输入通道的Bean实例，调用该方法即可实现需求。

方法一：依赖注入获取输入通道（推荐） #

如果你的inputChannel()方法返回的是Spring容器管理的MessageChannel Bean，直接在Web端点所在类中注入该通道即可：

@RestController
public class MessageDeliveryController {
    // 构造注入输入通道实例，符合Spring规范
    private final MessageChannel inputChannel;

    public MessageDeliveryController(MessageChannel inputChannel) {
        this.inputChannel = inputChannel;
    }

    @PostMapping("/submit-message")
    public String submitMessage() {
        // 构建消息
        Message<String> message = MessageBuilder.withPayload("Test").build();
        // 投递到输入通道
        inputChannel.send(message);
        return "消息已成功投递到输入通道";
    }
}

如果输入通道有自定义名称（比如通过MessageChannels.direct("customInputChannel")定义），可通过@Qualifier指定名称注入：

public MessageDeliveryController(@Qualifier("customInputChannel") MessageChannel inputChannel) {
    this.inputChannel = inputChannel;
}

方法二：通过ApplicationContext按名称获取通道 #

如果需要像示例那样通过通道名称动态获取，可注入ApplicationContext来获取通道Bean：

@RestController
public class MessageDeliveryController {
    private final ApplicationContext applicationContext;

    public MessageDeliveryController(ApplicationContext applicationContext) {
        this.applicationContext = applicationContext;
    }

    @PostMapping("/submit-message")
    public String submitMessage() {
        Message<String> message = MessageBuilder.withPayload("Test").build();
        // 替换为你的输入通道Bean名称
        MessageChannel inputChannel = applicationContext.getBean("inputChannel", MessageChannel.class);
        inputChannel.send(message);
        return "消息已成功投递到输入通道";
    }
}

关键说明 #

• 你示例中的Something.submitToChannel本质就是封装了「获取通道实例 + 调用send方法」的逻辑，Spring Integration本身无需额外工具类，直接使用MessageChannel的原生API即可。
• send()方法支持重载，可指定超时时间（比如send(message, 1000)表示1秒超时）。

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