写点什么

Java 高手速成 | WebFlux 框架的函数式开发模式

作者:TiAmo
  • 2023-02-14
    江苏
  • 本文字数:2329 字

    阅读完需:约 8 分钟

Java高手速成 | WebFlux框架的函数式开发模式

WebFlux 框架的函数式开发模式

01、WebFlux 框架的函数式开发模式

所谓函数式开发模式,是和面向对象开发模式相对的一个概念。在面向对象的开发模式中,对象是程序中的主角,程序在运行时会创建各种对象,这些对象产生各种行为,彼此之间互相协作,最后产生运算结果。而在函数式开发模式中,实现特定功能的各种方法是程序中的主角,一个接一个的方法被调用,环环相扣,最后产生运算结果,就像生产流水线一样,而至于到底是哪些对象来提供这些方法,可以被忽略。

例如以下代码中的 Lambda 表达式就体现了函数式编程思想,Lambda 表达式定义了处理所接收到的数据的功能,而至于这些功能属于哪个匿名对象,在这里被忽略:

//发送方发送“Hello”字符串Mono<String> mono=Mono.just(“Hello”); //接收方按照异步非阻塞方式接收“Hello”字符串mono.subscribe(  value -> System.out.println(value),  error -> error.printStackTrace());
复制代码

由于 Java 语言本质是面向对象的开发语言,因此,程序在引入函数式开发模式时,实际上是面向对象开发和函数式开发两种模式夹杂在一起。

在 WebFlux 框架的函数式开发模式中,控制器类是任意的用 @Component 组件标识的类。以下例程 1 的 DataHandler 类就是控制器类。

例程 1 DataHandler.java

……import static org.springframework.web.reactive                            .function.server.ServerResponse.ok;@Componentpublic class DataHandler {  public Mono<ServerResponse> greet(ServerRequest request) {    StringcurrentTime="Now is "        + newSimpleDateFormat("HH:mm:ss").format(new Date());      returnok().contentType(MediaType.TEXT_PLAIN)               .body(Mono.just(currentTime),String.class);   }   publicMono<ServerResponse> count(ServerRequest request) {    List<Integer> scores=new ArrayList<Integer>();     for(inti=0;i<100000;i++)      scores.add(i);     Flux<Integer> data=Flux.fromIterable(scores);      returnok()               .contentType(MediaType.APPLICATION_STREAM_JSON)               .body(data,Integer.class);   }   publicMono<ServerResponse> push(ServerRequest request) {    List<Integer> scores=new ArrayList<Integer>();     for(inti=0;i<100000;i++)      scores.add(i);      //间隔5秒发送一次数据   Flux<Integer> data=Flux.interval(Duration.ofSeconds(5))                                .fromIterable(scores);     returnok()                .contentType(MediaType.TEXT_EVENT_STREAM)                .body(data,Integer.class);   }}
复制代码

DataHandler 类的请求处理方法有一个表示客户请求的 ServerRequest 类型的请求参数,返回类型是 Mono<ServerResponse>类型。

DataHandler 类的 greet()、count()和 push()方法分别返回不同类型的响应结果:

1.MediaType.TEXT_PLAIN:纯文本类型。

2.MediaType.APPLICATION_STREAM_JSON:JSON 格式的异步非阻塞的数据流。

3.MediaType.TEXT_EVENT_STREAM:事件驱动的异步非阻塞的文本数据流。

以 DataHandler 类的 greet()方法为例,它的以下代码体现了函数式编程的思想:

import static org.springframework.web.reactive                       .function.server.ServerResponse.ok; ……return ok().contentType(MediaType.TEXT_PLAIN)                .body(Mono.just(currentTime),String.class);
复制代码

以上 ok()方法是静态引入的方法,具有返回正常响应结果的功能,接下来又调用 contentType()和 body()方法来设置响应结果的数据类型和正文内容。产生整个运算结果是由一系列的方法调用来产生的,对象在程序中的主导地位被削弱了,这就体现了函数式编程的思想。

DataHandler 类没有用 @Controller 注解来标识,所以不能用 @RequestMapping 等注解来为它的请求处理方法设定映射路径。那么在这种情况下,该如何为请求处理方法设定映射路径呢?用 RouterFunction 路由函数接口来设定映射路径,也称作设定路由。

在以下例程 2 的 DataRouter 类中,为 DataHandler 类的三个请求处理方法均设定了路由。

例程 2 DataRouter.java

@Configurationpublic class DataRouter {  @Bean  public RouterFunction<ServerResponse> route(                            DataHandler dataHandler) {     returnRouterFunctions      .route(RequestPredicates.GET("/greet")      .and(RequestPredicates.accept(MediaType.TEXT_PLAIN))                                                        ,dataHandler::greet)      .andRoute(RequestPredicates.GET("/push")      .and(RequestPredicates.accept(                                         MediaType.TEXT_EVENT_STREAM))                                         ,dataHandler::push)      .andRoute(RequestPredicates.GET("/count")      .and(RequestPredicates.accept(                           MediaType.APPLICATION_STREAM_JSON)),                          dataHandler::count);    }}
复制代码

DataRouter 类用 @Configuration 注解来标识,表明 DataRouter 类属于配置类,因此 Spring 框架在启动时会把 DataRouter 类设定的路由加载到内存中。root()方法用 @Bean 注解标识,表明 root()方法返回的 RouterFunction 对象会作为 Bean 组件注册到 Spring 框架中。

在 Intellij IDEA 中运行本范例程序,DataRouter 类为 DataHandler 类的 greet()、push()和 count()方法设定的映射路径分别为:

http://localhost:8080/greet

http://localhost:8080/push

http://localhost:8080/count


发布于: 6 小时前阅读数: 7
用户头像

TiAmo

关注

有能力爱自己,有余力爱别人! 2022-06-16 加入

CSDN全栈领域优质创作者;阿里云创作者社区专家博主、技术博主、星级博主、阿里云ACE;华为云享专家;

评论

发布
暂无评论
Java高手速成 | WebFlux框架的函数式开发模式_Java_TiAmo_InfoQ写作社区