Java Lambda项目报错：缺少spring.cloud.function路由相关配置

异常核心原因 #

Lambda消费队列消息时，Spring Cloud Function无法确定要调用的目标函数，因为缺少以下任一必要配置：

• 消息头或应用配置中的spring.cloud.function.definition
• 应用配置中的spring.cloud.function.routing-expression

针对性解决方案 #

1. 单函数项目：配置默认函数

如果项目中仅存在一个Function Bean，直接在应用配置文件中指定默认调用的函数即可：

application.properties

spring.cloud.function.definition=你的函数Bean名称

application.yml

spring:
  cloud:
    function:
      definition: 你的函数Bean名称

举个例子，若你的函数类是：

@Component
public class OrderHandler implements Function<String, String> {
    @Override
    public String apply(String payload) {
        // 业务处理逻辑
        return processedResult;
    }
}

这里的函数Bean名称就是orderHandler（默认采用类名驼峰命名规则）。

2. 多函数项目：指定路由规则

如果存在多个Function Bean，可通过两种方式指定路由：

• 方式一：在消息头中指定目标函数
  发送队列消息时，添加spring.cloud.function.definition消息头，值为要调用的函数名称。以SQS发送消息为例：

  SendMessageRequest request = SendMessageRequest.builder()
          .queueUrl(queueUrl)
          .messageBody(messageContent)
          .messageAttributes(Map.of(
                  "spring.cloud.function.definition", MessageAttributeValue.builder()
                          .stringValue("orderHandler")
                          .dataType("String")
                          .build()
          ))
          .build();
  

• 方式二：配置动态路由表达式
  在应用配置中添加路由表达式，根据消息属性或内容动态匹配函数：

  spring.cloud.function.routing-expression=headers['target-function']
  

  此时消息头中target-function的值会被用来匹配对应的Function Bean。

3. 检查Lambda触发器配置

确保SQS等触发器在传递消息时，没有过滤掉自定义消息头。AWS Lambda的SQS触发器默认会传递消息属性，但如果有自定义消息转换逻辑，需保证spring.cloud.function.definition这类关键头被正确带入Lambda处理环节。

原始异常堆栈 #

无法建立路由，原因是未提供以下任一配置：作为消息头或应用程序属性的'spring.cloud.function.definition'，或作为应用程序属性的'spring.cloud.function.routing-expression'。传入消息：GenericMessage [payload=byte[973], headers={aws-context=lambdainternal.api.LambdaContext@13b29b34, id=7e00385d-ff52-2e7e-0a6a-c68df012c679, timestamp=1685986732788}]: java.lang.IllegalStateException
java.lang.IllegalStateException: 无法建立路由，原因是未提供以下任一配置：作为消息头或应用程序属性的'spring.cloud.function.definition'，或作为应用程序属性的'spring.cloud.function.routing-expression'。传入消息：GenericMessage [payload=byte[973], headers={aws-context=lambdainternal.api.LambdaContext@13b29b34, id=7e00385d-ff52-2e7e-0a6a-c68df012c679, timestamp=1685986732788}]
    at org.springframework.cloud.function.context.config.RoutingFunction.route(RoutingFunction.java:156)
    at org.springframework.cloud.function.context.config.RoutingFunction.apply(RoutingFunction.java:103)
    at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.doApply(SimpleFunctionRegistry.java:710)
    at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.apply(SimpleFunctionRegistry.java:562)
    at org.springframework.cloud.function.adapter.aws.FunctionInvoker.handleRequest(FunctionInvoker.java:113)
    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
    at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
    at java.base/java.lang.reflect.Method.invoke(Unknown Source)

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