SpringBoot+Spring Cloud Function可配置函数组合实现方案咨询

核心依赖 #

首先确保项目引入spring-cloud-function-context依赖（无需Spring Cloud Stream/Kafka相关依赖），Maven示例：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-function-context</artifactId>
    <version>适配你的Spring Boot版本</version>
</dependency>

（注：版本需与Spring Boot版本匹配，比如Spring Boot 3.x对应Spring Cloud 2022.x系列）

1. 定义Function Bean #

参考标准实现方式（你已完成此步骤，以下为示例）：

import java.util.function.Function;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class FunctionConfig {

    @Bean
    public Function<String, String> reverse() {
        return input -> new StringBuilder(input).reverse().toString();
    }

    @Bean
    public Function<String, String> upper() {
        return String::toUpperCase;
    }
}

2. 配置业务逻辑组合 #

在application.properties中通过spring.cloud.function.definition指定要启用的函数（支持单个或管道组合）：

# 单个函数：仅执行反转逻辑
spring.cloud.function.definition=reverse

# 组合函数：先转大写再反转（管道符|表示执行顺序）
# spring.cloud.function.definition=upper|reverse

3. 在Controller中获取并应用配置的函数 #

通过注入FunctionCatalog获取配置中指定的函数实例，它会自动处理单个或组合函数的封装：

import org.springframework.cloud.function.context.FunctionCatalog;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import java.util.function.Function;

@RestController
public class WordProcessorController {

    private final Function<String, String> configuredFunction;

    // 从FunctionCatalog中自动加载配置的函数
    public WordProcessorController(FunctionCatalog functionCatalog) {
        // "function"为固定参数，代表读取spring.cloud.function.definition配置的默认函数
        this.configuredFunction = functionCatalog.lookup(Function.class, "function");
    }

    @PostMapping("/process")
    public String processWord(@RequestBody String word) {
        return configuredFunction.apply(word);
    }
}

4. 测试验证 #

• 配置为reverse时，输入"hello"返回"olleh"
• 配置为upper|reverse时，输入"hello"返回"OLLEH"

关键原理 #

Spring Cloud Function的FunctionCatalog负责管理所有注册的Function Bean，解析spring.cloud.function.definition配置中的函数名和组合规则（管道符|串联多个函数），最终返回一个封装了全部逻辑的Function实例，无需手动处理组合逻辑，完全通过配置控制业务流程。

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