SpringCloud 功能支持

從Spring Cloud Stream v2.1開始，定義流處理程序和源的另一種方法是使用對Spring Cloud函數(shù)的內(nèi)置支持，其中可以將它們表示為java.util.function.[Supplier/Function/Consumer]類型的beans。

若要指定要綁定到綁定公開的外部目標(biāo)的功能bean，必須提供spring.cloud.stream.function.definition屬性。

這是Processor應(yīng)用程序?qū)⑾⑻幚沓绦蚬_為java.util.function.Function的示例

@SpringBootApplication
@EnableBinding(Processor.class)
public class MyFunctionBootApp {

	public static void main(String[] args) {
		SpringApplication.run(MyFunctionBootApp.class, "--spring.cloud.stream.function.definition=toUpperCase");
	}

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

在上面的代碼中，我們僅定義了類型為java.util.function.Function的bean（稱為toUpperCase）并將其標(biāo)識為bean，用作消息處理程序，其“輸入”和“輸出”必須綁定到外部目標(biāo)由處理器綁定公開。

以下是支持源，處理器和接收器的簡單功能應(yīng)用程序的示例。

這是定義為java.util.function.Supplier的Source應(yīng)用程序的示例

@SpringBootApplication
@EnableBinding(Source.class)
public static class SourceFromSupplier {
	public static void main(String[] args) {
		SpringApplication.run(SourceFromSupplier.class, "--spring.cloud.stream.function.definition=date");
	}
	@Bean
	public Supplier<Date> date() {
		return () -> new Date(12345L);
	}
}

這是定義為java.util.function.Function的Processor應(yīng)用程序的示例

@SpringBootApplication
@EnableBinding(Processor.class)
public static class ProcessorFromFunction {
	public static void main(String[] args) {
		SpringApplication.run(ProcessorFromFunction.class, "--spring.cloud.stream.function.definition=toUpperCase");
	}
	@Bean
	public Function<String, String> toUpperCase() {
		return s -> s.toUpperCase();
	}
}

這是一個(gè)定義為java.util.function.Consumer的接收器應(yīng)用程序的示例

@EnableAutoConfiguration
@EnableBinding(Sink.class)
public static class SinkFromConsumer {
	public static void main(String[] args) {
		SpringApplication.run(SinkFromConsumer.class, "--spring.cloud.stream.function.definition=sink");
	}
	@Bean
	public Consumer<String> sink() {
		return System.out::println;
	}
}

@Bean
public Function<String, String> wrapInQuotes() {
	return s -> "\"" + s + "\"";
}

—spring.cloud.stream.function.definition=toUpperCase|wrapInQuotes