Spring Boot 2 快速教程:WebFlux Restful CRUD 实践(三)

  • 时间:
  • 浏览:0
  • 来源:大发pk10_pk10信誉网_大发pk10信誉网

摘要: 原创出处 https://www.bysocket.com 「公众号:泥瓦匠BYSocket 」欢迎关注和转载,保留摘要,谢谢!

这是泥瓦匠的第102篇原创

文章工程:

* JDK 1.8

* Maven 3.5.2

* Spring Boot 2.1.3.RELEASE

* 工程名:springboot-webflux-2-restful

* 工程地址:见文末

一、前言

上一篇基于功能性端点去创建另另一个多 简单服务,实现了 Hello 。五种篇用 Spring Boot WebFlux 的注解控制层技术创建另另一个多 CRUD WebFlux 应用,让开发更方便。这里当一群人 儿不对数据库储存进行访问,意味着着后续会讲到,否则 这里主也不讲另另一个多 删改的 WebFlux CRUD。

二、底部形态

五种工程会对城市(City)进行管理实现 CRUD 操作。该工程创建编写后,得到下面的底部形态,其目录底部形态如下:

├── pom.xml
├── src
│   └── main
│       ├── java
│       │   └── org
│       │       └── spring
│       │           └── springboot
│       │               ├── Application.java
│       │               ├── dao
│       │               │   └── CityRepository.java
│       │               ├── domain
│       │               │   └── City.java
│       │               ├── handler
│       │               │   └── CityHandler.java
│       │               └── webflux
│       │                   └── controller
│       │                       └── CityWebFluxController.java
│       └── resources
│           └── application.properties
└── target

如目录底部形态,当一群人 儿非要编写的内容按顺序有:

  • 对象
  • 数据访问层类 Repository
  • 外理器类 Handler
  • 控制器类 Controller

三、对象

新建包 org.spring.springboot.domain ,作为编写城市实体对象类。新建城市(City)对象 City,代码如下:

城市暗含了城市编号、省份编号、城市名称和描述。具体开发中,会使用 Lombok 工具来消除冗长的 Java 代码,尤其是 POJO 的 getter / setter 土办法。具体查看 Lombok 官网地址:projectlombok.org。

四、数据访问层 CityRepository

新建包 org.spring.springboot.dao ,作为编写城市数据访问层类 Repository。新建 CityRepository,代码如下:

import org.spring.springboot.domain.City;
import org.springframework.stereotype.Repository;

import java.util.Collection;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.atomic.AtomicLong;

@Repository
public class CityRepository {

    private ConcurrentMap<Long, City> repository = new ConcurrentHashMap<>();

    private static final AtomicLong idGenerator = new AtomicLong(0);

    public Long save(City city) {
        Long id = idGenerator.incrementAndGet();
        city.setId(id);
        repository.put(id, city);
        return id;
    }

    public Collection<City> findAll() {
        return repository.values();
    }


    public City findCityById(Long id) {
        return repository.get(id);
    }

    public Long updateCity(City city) {
        repository.put(city.getId(), city);
        return city.getId();
    }

    public Long deleteCity(Long id) {
        repository.remove(id);
        return id;
    }
}

@Repository 用于标注数据访问组件,即 DAO 组件。实现代码中使用名为 repository 的 Map 对象作为内存数据存储,并对对象具体实现了具体业务逻辑。CityRepository 负责将 Book 持久层(数据操作)相关的封装组织,完成新增、查询、删除等操作。

这里不要再涉及到数据存储这块,具体数据存储会在后续介绍。

五、外理器类 Handler

新建包 org.spring.springboot.handler ,作为编写城市外理器类 CityHandler。新建 CityHandler,代码如下:

import org.spring.springboot.dao.CityRepository;
import org.spring.springboot.domain.City;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

@Component
public class CityHandler {

    private final CityRepository cityRepository;

    @Autowired
    public CityHandler(CityRepository cityRepository) {
        this.cityRepository = cityRepository;
    }

    public Mono<Long> save(City city) {
        return Mono.create(cityMonoSink -> cityMonoSink.success(cityRepository.save(city)));
    }

    public Mono<City> findCityById(Long id) {
        return Mono.justOrEmpty(cityRepository.findCityById(id));
    }

    public Flux<City> findAllCity() {
        return Flux.fromIterable(cityRepository.findAll());
    }

    public Mono<Long> modifyCity(City city) {
        return Mono.create(cityMonoSink -> cityMonoSink.success(cityRepository.updateCity(city)));
    }

    public Mono<Long> deleteCity(Long id) {
        return Mono.create(cityMonoSink -> cityMonoSink.success(cityRepository.deleteCity(id)));
    }
}

@Component 泛指组件,当组件不好归类的以前,使用该注解进行标注。否则 用 final 和 @Autowired 标注在构造器注入 CityRepository Bean,代码如下:

    private final CityRepository cityRepository;

    @Autowired
    public CityHandler(CityRepository cityRepository) {
        this.cityRepository = cityRepository;
    }

从返回值能才能看出,Mono 和 Flux 适用于另另一个多 场景,即:

  • Mono:实现发布者,并返回 0 或 1 个元素,即单对象
  • Flux:实现发布者,并返回 N 个元素,即 List 列表对象

一群人会问,这为什么么么在不直接返回对象,比如返回 City/Long/List。意味着着是,直接使用 Flux 和 Mono 是非阻塞写法,最少回调土办法。利用函数式能才能减少了回调,否则 会看非要相关接口。反应了是 WebFlux 的好处:集合了非阻塞 + 异步。

5.1 Mono

Mono 是有哪些? 官方描述如下:A Reactive Streams Publisher with basic rx operators that completes successfully by emitting an element, or with an error.

Mono 是响应流 Publisher ,即要么成功发布元素,要么错误。如图所示:

Mono 常用的土办法有:

  • Mono.create():使用 MonoSink 来创建 Mono
  • Mono.justOrEmpty():从另另一个多 Optional 对象或 null 对象中创建 Mono。
  • Mono.error():创建另另一个多 只暗含错误消息的 Mono
  • Mono.never():创建另另一个多 不暗含任何消息通知的 Mono
  • Mono.delay():在指定的延迟时间以前,创建另另一个多 Mono,产生数字 0 作为唯一值

5.2 Flux

Flux 是有哪些? 官方描述如下:A Reactive Streams Publisher with rx operators that emits 0 to N elements, and then completes (successfully or with an error).

Flux 是响应流 Publisher ,即要么成功发布 0 到 N 个元素,要么错误。Flux 实在是 Mono 的另另一个多 补充。如图所示:

也不 要注意:意味着着知道 Publisher 是 0 或 1 个,则用 Mono。

Flux 最值得一提的是 fromIterable 土办法。fromIterable(Iterable<? extends T> it) 能才能发布 Iterable 类型的元素。当然,Flux 也暗含了基础的操作:map、merge、concat、flatMap、take,这里就不展开介绍了。

六、控制器类 Controller

Spring Boot WebFlux 才能才能使用自动配置加注解驱动的模式来进行开发。

新建包目录 org.spring.springboot.webflux.controller ,并在目录中创建名为 CityWebFluxController 来外理不同的 HTTP Restful 业务请求。代码如下:

import org.spring.springboot.domain.City;
import org.spring.springboot.handler.CityHandler;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

@RestController
@RequestMapping(value = "/city")
public class CityWebFluxController {

    @Autowired
    private CityHandler cityHandler;

    @GetMapping(value = "/{id}")
    public Mono<City> findCityById(@PathVariable("id") Long id) {
        return cityHandler.findCityById(id);
    }

    @GetMapping()
    public Flux<City> findAllCity() {
        return cityHandler.findAllCity();
    }

    @PostMapping()
    public Mono<Long> saveCity(@RequestBody City city) {
        return cityHandler.save(city);
    }

    @PutMapping()
    public Mono<Long> modifyCity(@RequestBody City city) {
        return cityHandler.modifyCity(city);
    }

    @DeleteMapping(value = "/{id}")
    public Mono<Long> deleteCity(@PathVariable("id") Long id) {
        return cityHandler.deleteCity(id);
    }
}

这里按照 REST 风格实现接口。那具体有哪些是 REST?

REST 是属于 WEB 自身的五种架构风格,是在 HTTP 1.1 规范下实现的。Representational State Transfer 全称翻译为表现层情况报告转化。Resource:资源。比如 newsfeed;Representational:表现形式,比如用JSON,富文本等;State Transfer:情况报告变化。通过HTTP 动作实现。

理解 REST ,要明白3个关键每项:

  • 资源(Resource)
  • 资源的表述(Representation)
  • 情况报告转移(State Transfer)
  • 统一接口(Uniform Interface)
  • 超文本驱动(Hypertext Driven)

6 个主要底部形态:

  • 面向资源(Resource Oriented)
  • 可寻址(Addressability)
  • 连通性(Connectedness)
  • 无情况报告(Statelessness)
  • 统一接口(Uniform Interface)
  • 超文本驱动(Hypertext Driven)

具体这里就不一一展开,详见 http://www.infoq.com/cn/articles/understanding-restful-style。

请求入参、Filters、重定向、Conversion、formatting 等知识会和以前 MVC 的知识一样,详情见文档:

https://docs.spring.io/spring/docs/current/spring-framework-reference/web-reactive.html

七、运行工程

另另一个多 CRUD 的 Spring Boot Webflux 工程就开发完毕了,下面运行工程验证下。使用 IDEA 右侧工具栏,点击 Maven Project Tab ,点击使用下 Maven 插件的 install 命令。意味着着使用命令行的形式,在工程根目录下,执行 Maven 清理和安装工程的指令:

cd springboot-webflux-2-restful
mvn clean install

在控制台中想看 成功的输出:

... 省略
[INFO] ------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 01:30 min
[INFO] Finished at: 2017-10-15T10:00:54+08:00
[INFO] Final Memory: 31M/174M
[INFO] ------------------------------------------------------------------------

在 IDEA 中执行 Application 类启动,任意正常模式意味着着 Debug 模式。能才能在控制台想看 成功运行的输出:

... 省略
2018-04-10 08:43:39.932  INFO 2052 --- [ctor-http-nio-1] r.ipc.netty.tcp.BlockingNettyContext     : Started HttpServer on /0:0:0:0:0:0:0:0:3030
2018-04-10 08:43:39.935  INFO 2052 --- [           main] o.s.b.web.embedded.netty.NettyWebServer  : Netty started on port(s): 3030
2018-04-10 08:43:39.930  INFO 2052 --- [           main] org.spring.springboot.Application        : Started Application in 6.547 seconds (JVM running for 9.851)

打开 POST MAN 工具,开发必备。进行下面操作:

新增城市信息 POST http://127.0.0.1:3030/city

获取城市信息列表 GET http://127.0.0.1:3030/city

许多接口就不演示了。

八、总结

这里,探讨了 Spring WebFlux 的许多功能,构建那末 底层数据库的基本 CRUD 工程。为了更好的展示了怎么才能 才能 创建 Flux 流,以及怎么才能 才能 对其进行操作。下面会讲到怎么才能 才能 操作数据存储。

系列教程目录

  • 《01:WebFlux 系列教程大纲》
  • 《02:WebFlux 快速入门实践》
  • 《03:WebFlux Web CRUD 实践》
  • 《04:WebFlux 整合 Mongodb》
  • 《05:WebFlux 整合 Thymeleaf》
  • 《06:WebFlux 中 Thymeleaf 和 Mongodb 实践》
  • 《07:WebFlux 整合 Redis》
  • 《08:WebFlux 中 Redis 实现缓存》
  • 《09:WebFlux 中 WebSocket 实现通信》
  • 《10:WebFlux 集成测试及部署》
  • 《11:WebFlux 实战图书管理系统》

代码示例

本文示例读者能才能通过查看下面仓库的中的模块工程名: 2-x-spring-boot-webflux-handling-errors:

  • Github:https://github.com/JeffLi1993/springboot-learning-example
  • Gitee:https://gitee.com/jeff1993/springboot-learning-example

意味着着您对有有哪些感兴趣,欢迎 star、follow、收藏、转发给予支持!

参考资料

  • Spring Boot 2.x WebFlux 系列:https://www.bysocket.com/archives/2290
  • spring.io 官方文档

以下专题教程你说歌词 您会有兴趣

  • 《Spring Boot 2.x 系列教程》 https://www.bysocket.com/springboot
  • 《Java 核心系列教程》 https://www.bysocket.com/archives/230

(关注微信公众号,领取 Java 精选干货学习资料) 

(添加我微信:bysocket01。加入纯技术交流群,成长技术)