SpringBoot中怎么利用RxJava构建响应式RESTAPI
这期内容当中小编将会给大家带来有关Spring Boot中怎么利用RxJava构建响应式REST API,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。
灌阳网站制作公司哪家好,找创新互联公司!从网页设计、网站建设、微信开发、APP开发、响应式网站等网站项目制作,到程序开发,运营维护。创新互联公司2013年开创至今到现在10年的时间,我们拥有了丰富的建站经验和运维经验,来保证我们的工作的顺利进行。专注于网站建设就选创新互联公司。
响应式REST API
构建一个只包含作者和书籍的简单CRUD
响应式REST API
。这些是端点:
[POST] /api/authors → 添加作者
[POST] /api/books → 添加书籍
[PUT] /api/books/{bookId} → 根据书籍id更新书籍信息
[GET] /api/books?limit={limit}&page={page} → 分页获取书籍列表
[GET] /api/book/{bookId} → 根据书籍id获取书籍详细信息
[DELETE] /api/book/{bookId} → 删除书籍
3.依赖
打开pom.xml并添加如下依赖项。
org.springframework.boot spring-boot-starter-web 2.1.5.RELEASE org.springframework.boot spring-boot-starter-data-jpa 2.1.5.RELEASE io.reactivex rxjava 1.3.8 io.reactivex rxjava-reactive-streams 1.2.1 com.h3database h3 1.4.199 org.projectlombok lombok true 1.18.8 org.springframework.boot spring-boot-starter-test 2.1.5.RELEASE test org.mockito mockito-core 2.25.0 test
备注: 请记住,您必须添加第19-23行依赖项。如果您不添加该依赖项,那么每次您点击响应式API时都会得到HttpMediaNotAcceptableException
。如您所见,我还添加了mockito
作为单元测试中mock对象的依赖项。但是我将在另一篇文章中讨论单元测试。
4.服务层
对于服务层,返回值不仅仅是常规数据类型,而是我将它们封装在RxJava
的Single
(单一)数据类型中。例如,下面的代码处理新书的添加。
@Override public SingleaddBook(AddBookRequest addBookRequest) { return saveBookToRepository(addBookRequest); } private Single saveBookToRepository(AddBookRequest addBookRequest) { return Single.create(singleSubscriber -> { Optional optionalAuthor = authorRepository.findById(addBookRequest.getAuthorId()); if (!optionalAuthor.isPresent()) singleSubscriber.onError(new EntityNotFoundException()); else { String addedBookId = bookRepository.save(toBook(addBookRequest)).getId(); singleSubscriber.onSuccess(addedBookId); } }); } private Book toBook(AddBookRequest addBookRequest) { Book book = new Book(); BeanUtils.copyProperties(addBookRequest, book); book.setId(UUID.randomUUID().toString()); book.setAuthor(Author.builder() .id(addBookRequest.getAuthorId()) .build()); return book; }
正如您所看到的,addBook
方法的返回值是一个封装在RxJava
中的字符串。
5.web层
@PostMapping( consumes = MediaType.APPLICATION_JSON_VALUE, produces = MediaType.APPLICATION_JSON_VALUE ) public Single> addBook(@RequestBody AddBookWebRequest addBookWebRequest) { return bookService.addBook(toAddBookRequest(addBookWebRequest)) .subscribeOn(Schedulers.io()) .map(s -> ResponseEntity.created(URI.create("/api/books/" + s)).body(BaseWebResponse.successNoData())); } private AddBookRequest toAddBookRequest(AddBookWebRequest addBookWebRequest) { AddBookRequest addBookRequest = new AddBookRequest(); BeanUtils.copyProperties(addBookWebRequest, addBookRequest); return addBookRequest; }
上述就是小编为大家分享的Spring Boot中怎么利用RxJava构建响应式REST API了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注创新互联行业资讯频道。
当前文章:SpringBoot中怎么利用RxJava构建响应式RESTAPI
分享网址:http://ybzwz.com/article/goegcc.html