Spring Boot WebFlux 入门之 Hello World
WebFlux 在国外使用的已经非常的多了,在国内用的人还不算多,这和大多数公司所采用的技术有关。随着 java 的发展,我认为函数式编程、响应式编程,像 WebFlux 这种异步的、非阻塞的、事件驱动的服务框架会逐渐流行起来。所以我就开始研究并学习关于 WebFlux 这个框架用法,本文是 WebFlux 系列教程的第一章,欢迎大家关注!
关于 WebFlux 是什么,我就不介绍了,有兴趣的可以去看 Spring 的官网,或者在我的微信公众号里搜相关的视频。另外我在百度百家里也发了一篇文章来介绍它,这里就直接开始撸代码。
下面我们先新建一个 webflux-helloworld 工程。maven 的 pom.xml 配置如下:
<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-webflux</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
这里的 spring-webflow 我使用的是 2.5.0.RELEASE 的版本。
然后是 WebFluxApplication.java 类,和其他 SpringBoot 启动类一样,代码如下:
@SpringBootApplication
public class WebFluxApplication {
public static void main(String[] args) {
SpringApplication.run(WebFluxApplication.class, args);
}
}
再接着,我们新建 WebFlux 的 Router 类,类似 SpringMVC 中的 Controller 。代码如下:
@Configuration
public class HelloWebFlux {
@Bean
public RouterFunction<ServerResponse> helloXttblog(XttblogHandler handler) {
return RouterFunctions
.route(RequestPredicates.GET("/hello")
.and(RequestPredicates.accept(MediaType.TEXT_PLAIN)),
handler::helloXttblog);
}
}
接着创建 Handler 类。XttblogHandler.java 代码如下:
@Component
public class XttblogHandler {
public Mono<ServerResponse> helloXttblog(ServerRequest request) {
return ServerResponse.ok().contentType(MediaType.TEXT_PLAIN)
.body(BodyInserters.fromObject("Hello, www.xttblog.com !"));
}
}
最后运行启动 WebFluxApplication 类。我们在浏览器里输入 http://localhost:8080/hello,即可看到如下的内容:
WebFlux 的端口默认是 8080,在启动的日志中就可以看到。
这里其实有一个问题,我们的 fromObject 方法传递的是一个英文的字符串,如果是一个带有中文的字符串,浏览器就会出现乱码?
参考资料
本文由 创作,采用 知识共享署名4.0 国际许可协议进行许可。本站文章除注明转载/出处外,均为本站原创或翻译,转载前请务必署名。最后编辑时间为: 2021/04/21 02:25