Spring Webflux入门

Spring Boot现在采用了反应式编程(响应式Reactive),它是一种非阻塞的异步应用程序和事件驱动编程。Spring Framework在内部使用Reactor支持这种Reactive支持,Reactor是一个Reactive Streams实现,它进一步扩展了Publisher模型Flux和Mono。

让我们开始创建一个新的Spring Boot项目,将Webflux,Mongo Reactive和Lombok作为依赖项。

spring init –dependencies=webflux,data-mongodb-reactive,lombok –build=gradle –language=java reactive-webflux-workshop

现在让我们创建一个简单的POJO来存储和检索MongoDB中的信息:

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

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

}

Lombok的@Data注释生成getter和setter方法,toString(),equals(),hashcode()并为每个对象创建一个构造函数。

Spring Data现在支持MongoDB,Couchbase,Redis和Casandra的全面反应体验,在这种情况下,让我们创建一个PersonRepository实现ReactiveMongoRepository:

<b>import</b> org.springframework.data.mongodb.repository.ReactiveMongoRepository;
<b>import</b> reactor.core.publisher.Flux;
<b>import</b> com.jos.dem.webflux.model.Person;

<b>public</b> <b>interface</b> PersonRepository <b>extends</b> ReactiveMongoRepository<Person, String> {}

我们将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
  CommandLineRunner start(){
    <b>return</b> args -> {
      System.out.println(<font>"Hello World!"</font><font>);
    };
  }

}
</font>

进一步定制start方法:创建人员列表并将其存储在MongoDB中:

@Bean
  CommandLineRunner start(PersonRepository personRepository){
    <b>return</b> args -> {
      Stream.of(<font>"josdem"</font><font>, </font><font>"tgrip"</font><font>, </font><font>"edzero"</font><font>, </font><font>"skuarch"</font><font>, </font><font>"siedrix"</font><font>)
      .map(nickname -> <b>new</b> Person(UUID.randomUUID().toString(), nickname, nickname + </font><font>"@email.com"</font><font>))
      .forEach(person -> personRepository.save(person).subscribe());
    };
  }
</font>

重要信息:在上面函数运算符中实现的逻辑仅在数据开始流动时执行,也就是直到使用subscribe()方法才会执行。

现在我们将Person对象存储到MongoDB,让我们添加一些代码来清理我们的数据库,插入和显示人员。

@Bean
  CommandLineRunner start(PersonRepository personRepository){
    <b>return</b> args -> {
      personRepository.deleteAll().subscribe();

      Stream.of(<font>"josdem"</font><font>, </font><font>"tgrip"</font><font>, </font><font>"edzero"</font><font>, </font><font>"skuarch"</font><font>, </font><font>"siedrix"</font><font>)
      .map(nickname -> <b>new</b> Person(UUID.randomUUID().toString(), nickname, nickname + </font><font>"@email.com"</font><font>))
      .forEach(person -> personRepository.save(person).subscribe());

      personRepository.findAll().log().subscribe(System.out::println);
    };
  }
</font>

为了运行这个例子,你需要在MongoDB中创建一个数据库authorization: "enabled"。另外,不要忘记将MongoDB凭据信息添加到您的application.properties文件中:

spring.data.mongodb.database=reactive_webflux

spring.data.mongodb.host=localhost

spring.data.mongodb.username=username

spring.data.mongodb.password=password

要浏览项目,请转到 此处
下载项目。

原文 

https://www.jdon.com/50544

本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。

PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处:Harries Blog™ » Spring Webflux入门

赞 (0)
分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址