如何编写一个基于自定义逻辑将数据生成到不同绑定的函数

Question

常规的Spring-Cloud-Stream函数如下所示（摘自文档）：

@Bean
public Function<String, String> toUpperCase() {
    return s -> s.toUpperCase();
}

考虑到不使用反应式方法，我想知道是否可以基于自定义逻辑进行不同的转换和/或将结果发送到不同的“输出”绑定？类似这样：

@Bean
public Function<String, String> transform() {
    return s -> {
      if (s.equals("A")) {
        return s.toUpperCase();       //this wants to be sent to toUpperCase-out-0
      } else if (s.equals("B")) {
        return s.toLowerCase();       //this wants to be sent to toLowerCase-out-0
      } else {
        return "unsupported";         //this wants to be sent to unsupported-out-0
      }
    };
}

此外，这里我们有相同的返回类型（字符串），但可能需要从每个分支返回不同类的对象（通过使用对象作为整个函数的返回类型）。

我可以用消费者而不是函数想象一个解决方案，在其中我们进行不同的StreamBridge调用，但也许可以用函数做同样的事情？

Answer 1

不要使用功能，而是使用消费者，并使用流桥发送输出。

https://docs.spring.io/spring-cloud-stream/docs/current/reference/html/spring-cloud-stream.html#_sending_arbitrary_data_to_an_output_e_g_foreign_event_driven_sources