Spring Webflux客户端

栏目: Java · 发布时间: 7年前

内容简介:在上一篇文章中,我们介绍了Web响应服务器,这次我们将看到如何编写客户端。让我们开始创建一个新项目,将Webflux,Mongo Reactive和Lombok作为依赖项。创建一个简单的POJO来从我们的Reactive服务器中检索信息。Lombok是一个避免样板代码的好工具,了解更多信息请到

在上一篇文章中,我们介绍了Web响应服务器,这次我们将看到如何编写客户端。让我们开始创建一个新项目,将Webflux,Mongo Reactive和Lombok作为依赖项。

创建一个简单的POJO来从我们的Reactive服务器中检索信息。

@Document
@AllArgsConstructor
@ToString
@NoArgsConstructor
@Data
<b>public</b> <b>class</b> Person {

  @Id
  <b>private</b> String uuid;
  <b>private</b> String nickname;
  <b>private</b> String email;

}

Lombok是一个避免样板代码的好工具,了解更多信息请到 这里

接下来,我们将CommandLineRunner用于启动我们的工作流程。这CommandLineRunner是Spring Boot中的回调接口,当Spring Boot启动时会调用它并传入args调用run()内部方法 。

@SpringBootApplication
<b>public</b> <b>class</b> PersonApplication {

  <b>public</b> <b>static</b> <b>void</b> main(String[] args) {
    SpringApplication.run(PersonApplication.<b>class</b>, args);
  }

  @Bean
  WebClient webClient() {
    <b>return</b> WebClient.create(<font>"http://localhost:8080/persons"</font><font>);
  }

  @Bean
  CommandLineRunner run(WebClient client){
    <b>return</b> args -> {
      client.get().uri(</font><font>""</font><font>).retrieve()
        .bodyToFlux(Person.<b>class</b>)
        .subscribe(System.out::println);
    };
  }

}
</font>

WebClient是定义为@Bean使用我们的响应式Web服务器执行非阻塞HTTP请求的Reactive客户端,默认情况下使用Netty。

不要忘记在我们的application.properties文件中使用以下规范在不同的端口运行此客户端:

server.port=8081

请转到 此处 下载项目:


以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

XML Hacks

XML Hacks

Michael Fitzgerald / O'Reilly Media, Inc. / 2004-07-27 / USD 24.95

Developers and system administrators alike are uncovering the true power of XML, the Extensible Markup Language that enables data to be sent over the Internet from one computer platform to another or ......一起来看看 《XML Hacks》 这本书的介绍吧!

随机密码生成器
随机密码生成器

多种字符组合密码

HTML 编码/解码
HTML 编码/解码

HTML 编码/解码

Base64 编码/解码
Base64 编码/解码

Base64 编码/解码