SpringBoot2使用WebFlux函数式编程

本文只是简单使用SpringBoot2使用WebFlux的函数式编程简单使用，后续会继续写关于Webflux相关的文章。

最近一直在研究WebFlux，后续会陆续出一些相关的文章。

首先看一下Srping官网上的一张图，对比一下SpringMvc和Spring WebFlux，如图：

在查看一下WebFlux的官方文档:docs.spring.io/spring/docs…，WebFlux提供了函数式编程，本文简单介绍一下WebFlux函数式编程简单使用。

新建项目

创建一个项目，pom文件中引入webflux依赖，完整pom文件如下：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.dalaoyang</groupId><artifactId>springboot2_webflux</artifactId><version>0.0.1-SNAPSHOT</version><packaging>jar</packaging><name>springboot2_webflux</name><description>springboot2_webflux</description><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.3.RELEASE</version><relativePath/> <!-- lookup parent from repository --></parent><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-webflux</artifactId></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>
复制代码

首先试试引入WebFlux依赖之后，SpringMvc方式是否还能使用，新建一个HelloController，完整代码如下，执行后发现，是可以正常执行访问的，这其实就是我们所说的注解式编程。

package com.dalaoyang.controller;import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;/*** @author dalaoyang* @project springboot_learn* @package com.dalaoyang.controller* @email yangyang@dalaoyang.cn* @date 2018/7/30*/
@RestController
public class HelloController {@GetMapping("hello")public String Hello(){return "Hello this is SpringWebFlux";}}
复制代码

结果如图：

接下来使用函数式编程，首先查阅一下官方文档，如图：

我们需要创建一个HandlerFunction返回值为Mono，新建一个HiHandler，里面写一个方法Hi，完整代码如下：

package com.dalaoyang.handler;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Component;
import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.server.ServerRequest;
import org.springframework.web.reactive.function.server.ServerResponse;
import reactor.core.publisher.Mono;/*** @author dalaoyang* @project springboot_learn* @package com.dalaoyang.handler* @email yangyang@dalaoyang.cn* @date 2018/7/30*/
@Component
public class HiHandler {public Mono<ServerResponse> Hi(ServerRequest request) {return ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(BodyInserters.fromObject("Hi , this is SpringWebFlux"));}
}
复制代码

其中ServerResponse是相应的封装对象，下面是它的源码，其中包含了响应状态，响应头等等，代码如下：

package org.springframework.web.reactive.function.server;import java.net.URI;
import java.time.ZonedDateTime;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.function.BiFunction;
import java.util.function.Consumer;
import org.reactivestreams.Publisher;
import org.springframework.core.ParameterizedTypeReference;
import org.springframework.http.CacheControl;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseCookie;
import org.springframework.http.codec.HttpMessageWriter;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.util.MultiValueMap;
import org.springframework.web.reactive.function.BodyInserter;
import org.springframework.web.reactive.result.view.ViewResolver;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;public interface ServerResponse {HttpStatus statusCode();HttpHeaders headers();MultiValueMap<String, ResponseCookie> cookies();Mono<Void> writeTo(ServerWebExchange var1, ServerResponse.Context var2);static ServerResponse.BodyBuilder from(ServerResponse other) {return new DefaultServerResponseBuilder(other);}static ServerResponse.BodyBuilder status(HttpStatus status) {return new DefaultServerResponseBuilder(status);}static ServerResponse.BodyBuilder status(int status) {return new DefaultServerResponseBuilder(status);}static ServerResponse.BodyBuilder ok() {return status(HttpStatus.OK);}static ServerResponse.BodyBuilder created(URI location) {ServerResponse.BodyBuilder builder = status(HttpStatus.CREATED);return (ServerResponse.BodyBuilder)builder.location(location);}static ServerResponse.BodyBuilder accepted() {return status(HttpStatus.ACCEPTED);}static ServerResponse.HeadersBuilder<?> noContent() {return status(HttpStatus.NO_CONTENT);}static ServerResponse.BodyBuilder seeOther(URI location) {ServerResponse.BodyBuilder builder = status(HttpStatus.SEE_OTHER);return (ServerResponse.BodyBuilder)builder.location(location);}static ServerResponse.BodyBuilder temporaryRedirect(URI location) {ServerResponse.BodyBuilder builder = status(HttpStatus.TEMPORARY_REDIRECT);return (ServerResponse.BodyBuilder)builder.location(location);}static ServerResponse.BodyBuilder permanentRedirect(URI location) {ServerResponse.BodyBuilder builder = status(HttpStatus.PERMANENT_REDIRECT);return (ServerResponse.BodyBuilder)builder.location(location);}static ServerResponse.BodyBuilder badRequest() {return status(HttpStatus.BAD_REQUEST);}static ServerResponse.HeadersBuilder<?> notFound() {return status(HttpStatus.NOT_FOUND);}static ServerResponse.BodyBuilder unprocessableEntity() {return status(HttpStatus.UNPROCESSABLE_ENTITY);}public interface Context {List<HttpMessageWriter<?>> messageWriters();List<ViewResolver> viewResolvers();}public interface BodyBuilder extends ServerResponse.HeadersBuilder<ServerResponse.BodyBuilder> {ServerResponse.BodyBuilder contentLength(long var1);ServerResponse.BodyBuilder contentType(MediaType var1);ServerResponse.BodyBuilder hint(String var1, Object var2);<T, P extends Publisher<T>> Mono<ServerResponse> body(P var1, Class<T> var2);<T, P extends Publisher<T>> Mono<ServerResponse> body(P var1, ParameterizedTypeReference<T> var2);Mono<ServerResponse> syncBody(Object var1);Mono<ServerResponse> body(BodyInserter<?, ? super ServerHttpResponse> var1);Mono<ServerResponse> render(String var1, Object... var2);Mono<ServerResponse> render(String var1, Map<String, ?> var2);}public interface HeadersBuilder<B extends ServerResponse.HeadersBuilder<B>> {B header(String var1, String... var2);B headers(Consumer<HttpHeaders> var1);B cookie(ResponseCookie var1);B cookies(Consumer<MultiValueMap<String, ResponseCookie>> var1);B allow(HttpMethod... var1);B allow(Set<HttpMethod> var1);B eTag(String var1);B lastModified(ZonedDateTime var1);B location(URI var1);B cacheControl(CacheControl var1);B varyBy(String... var1);Mono<ServerResponse> build();Mono<ServerResponse> build(Publisher<Void> var1);Mono<ServerResponse> build(BiFunction<ServerWebExchange, ServerResponse.Context, Mono<Void>> var1);}
}
复制代码

在回过头了看上面官方文档的图片，还需要配置一个路由来类似@RequestMapping的功能，通过RouterFunctions.route(RequestPredicate, HandlerFunction)提供了一个路由器函数默认实现，新建一个HiRouter，代码如下：

package com.dalaoyang.router;import com.dalaoyang.handler.HiHandler;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.MediaType;
import org.springframework.web.reactive.function.server.RequestPredicates;
import org.springframework.web.reactive.function.server.RouterFunction;
import org.springframework.web.reactive.function.server.RouterFunctions;
import org.springframework.web.reactive.function.server.ServerResponse;
/*** @author dalaoyang* @project springboot_learn* @package com.dalaoyang.router* @email yangyang@dalaoyang.cn* @date 2018/7/30*/
@Configuration
public class HiRouter {@Beanpublic RouterFunction<ServerResponse> routeHi(HiHandler hiHandler) {return RouterFunctions.route(RequestPredicates.GET("/hi").and(RequestPredicates.accept(MediaType.APPLICATION_JSON)),hiHandler::Hi);}
}
复制代码

启动项目，通过控制台可以看到，两种方式的映射都被打印出来了，如图所示：

在浏览器访问，http://localhost:8080/hi,结果如图所示:

源码下载 ：大老杨码云

个人网站：www.dalaoyang.cn

关注作者公众号

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/451060.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

单点登录原理与简单实现

单点登录原理与简单实现

前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到教程。 一、单系统登录机制 1、http无状态协议 web应用采用browser/server架构&#xff0c;http作为通信协议。http是无状态协议&#xff0c;浏…
阅读更多...
java接口类支持多继承

java接口类支持多继承

一个类只能extends一个父类&#xff0c;只能有一个父类&#xff0c;但可以implements多个接口。java通过使用接口的概念来取代C中多继承。与此同时&#xff0c;一个接口则可以同时extends多个接口&#xff0c;却不能implements任何接口。Java中的接口是支持多继承的。
阅读更多...
xmind-HTTP协议

xmind-HTTP协议

转载于:https://www.cnblogs.com/margot921/p/9764788.html
阅读更多...
弹性布局

弹性布局

弹性布局 一、Flex布局是什么&#xff1f; Flex是Flexible Box的缩写&#xff0c;意为”弹性布局”&#xff0c;用来为盒状模型提供最大的灵活性。任何一个容器都可以指定为Flex布局。 二、基本概念 采用Flex布局的元素&#xff0c;称为Flex容器&#xff08;flex container&…
阅读更多...
Java-Type简单分类

Java-Type简单分类

&#xff08;1&#xff09;ParameterizedType&#xff1a; 参数化类型&#xff0c;例如List<T>。 &#xff08;2&#xff09;GenericArrayType&#xff1a; 泛型数组类型&#xff0c;例如T[]。 &#xff08;3&#xff09;TypeVariable&#xff1a; 泛型的类型变量&a…
阅读更多...
解决dataTable 报错：cannot read property “style“ of undefined

解决dataTable 报错：cannot read property “style“ of undefined

前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到教程。 其实这错&#xff0c;我之前也遇到过&#xff0c;只是太久了&#xff0c;没有记录下来&#xff0c; 今天看到群里朋友也遇到这个错误&a…
阅读更多...
万恶之源 - Python基础数据类型一

万恶之源 - Python基础数据类型一

整数 整数在Python中的关键字用int来表示; 整型在计算机中运于计算和比较 在32位机器上int的范围是: -2**31&#xff5e;2**31-1&#xff0c;即-2147483648&#xff5e;2147483647 在64位机器上int的范围是: -2**63&#xff5e;2**63-1&#xff0c;即-9223372036854775808&…
阅读更多...
谈谈对于技术面试的心得体验

谈谈对于技术面试的心得体验

导读&#xff1a;作者lzprgmr写了一篇《谈谈技术面试》文章&#xff0c;他在文中讲述了自己对于技术人员面试的经验和心得&#xff0c;以下是文章内容&#xff1a; 只要是招一个技术人员&#xff0c;不管是初级的程序员还是高级软件工程师&#xff0c;技术上的考核都必不可少。…
阅读更多...
es6中class类的全方面理解（三）------静态方法

es6中class类的全方面理解（三）------静态方法

不需要实例化类&#xff0c;即可直接通过该类来调用的方法&#xff0c;即称之为“静态方法”。将类中的方法设为静态方法也很简单&#xff0c;在方法前加上static关键字即可。这样该方法就不会被实例继承&#xff01; class Box{static a(){return "我是Box类中的&#xf…
阅读更多...
jackson/fastJson boolean类型问题

jackson/fastJson boolean类型问题

1.我们以Person对象举个栗子&#xff0c;person有三个属性。name&#xff0c;age和isGay Data public class Person {public Person(String name, int age, boolean isGay) {this.name name;this.age age;this.isGay isGay;}private String name;private Integer age;priva…
阅读更多...
django模板系统（下）

django模板系统（下）

主要内容&#xff1a;母版&#xff0c;继承母版&#xff0c;块&#xff0c;组件&#xff0c;静态文件 母版 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta http-equiv"x-ua-compatible" conten…
阅读更多...
狗窝里的小日子 ...

狗窝里的小日子 ...

来&#xff0c;把平时作的菜菜整理下下&#xff1a; 1. 2. 3. 4. 5. 6. 7. 8.
阅读更多...
面试开发人员的有效方法

面试开发人员的有效方法

伯乐在线 写道 "Alan Skorkin是一名软件开发人员&#xff0c;这是他分享的另一篇有关面试和开发人员的文章(中文)。Skorkin 认为&#xff0c;“当要雇佣开发者时&#xff0c;传统的面试方法显得力不从心&#xff0c;这是必须要面对的现实。为什么不行&#xff1f;原因也许…
阅读更多...
Android直接用手机打包apk!

Android直接用手机打包apk!

你没有看错&#xff0c;用手机浏览器访问Jenkins&#xff0c;就可以打包apk&#xff0c;并生成下载二维码&#xff0c;发送邮件通知测试人员下载&#xff0c;从此解放双手&#xff0c;告别打包测试。先上本人手机邮箱收到的打包成功通知效果图&#xff1a; 废话少说&#xff0c…
阅读更多...
java中byte、short、char、boolean实际都是按照int处理的！

java中byte、short、char、boolean实际都是按照int处理的！

byte、char、short、boolean四种类型在汇编期或运行期间采取和int类型一样的存储方式&#xff0c;在计算时会先转换为int类型&#xff0c;后进行计算。所以两个short类型数据做算数运算&#xff0c;结果却为int类型。这主要是因为jvm的字节码为了简洁高效&#xff0c;设计时只使…
阅读更多...
4、2 核心组件

4、2 核心组件

1、Stage&#xff1a;虚的　　一组RDD构成的链条并行的task集合&#xff0c;同一Stage的所有任务有着相同的Shuffle依赖。阶段的划分按照shuffle标记来进行的。一个阶段含多个RDD&#xff0c;先有RDD后有Stage一个阶段含多个taskstage通过ShuffleDependency划分&#xff0c;一个…
阅读更多...
狗窝里的小日子- 2 ...

狗窝里的小日子- 2 ...

来&#xff0c;把平时作的菜菜整理下&#xff1a; 9. 10. 11. 12. 13. 14. 15. 16. 17. 18. 19. 20.
阅读更多...
优秀程序员必备素质——快速调试

优秀程序员必备素质——快速调试

你是否有过这些经历&#xff1a; 1.代码敲完了&#xff0c;刚想松口气&#xff0c;一运行程序&#xff0c;满满的Bug。 2.找啊找啊找&#xff0c;怎么找都找不到哪里出了问题。 3.调试了半天出不来&#xff0c;就开始便得心烦气躁。 4.一天连一个Bug也没调出来&#xff0c;…
阅读更多...
Java程序编译运行过程

Java程序编译运行过程

整体流程 1.首先由源程序文件编译成class文件。注意这里的源程序并不仅限于java程序&#xff0c;其他语言如果能够编译成class文件&#xff0c;并且符合jvm规范也能够在jvm上运行。 2.jvm将class文件拷贝到内存&#xff0c;解释成相应的机器语言运行。我们常用的hotspot虚拟机…
阅读更多...
【TeeChart .NET教程】（七）使用函数

【TeeChart .NET教程】（七）使用函数

2019独角兽企业重金招聘Python工程师标准>>> 上一篇&#xff1a;【TeeChart .NET教程】&#xff08;六&#xff09;使用系列 【下载TeeChart.Net最新版本】 &#xff08;一&#xff09;功能类型 1.1 功能类型 TeeChart Pro功能是一个系列&#xff0c;几乎可以是任何…
阅读更多...
最新文章

Copyright @ 2022~2023