這期內(nèi)容當(dāng)中小編將會給大家?guī)碛嘘P(guān)Spring Boot中怎么利用RxJava構(gòu)建響應(yīng)式REST API,文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述,閱讀完這篇文章希望大家可以有所收獲。
灌陽網(wǎng)站制作公司哪家好,找創(chuàng)新互聯(lián)公司!從網(wǎng)頁設(shè)計、網(wǎng)站建設(shè)、微信開發(fā)、APP開發(fā)、響應(yīng)式網(wǎng)站等網(wǎng)站項目制作,到程序開發(fā),運營維護。創(chuàng)新互聯(lián)公司2013年開創(chuàng)至今到現(xiàn)在10年的時間,我們擁有了豐富的建站經(jīng)驗和運維經(jīng)驗,來保證我們的工作的順利進行。專注于網(wǎng)站建設(shè)就選創(chuàng)新互聯(lián)公司。
響應(yīng)式REST API
構(gòu)建一個只包含作者和書籍的簡單CRUD
響應(yīng)式REST API
。這些是端點:
[POST] /api/authors → 添加作者
[POST] /api/books → 添加書籍
[PUT] /api/books/{bookId} → 根據(jù)書籍id更新書籍信息
[GET] /api/books?limit={limit}&page={page} → 分頁獲取書籍列表
[GET] /api/book/{bookId} → 根據(jù)書籍id獲取書籍詳細信息
[DELETE] /api/book/{bookId} → 刪除書籍
打開pom.xml并添加如下依賴項。
<dependencies> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-web</artifactid> <version>2.1.5.RELEASE</version> </dependency> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-data-jpa</artifactid> <version>2.1.5.RELEASE</version> </dependency> <dependency> <groupid>io.reactivex</groupid> <artifactid>rxjava</artifactid> <version>1.3.8</version> </dependency> <!--IMPORTANT!!! ADD THIS DEPENDENCY TO SOLVE HttpMediaNotAcceptableException--> <dependency> <groupid>io.reactivex</groupid> <artifactid>rxjava-reactive-streams</artifactid> <version>1.2.1</version> </dependency> <dependency> <groupid>com.h3database</groupid> <artifactid>h3</artifactid> <version>1.4.199</version> </dependency> <dependency> <groupid>org.projectlombok</groupid> <artifactid>lombok</artifactid> <optional>true</optional> <version>1.18.8</version> </dependency> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-test</artifactid> <version>2.1.5.RELEASE</version> <scope>test</scope> </dependency> <dependency> <groupid>org.mockito</groupid> <artifactid>mockito-core</artifactid> <version>2.25.0</version> <scope>test</scope> </dependency> </dependencies>
備注: 請記住,您必須添加第19-23行依賴項。如果您不添加該依賴項,那么每次您點擊響應(yīng)式API時都會得到HttpMediaNotAcceptableException
。如您所見,我還添加了mockito
作為單元測試中mock對象的依賴項。但是我將在另一篇文章中討論單元測試。
對于服務(wù)層,返回值不僅僅是常規(guī)數(shù)據(jù)類型,而是我將它們封裝在RxJava
的Single
(單一)數(shù)據(jù)類型中。例如,下面的代碼處理新書的添加。
@Override public Single<string> addBook(AddBookRequest addBookRequest) { return saveBookToRepository(addBookRequest); } private Single<string> saveBookToRepository(AddBookRequest addBookRequest) { return Single.create(singleSubscriber -> { Optional<author> 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
中的字符串。
@PostMapping( consumes = MediaType.APPLICATION_JSON_VALUE, produces = MediaType.APPLICATION_JSON_VALUE ) public Single<responseentity<basewebresponse>> 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構(gòu)建響應(yīng)式REST API了,如果剛好有類似的疑惑,不妨參照上述分析進行理解。如果想知道更多相關(guān)知識,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
名稱欄目:SpringBoot中怎么利用RxJava構(gòu)建響應(yīng)式RESTAPI
URL分享:http://bm7419.com/article22/goegcc.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供App設(shè)計、網(wǎng)頁設(shè)計公司、小程序開發(fā)、做網(wǎng)站、網(wǎng)站設(shè)計、Google
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)