环境：SpringBoot2.3.12.RELEASE + Spring Cloud 2020.0.5

简介

Spring Cloud Function是一个具有以下高层目标的项目:

通过函数促进业务逻辑的实现。将业务逻辑的开发生命周期与任何特定的运行时目标解耦，这样相同的代码就可以作为web端点、流处理器或任务运行。支持跨无服务器（serverless）提供商的统一编程模型，以及独立运行(本地或PaaS中)的能力。在无服务（serverless）提供商上启用Spring Boot特性(自动配置、依赖注入、指标)。

它抽象了所有的传输细节和基础设施，允许开发人员保留所有熟悉的工具和流程，并将重点牢牢地放在业务逻辑上。如下示例：

@SpringBootApplicationpublic class Application {  @Bean  public Function<Flux<String>, Flux<String>> uppercase() {    return flux -> flux.map(value -> value.toUpperCase());  }  public static void main(String[] args) {    SpringApplication.run(Application.class, args);  }}

如上，它只是一个Spring Boot应用程序，所以它可以在本地和CI构建中构建、运行和测试，就像其他Spring Boot应用程序一样。该 Function来自 java.util 与 Flux 是反应流发布者Publisher。可以通过HTTP或消息传递访问该功能。

Spring Cloud Function 有4个主要的功能：

简而言之，Spring Cloud Function提供了以下功能：Function、Consumer和Supplier类型的@Beans的包装器，将它们作为HTTP端点或消息流侦听器/发布者与RabbitMQ、Kafka等一起公开给外部使用。

编程风格的选择——反应式、命令式或混合式。函数组合和适配(例如，组合命令式函数和响应式函数)。支持响应式函数，具有多个输入和输出，允许函数处理合并、连接和其他复杂的流操作。输入和输出的透明类型转换。针对目标平台(例如，Project Riff, AWS Lambda等)的部署打包功能将函数作为HTTP端点等对外公开的适配器。使用独立的类加载器部署包含此类应用程序上下文的JAR文件，以便可以将它们打包到单个JVM中。将作为Java函数体的字符串编译成字节码，然后将它们转换成可以像上面那样包装的@bean。适用于AWS Lambda、Azure、Google Cloud Functions、Apache OpenWhisk和其他可能的“serverless”服务提供商的适配器。案例应用

函数可以自动导出为HTTP端点。

Spring -cloud-function-web模块具有自动配置功能，当它被包含在Spring Boot web应用程序中时(带有MVC支持)就会被激活。如果你只是想要一个简单的入门体验，spring-cloud-starter- functional -web也可以收集所有可选的依赖项。

激活web配置后，你的应用将会有一个MVC端点(默认值为"/"，但可以通过spring.cloud.function.web.path配置)，它可以用来访问应用上下文中的函数，其中函数名成为URL路径的一部分。支持的内容类型是纯文本和JSON。

编号

Method

Path

Request

Response

Status

1

GET

/{supplier}

-

Items from the named supplier

200 OK

2

POST

/{consumer}

JSON object or text

Mirrors input and pushes request body into consumer

202 Accepted

3

POST

/{consumer}

JSON array or text with new lines

Mirrors input and pushes body into consumer one by one

202 Accepted

4

POST

/{function}

JSON object or text

The result of applying the named function

200 OK

5

POST

/{function}

JSON array or text with new lines

The result of applying the named function

200 OK

6

GET

/{function}/{item}

-

Convert the item into an object and return the result of applying the function

200 OK

针对以上6中情况，演示示例如下：

1 GET /{supplier}

@Beanpublic Function<Flux<String>, Flux<String>> uppercase() {  return flux -> flux.map(value -> value.toUpperCase());}

请求结果：

GET /{supplier}

2 POST /{consumer}

@Beanpublic Consumer<Person> consumer1() {  return person -> System.out.println("阻塞式调用：" + person) ;}

请求结果：

POST /{consumer}

Result

3 POST /{consumer}

@Beanpublic Consumer<Flux<Person>> consumer2() {  return person -> {    person.subscribe(System.out::println) ;  } ;}

请求结果：

consumer2

Result

4 POST /{consumer}

@Beanpublic Consumer<Flux<Person>> consumer3() {  return person -> {    person.subscribe(System.out::println) ;  } ;}

请求结果：

POST /consumer

Result

6 GET /{function}/{item}

@Beanpublic Function<Flux<Person>, Flux<Map<String, Object>>> function1() {  return person -> person.map(p -> {    Map<String, Object> result = new HashMap<>() ;    result.put("姓名", p.getName()) ;    result.put("年龄", p.getAge()) ;    return result ;  }) ;}

请求结果：

GET /{function}/{item}

完毕！！！

spring data jpa 高级应用

Spring Retry重试框架的应用

Spring容器这些扩展点你都清楚了吗？

Spring MVC 异步请求方式

Spring MVC 异常处理方式

Spring事务实现原理源码分析

Spring 自定义Advisor以编程的方式实现AOP

SpringBoot WebFlux整合Spring Security进行权限认证