Spring Cloud Stream非响应式下如何实现Function按自定义逻辑路由到不同输出绑定

核心结论 #

非响应式场景下，普通单返回值Function无法通过默认绑定逻辑直接实现按自定义逻辑路由到不同output绑定的效果。
Spring Cloud Stream对命令式（非响应式）Function的默认绑定规则是固定的：单个函数只会映射1个输入绑定<functionName>-in-0和1个输出绑定<functionName>-out-0，函数内所有分支的返回值，默认都会统一发送到这唯一的输出绑定，不会根据返回内容、返回类型自动拆分到你期望的toUpperCase-out-0/toLowerCase-out-0这类独立绑定。就算你把函数返回值声明为Object、抽象类来兼容不同分支的返回类型，也只能解决序列化兼容问题，无法实现多出口路由。

基于Function的可行实现方案 #

如果你不想用Consumer+StreamBridge的组合，可以通过返回带指定路由头的Message对象实现需求，这是框架原生支持的Function级路由能力，不需要额外依赖：

import org.springframework.messaging.Message;
import org.springframework.messaging.support.MessageBuilder;
import java.util.function.Function;

@Bean
public Function<String, Message<?>> transform() {
    return s -> {
        if (s.equals("A")) {
            return MessageBuilder.withPayload(s.toUpperCase())
                    // 指定消息发往的目标绑定
                    .setHeader("spring.cloud.stream.sendto", "toUpperCase-out-0")
                    .build();
        } else if (s.equals("B")) {
            return MessageBuilder.withPayload(s.toLowerCase())
                    .setHeader("spring.cloud.stream.sendto", "toLowerCase-out-0")
                    .build();
        } else {
            return MessageBuilder.withPayload("unsupported")
                    .setHeader("spring.cloud.stream.sendto", "unsupported-out-0")
                    .build();
        }
    };
}

方案说明 #

• 这种方式完全符合Function编程模型，不需要手动注入发送组件，框架会自动识别spring.cloud.stream.sendto头，把消息路由到指定的输出绑定，跳过当前函数默认的out-0绑定。
• 不同分支返回不同类型的业务对象完全兼容，只要对应MQ的序列化配置正常即可，不需要强制统一返回类型。
• 如果你需要更固定的路由规则，也可以通过配置文件给函数输出绑定设置路由表达式，根据消息内容、消息头做转发，但灵活性不如代码中动态判断的方式。

注意事项 #

不要尝试给单个非响应式Function手动声明多个output绑定，原生多输入/多输出绑定的映射能力仅对响应式返回值（如Flux、多流Tuple封装）生效，非响应式单返回值Function不支持该特性。

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