Spring Cloud Stream调用REST暴露的Function未输出到绑定队列如何解决

行为合理性说明 #

你遇到的REST调用Function后输出不进入绑定队列的情况是预期行为：
spring-cloud-function-web模块的默认逻辑是将HTTP请求作为函数输入，函数返回值直接作为HTTP响应返回给调用方，整个调用链路不会经过Spring Cloud Stream的消息绑定通道。只有当函数的输入来自Stream绑定的消息源（比如你主动投递消息到logfileEventFunction-in-0队列的场景）时，Spring Cloud Stream才会将函数的返回值路由到你配置的输出绑定队列中。

实现方案 #

提供两种可行的实现方式，可根据业务场景选择：

方案一：使用StreamBridge手动投递（推荐） #

直接新增自定义REST接口，注入Spring Cloud Stream内置的StreamBridge工具类，收到HTTP请求后直接将消息投递到目标队列对应的destination，无需修改现有函数逻辑：

@RestController
public class LogEventForwardController {
    @Autowired
    private StreamBridge streamBridge;

    @PostMapping("/pushLogEvent")
    public String pushLogEvent(@RequestBody Message message) {
        // 第一个参数为你配置的输出绑定destination名称
        streamBridge.send("logfileEventChannel-out-0", message);
        return "消息投递完成";
    }
}

投递后的消息会被你已经定义的logfileEventConsumer正常消费。

方案二：配置函数转发规则 #

如果你希望复用现有logfileEventFunction的逻辑，可通过新增配置让web调用后的返回值自动转发到Stream输出绑定：

# 指定web调用函数后的返回值转发到Stream的目标destination
spring.cloud.function.web.forward-to=logfileEventChannel-out-0
# 可选：关闭web接口直接返回函数结果，仅返回标准投递响应
spring.cloud.function.web.always-produces-response=false

配置完成后直接调用logfileEventFunction对应的默认REST端点/logfileEventFunction，返回的消息就会自动进入配置的队列中。

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