网站支持ipv6怎么做,756ka网站建设,wordpress发表的文章百度抓取失败,wordpress微信支付本文只是简单使用SpringBoot2使用WebFlux的函数式编程简单使用#xff0c;后续会继续写关于Webflux相关的文章。 最近一直在研究WebFlux#xff0c;后续会陆续出一些相关的文章。 首先看一下Srping官网上的一张图#xff0c;对比一下SpringMvc和Spring WebFlux#xff0c;如… 本文只是简单使用SpringBoot2使用WebFlux的函数式编程简单使用后续会继续写关于Webflux相关的文章。 最近一直在研究WebFlux后续会陆续出一些相关的文章。 首先看一下Srping官网上的一张图对比一下SpringMvc和Spring WebFlux如图 在查看一下WebFlux的官方文档:docs.spring.io/spring/docs…WebFlux提供了函数式编程本文简单介绍一下WebFlux函数式编程简单使用。 新建项目 创建一个项目pom文件中引入webflux依赖完整pom文件如下 ?xml version1.0 encodingUTF-8?
project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersiongroupIdcom.dalaoyang/groupIdartifactIdspringboot2_webflux/artifactIdversion0.0.1-SNAPSHOT/versionpackagingjar/packagingnamespringboot2_webflux/namedescriptionspringboot2_webflux/descriptionparentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion2.0.3.RELEASE/versionrelativePath/ !-- lookup parent from repository --/parentpropertiesproject.build.sourceEncodingUTF-8/project.build.sourceEncodingproject.reporting.outputEncodingUTF-8/project.reporting.outputEncodingjava.version1.8/java.version/propertiesdependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-webflux/artifactId/dependency/dependenciesbuildpluginsplugingroupIdorg.springframework.boot/groupIdartifactIdspring-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 yangyangdalaoyang.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 yangyangdalaoyang.cn* date 2018/7/30*/
Component
public class HiHandler {public MonoServerResponse 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();MultiValueMapString, ResponseCookie cookies();MonoVoid 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 {ListHttpMessageWriter? messageWriters();ListViewResolver viewResolvers();}public interface BodyBuilder extends ServerResponse.HeadersBuilderServerResponse.BodyBuilder {ServerResponse.BodyBuilder contentLength(long var1);ServerResponse.BodyBuilder contentType(MediaType var1);ServerResponse.BodyBuilder hint(String var1, Object var2);T, P extends PublisherT MonoServerResponse body(P var1, ClassT var2);T, P extends PublisherT MonoServerResponse body(P var1, ParameterizedTypeReferenceT var2);MonoServerResponse syncBody(Object var1);MonoServerResponse body(BodyInserter?, ? super ServerHttpResponse var1);MonoServerResponse render(String var1, Object... var2);MonoServerResponse render(String var1, MapString, ? var2);}public interface HeadersBuilderB extends ServerResponse.HeadersBuilderB {B header(String var1, String... var2);B headers(ConsumerHttpHeaders var1);B cookie(ResponseCookie var1);B cookies(ConsumerMultiValueMapString, ResponseCookie var1);B allow(HttpMethod... var1);B allow(SetHttpMethod var1);B eTag(String var1);B lastModified(ZonedDateTime var1);B location(URI var1);B cacheControl(CacheControl var1);B varyBy(String... var1);MonoServerResponse build();MonoServerResponse build(PublisherVoid var1);MonoServerResponse build(BiFunctionServerWebExchange, ServerResponse.Context, MonoVoid 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 yangyangdalaoyang.cn* date 2018/7/30*/
Configuration
public class HiRouter {Beanpublic RouterFunctionServerResponse routeHi(HiHandler hiHandler) {return RouterFunctions.route(RequestPredicates.GET(/hi).and(RequestPredicates.accept(MediaType.APPLICATION_JSON)),hiHandler::Hi);}
}
复制代码启动项目通过控制台可以看到两种方式的映射都被打印出来了如图所示 在浏览器访问http://localhost:8080/hi,结果如图所示: 源码下载 大老杨码云 个人网站www.dalaoyang.cn 关注作者公众号
