\u5982\u679c\u60a8\u662f\u521d\u6b21\u63a5\u89e6 Spring 5\uff0c\u90a3\u4e48\u8bf7\u4ed4\u7ec6\u9605\u8bfb Spring 5 \u7684\u7279\u70b9<\/a>\u3002<\/p>\n \u6700\u91cd\u8981\u7684\u4f9d\u8d56\u662f Spring WebFlux \u5904\u7406\u5668\u65b9\u6cd5\u7528\u4e8e\u5904\u7406\u8bf7\u6c42\uff0c\u5e76\u4ee5 \u8bf7\u6ce8\u610f\uff0c\u54cd\u5e94\u5f0f\u7ec4\u4ef6 Spring WebFlux \u8def\u7531\u5668\u65b9\u6cd5\u7528\u4e8e\u5b9a\u4e49\u5e94\u7528\u7a0b\u5e8f\u7684\u8def\u7531\u3002\u8fd9\u4e9b\u65b9\u6cd5\u8fd4\u56de\u4e00\u4e2a\u540c\u65f6\u5305\u542b\u670d\u52a1\u5668\u54cd\u5e94\u4e3b\u4f53\u7684 \u56e0\u6b64\uff0c\u6211\u4eec\u4e3a \u73b0\u5728\uff0c\u8ba9\u6211\u4eec\u4f7f\u7528 Spring Boot \u914d\u7f6e\u6211\u4eec\u7b80\u5355\u7684 WebFlux \u5e94\u7528\u7a0b\u5e8f\u3002<\/p>\n \u5982\u679c\u60a8\u67e5\u770b\u4e0a\u9762\u7684\u4ee3\u7801\uff0c\u4f1a\u53d1\u73b0\u5b83\u4e0e Spring WebFlux \u5e76\u6ca1\u6709\u76f4\u63a5\u5173\u8054\u3002\u4f46\u662f\uff0c\u7531\u4e8e\u6211\u4eec\u6dfb\u52a0\u4e86 \u6211\u4eec\u7684\u5e94\u7528\u7a0b\u5e8f\u5df2\u51c6\u5907\u597d\u5728 Java 8 \u4e0a\u6267\u884c\uff0c\u4f46\u5982\u679c\u60a8\u4f7f\u7528\u7684\u662f Java 9\uff0c\u6211\u4eec\u8fd8\u9700\u8981\u6dfb\u52a0 \u6839\u636e\u65e5\u5fd7\u663e\u793a\uff0c\u6211\u4eec\u7684\u5e94\u7528\u7a0b\u5e8f\u6b63\u5728 8080 \u7aef\u53e3\u4e0a\u8fd0\u884c\u4e8e Netty \u670d\u52a1\u5668\u4e0a\u3002\u8ba9\u6211\u4eec\u7ee7\u7eed\u6d4b\u8bd5\u6211\u4eec\u7684\u5e94\u7528\u7a0b\u5e8f\u5427\u3002<\/p>\n \u6211\u4eec\u53ef\u4ee5\u7528\u591a\u79cd\u65b9\u6cd5\u6d4b\u8bd5\u6211\u4eec\u7684\u5e94\u7528\u7a0b\u5e8f\u3002<\/p>\n \u76f4\u63a5\u5728\u6d4f\u89c8\u5668\u4e2d\u8bbf\u95ee \u4ee5\u4e0b\u662f\u4e00\u4e2a\u4f7f\u7528Spring 5\u54cd\u5e94\u5f0f \u5c06\u5176\u4f5c\u4e3a\u4e00\u4e2aJUnit\u6d4b\u8bd5\u7528\u4f8b\u8fd0\u884c\uff0c\u5e94\u8be5\u4f1a\u987a\u5229\u901a\u8fc7\u3002<\/p>\n \u5c06\u5176\u4f5c\u4e3a\u4e00\u4e2a\u7b80\u5355\u7684Java\u5e94\u7528\u7a0b\u5e8f\u8fd0\u884c\uff0c\u4f60\u5e94\u8be5\u80fd\u770b\u5230\u6b63\u786e\u7684\u8f93\u51fa\u548c\u5927\u91cf\u7684\u8c03\u8bd5\u6d88\u606f\u3002<\/p>\n \u5728\u8fd9\u7bc7\u6587\u7ae0\u4e2d\uff0c\u6211\u4eec\u5b66\u4e60\u4e86Spring WebFlux\u4ee5\u53ca\u5982\u4f55\u6784\u5efa\u4e00\u4e2a\u201cHello World\u201d\u54cd\u5e94\u5f0fRESTful Web\u670d\u52a1\u3002\u770b\u5230\u50cfSpring\u8fd9\u6837\u7684\u6d41\u884c\u6846\u67b6\u4e5f\u652f\u6301\u54cd\u5e94\u5f0f\u7f16\u7a0b\u6a21\u578b\uff0c\u771f\u662f\u4ee4\u4eba\u9ad8\u5174\u3002\u4f46\u662f\u6211\u4eec\u8fd8\u6709\u5f88\u591a\u9700\u8981\u5904\u7406\uff0c\u56e0\u4e3a\u5982\u679c\u4f60\u7684\u6240\u6709\u4f9d\u8d56\u90fd\u4e0d\u662f\u54cd\u5e94\u5f0f\u4e14\u975e\u963b\u585e\u7684\uff0c\u90a3\u4e48\u4f60\u7684\u5e94\u7528\u7a0b\u5e8f\u4e5f\u4e0d\u662f\u771f\u6b63\u7684\u54cd\u5e94\u5f0f\u3002\u4f8b\u5982\uff0c\u5173\u7cfb\u578b\u6570\u636e\u5e93\u4f9b\u5e94\u5546\u5e76\u6ca1\u6709\u63d0\u4f9b\u54cd\u5e94\u5f0f\u7684\u9a71\u52a8\u7a0b\u5e8f\uff0c\u56e0\u4e3a\u5b83\u4eec\u4f9d\u8d56\u4e8eJDBC\uff0c\u800cJDBC\u4e0d\u662f\u54cd\u5e94\u5f0f\u7684\u3002\u56e0\u6b64\uff0cHibernate API\u4e5f\u662f\u975e\u54cd\u5e94\u5f0f\u7684\u3002\u6240\u4ee5\uff0c\u5982\u679c\u4f60\u4f7f\u7528\u7684\u662f\u5173\u7cfb\u578b\u6570\u636e\u5e93\uff0c\u90a3\u4e48\u4f60\u76ee\u524d\u8fd8\u65e0\u6cd5\u6784\u5efa\u4e00\u4e2a\u771f\u6b63\u7684\u54cd\u5e94\u5f0f\u5e94\u7528\u7a0b\u5e8f\u3002\u4f46\u6211\u5e0c\u671b\u8fd9\u5c06\u4f1a\u5f88\u5feb\u6539\u53d8\u3002<\/p>\n \u4f60\u53ef\u4ee5\u4ece\u6211\u7684GitHub\u4ed3\u5e93<\/a>\u4e0b\u8f7d\u9879\u76ee\u4ee3\u7801\u3002<\/p>\nSpring WebFlux \u6838\u5fc3\u6982\u5ff5<\/h2>\n
![\"Spring](\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/656474fba4b2f92e6c729e7d\/6-0.png\" "\\"Spring")
<\/div>\n\n
\n
\n
Spring WebFlux Hello World \u793a\u4f8b<\/h2>\n
![\"Spring](\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/656474fba4b2f92e6c729e7d\/9-0.png\" "\\"Spring")
<\/div>\nSpring WebFlux \u7684 Maven \u4f9d\u8d56\u9879<\/h3>\n
<project xmlns=\"https:\/\/maven.apache.org\/POM\/4.0.0\" xmlns:xsi=\"https:\/\/www.w3.org\/2001\/XMLSchema-instance\" xsi:schemaLocation=\"https:\/\/maven.apache.org\/POM\/4.0.0 https:\/\/maven.apache.org\/xsd\/maven-4.0.0.xsd\">\r\n <modelVersion>4.0.0<\/modelVersion>\r\n <groupId>com.Olivia.spring<\/groupId>\r\n <artifactId>SpringWebflux<\/artifactId>\r\n <version>0.0.1-SNAPSHOT<\/version>\r\n <name>Spring WebFlux<\/name>\r\n <description>Spring WebFlux \u793a\u4f8b<\/description>\r\n \r\n <properties>\r\n <project.build.sourceEncoding>UTF-8<\/project.build.sourceEncoding>\r\n <project.reporting.outputEncoding>UTF-8<\/project.reporting.outputEncoding>\r\n <jdk.version>1.9<\/jdk.version>\r\n <\/properties>\r\n \r\n <parent>\r\n\t\t<groupId>org.springframework.boot<\/groupId>\r\n\t\t<artifactId>spring-boot-starter-parent<\/artifactId>\r\n\t\t<version>2.0.1.RELEASE<\/version>\r\n\t\t<relativePath\/> <!-- \u4ece\u4ed3\u5e93\u67e5\u627e\u7236\u7ea7 -->\r\n\t<\/parent>\r\n\r\n\t<dependencies>\r\n\t\t<dependency>\r\n\t\t\t<groupId>org.springframework.boot<\/groupId>\r\n\t\t\t<artifactId>spring-boot-starter-webflux<\/artifactId>\r\n\t\t<\/dependency>\r\n\t\t<dependency>\r\n\t\t\t<groupId>org.springframework.boot<\/groupId>\r\n\t\t\t<artifactId>spring-boot-starter-test<\/artifactId>\r\n\t\t\t<scope>test<\/scope>\r\n\t\t<\/dependency>\r\n\r\n\t\t<dependency>\r\n\t\t\t<groupId>io.projectreactor<\/groupId>\r\n\t\t\t<artifactId>reactor-test<\/artifactId>\r\n\t\t\t<scope>test<\/scope>\r\n\t\t<\/dependency>\r\n <\/dependencies>\r\n\t<repositories>\r\n\t\t<repository>\r\n\t\t\t<id>spring-snapshots<\/id>\r\n\t\t\t<name>Spring \u5feb\u7167\u4ed3\u5e93<\/name>\r\n\t\t\t<url>https:\/\/repo.spring.io\/snapshot<\/url>\r\n\t\t\t<snapshots>\r\n\t\t\t\t<enabled>true<\/enabled>\r\n\t\t\t<\/snapshots>\r\n\t\t<\/repository>\r\n\t\t<repository>\r\n\t\t\t<id>spring-milestones<\/id>\r\n\t\t\t<name>Spring \u91cc\u7a0b\u7891\u4ed3\u5e93<\/name>\r\n\t\t\t<url>https:\/\/repo.spring.io\/milestone<\/url>\r\n\t\t\t<snapshots>\r\n\t\t\t\t<enabled>false<\/enabled>\r\n\t\t\t<\/snapshots>\r\n\t\t<\/repository>\r\n\t<\/repositories>\r\n\t<pluginRepositories>\r\n\t\t<pluginRepository>\r\n\t\t\t<id>spring-snapshots<\/id>\r\n\t\t\t<name>Spring \u5feb\u7167\u63d2\u4ef6\u4ed3\u5e93<\/name>\r\n\t\t\t<url>https:\/\/repo.spring.io\/snapshot<\/url>\r\n\t\t\t<snapshots>\r\n\t\t\t\t<enabled>true<\/enabled>\r\n\t\t\t<\/snapshots>\r\n\t\t<\/pluginRepository>\r\n\t\t<pluginRepository>\r\n\t\t\t<id>spring-milestones<\/id>\r\n\t\t\t<name>Spring \u91cc\u7a0b\u7891\u63d2\u4ef6\u4ed3\u5e93<\/name>\r\n\t\t\t<url>https:\/\/repo.spring.io\/milestone<\/url>\r\n\t\t\t<snapshots>\r\n\t\t\t\t<enabled>false<\/enabled>\r\n\t\t\t<\/snapshots>\r\n\t\t<\/pluginRepository>\r\n\t<\/pluginRepositories>\r\n <build>\r\n <plugins>\r\n <plugin>\r\n <groupId>org.springframework.boot<\/groupId>\r\n <artifactId>spring-boot-maven-plugin<\/artifactId>\r\n <\/plugin>\r\n <\/plugins>\r\n <pluginManagement>\r\n <plugins>\r\n <plugin>\r\n <groupId>org.apache.maven.plugins<\/groupId>\r\n <artifactId>maven-compiler-plugin<\/artifactId>\r\n <version>3.7.0<\/version>\r\n <configuration>\r\n <source>${jdk.version}<\/source>\r\n <target>${jdk.version}<\/target>\r\n <\/configuration>\r\n <\/plugin>\r\n <\/plugins>\r\n <\/pluginManagement>\r\n <\/build>\r\n \r\n<\/project><\/code><\/pre>\nspring-boot-starter-webflux<\/code> \u548c spring-boot-starter-parent<\/code>\u3002\u5176\u4ed6\u4f9d\u8d56\u9879\u4e3b\u8981\u7528\u4e8e\u521b\u5efa JUnit \u6d4b\u8bd5\u7528\u4f8b\u3002<\/p>\nSpring WebFlux \u5904\u7406\u5668<\/h3>\n
Spring WebFlux \u5904\u7406\u5668\u65b9\u6cd5<\/h3>\n
Mono<\/code> \u6216 Flux<\/code> \u4f5c\u4e3a\u54cd\u5e94\u8fd4\u56de\u3002<\/p>\npackage com.Olivia.spring.component;\r\n\r\nimport org.springframework.http.MediaType;\r\nimport org.springframework.stereotype.Component;\r\nimport org.springframework.web.reactive.function.BodyInserters;\r\nimport org.springframework.web.reactive.function.server.ServerRequest;\r\nimport org.springframework.web.reactive.function.server.ServerResponse;\r\n\r\nimport reactor.core.publisher.Mono;\r\n\r\n@Component\r\npublic class HelloWorldHandler {\r\n\tpublic Mono<ServerResponse> helloWorld(ServerRequest request) {\r\n\t\treturn ServerResponse.ok().contentType(MediaType.TEXT_PLAIN)\r\n\t\t\t.body(BodyInserters.fromObject(\"Hello World!\"));\r\n\t}\r\n}\r\n<\/code><\/pre>\nMono<\/code> \u4fdd\u5b58\u4e86 ServerResponse<\/code> \u7684\u4e3b\u4f53\u3002\u540c\u65f6\uff0c\u89c2\u5bdf\u51fd\u6570\u94fe\u5982\u4f55\u8bbe\u7f6e\u8fd4\u56de\u7684\u5185\u5bb9\u7c7b\u578b\u3001\u54cd\u5e94\u4ee3\u7801\u548c\u4e3b\u4f53\u3002<\/p>\nSpring WebFlux \u8def\u7531\u5668\u65b9\u6cd5<\/h3>\n
RouterFunction<\/code> \u5bf9\u8c61\u3002<\/p>\npackage com.Olivia.spring.component;\r\n\r\nimport org.springframework.context.annotation.Bean;\r\nimport org.springframework.context.annotation.Configuration;\r\nimport org.springframework.http.MediaType;\r\nimport org.springframework.web.reactive.function.server.RequestPredicates;\r\nimport org.springframework.web.reactive.function.server.RouterFunction;\r\nimport org.springframework.web.reactive.function.server.RouterFunctions;\r\nimport org.springframework.web.reactive.function.server.ServerResponse;\r\n\r\n@Configuration\r\npublic class HelloWorldRouter {\r\n\r\n\t@Bean\r\n\tpublic RouterFunction<ServerResponse> routeHelloWorld(HelloWorldHandler helloWorldHandler) {\r\n\r\n\t\treturn RouterFunctions.route(RequestPredicates.GET(\"\/helloWorld\")\r\n .and(RequestPredicates.accept(MediaType.TEXT_PLAIN)), helloWorldHandler::helloWorld);\r\n\t}\r\n}\r\n<\/code><\/pre>\n\/helloWorld<\/code> \u66b4\u9732\u4e86\u4e00\u4e2a GET \u65b9\u6cd5\uff0c\u5ba2\u6237\u7aef\u8c03\u7528\u65f6\u5e94\u63a5\u53d7\u7eaf\u6587\u672c\u54cd\u5e94\u3002<\/p>\nSpring Boot \u5e94\u7528\u7a0b\u5e8f<\/h3>\n
package com.Olivia.spring;\r\n\r\nimport org.springframework.boot.SpringApplication;\r\nimport org.springframework.boot.autoconfigure.SpringBootApplication;\r\n\r\n@SpringBootApplication\r\npublic class Application {\r\n\r\n\tpublic static void main(String[] args) {\r\n\t\tSpringApplication.run(Application.class, args);\r\n\t}\r\n}\r\n<\/code><\/pre>\nspring-boot-starter-webflux<\/code> \u6a21\u5757\u7684\u4f9d\u8d56\uff0cSpring Boot \u5c06\u81ea\u52a8\u914d\u7f6e\u6211\u4eec\u7684\u5e94\u7528\u7a0b\u5e8f\u4ee5\u652f\u6301 Spring WebFlux\u3002<\/p>\n\u652f\u6301 Java 9 \u6a21\u5757<\/h3>\n
module-info.java<\/code> \u7c7b\u3002<\/p>\nmodule com.Olivia.spring {\r\n requires reactor.core;\r\n requires spring.web;\r\n requires spring.beans;\r\n requires spring.context;\r\n requires spring.webflux;\r\n requires spring.boot;\r\n requires spring.boot.autoconfigure;\r\n exports com.Olivia.spring;\r\n}\r\n<\/code><\/pre>\n\u8fd0\u884c Spring WebFlux Spring Boot \u5e94\u7528\u7a0b\u5e8f<\/h3>\n
![\"Eclipse](\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/656474fba4b2f92e6c729e7d\/29-0.png\" "\\"\\"")
<\/div>\n2018-05-07 15:01:47.893 INFO 25158 --- [ main] o.s.w.r.f.s.s.RouterFunctionMapping : Mapped ((GET && \/helloWorld) && Accept: [text\/plain]) -> com.Olivia.spring.component.HelloWorldRouter$$Lambda$501\/704766954@6eeb5d56\r\n2018-05-07 15:01:48.495 INFO 25158 --- [ctor-http-nio-1] r.ipc.netty.tcp.BlockingNettyContext : Started HttpServer on \/0:0:0:0:0:0:0:0:8080\r\n2018-05-07 15:01:48.495 INFO 25158 --- [ main] o.s.b.web.embedded.netty.NettyWebServer : Netty started on port(s): 8080\r\n2018-05-07 15:01:48.501 INFO 25158 --- [ main] com.Olivia.spring.Application : Started Application in 1.86 seconds (JVM running for 5.542)\r\n<\/code><\/pre>\nSpring WebFlux \u5e94\u7528\u7a0b\u5e8f\u6d4b\u8bd5<\/h3>\n
1. \u4f7f\u7528CURL\u547d\u4ee4<\/h3>\n
$ curl https:\/\/localhost:8080\/helloWorld\r\nHello World!\r\n$<\/code><\/pre>\n2. \u5728\u6d4f\u89c8\u5668\u4e2d\u6253\u5f00URL<\/h3>\n
https:\/\/localhost:8080\/helloWorld<\/code>\u3002<\/p>\n3. \u4f7f\u7528Spring 5\u7684WebTestClient\u8fdb\u884c\u5355\u5143\u6d4b\u8bd5<\/h3>\n
WebTestClient<\/code> \u6d4b\u8bd5REST Web\u670d\u52a1\u7684JUnit\u6d4b\u8bd5\u793a\u4f8b\uff1a<\/p>\npackage com.Olivia.spring;\r\n\r\nimport org.junit.jupiter.api.Test;\r\nimport org.springframework.beans.factory.annotation.Autowired;\r\nimport org.springframework.boot.test.context.SpringBootTest;\r\nimport org.springframework.http.MediaType;\r\nimport org.springframework.test.web.reactive.server.WebTestClient;\r\n\r\n@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)\r\npublic class SpringWebFluxTest {\r\n\r\n @Autowired\r\n private WebTestClient webTestClient;\r\n\r\n @Test\r\n public void testHelloWorld() {\r\n webTestClient\r\n .get().uri(\"\/helloWorld\") \/\/ GET\u65b9\u6cd5\u548cURI\r\n .accept(MediaType.TEXT_PLAIN) \/\/ \u8bbe\u7f6eACCEPT\u5185\u5bb9\u7c7b\u578b\r\n .exchange() \/\/ \u53d1\u9001\u8bf7\u6c42\u5e76\u83b7\u53d6\u54cd\u5e94\r\n .expectStatus().isOk() \/\/ \u68c0\u67e5\u54cd\u5e94\u72b6\u6001\u662f\u5426\u4e3aOK (200)\r\n .expectBody(String.class).isEqualTo(\"Hello World!\"); \/\/ \u68c0\u67e5\u54cd\u5e94\u4f53\u7c7b\u578b\u548c\u5185\u5bb9\u662f\u5426\u4e00\u81f4\r\n }\r\n}\r\n<\/code><\/pre>\n4. \u4f7f\u7528Spring Web Reactive\u7684WebClient\u8c03\u7528REST Web\u670d\u52a1<\/h3>\n
WebClient<\/code> \u4e5f\u53ef\u4ee5\u7528\u4e8e\u8c03\u7528REST Web\u670d\u52a1\uff0c\u4ee5\u4e0b\u662f\u4e00\u4e2a\u793a\u4f8b\uff1a<\/p>\npackage com.Olivia.spring.client;\r\n\r\nimport org.springframework.http.MediaType;\r\nimport org.springframework.web.reactive.function.client.WebClient;\r\nimport reactor.core.publisher.Mono;\r\n\r\npublic class HelloWorldWebClient {\r\n\r\n public static void main(String[] args) {\r\n WebClient client = WebClient.create(\"https:\/\/localhost:8080\");\r\n\r\n Mono<String> result = client.get()\r\n .uri(\"\/helloWorld\")\r\n .accept(MediaType.TEXT_PLAIN)\r\n .retrieve() \/\/ \u66ff\u6362 exchange()\uff0c\u66f4\u7b80\u6d01\u5730\u83b7\u53d6\u54cd\u5e94\u4f53\r\n .bodyToMono(String.class); \/\/ \u5c06\u54cd\u5e94\u4f53\u8f6c\u6362\u4e3aMono<String>\r\n\r\n System.out.println(\"\u7ed3\u679c = \" + result.block());\r\n }\r\n}\r\n<\/code><\/pre>\n\u603b\u7ed3<\/h2>\n
\u53c2\u8003\uff1a<\/h3>\n