這期內(nèi)容當(dāng)中小編將會(huì)給大家?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è)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、APP開發(fā)、響應(yīng)式網(wǎng)站等網(wǎng)站項(xiàng)目制作，到程序開發(fā)，運(yùn)營維護(hù)。創(chuàng)新互聯(lián)公司2013年開創(chuàng)至今到現(xiàn)在10年的時(shí)間，我們擁有了豐富的建站經(jīng)驗(yàn)和運(yùn)維經(jīng)驗(yàn)，來保證我們的工作的順利進(jìn)行。專注于網(wǎng)站建設(shè)就選創(chuàng)新互聯(lián)公司。

響應(yīng)式REST API

構(gòu)建一個(gè)只包含作者和書籍的簡單CRUD響應(yīng)式REST API。這些是端點(diǎn):

[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獲取書籍詳細(xì)信息

[DELETE] /api/book/{bookId} → 刪除書籍

3.依賴

打開pom.xml并添加如下依賴項(xiàng)。

<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>

備注： 請(qǐng)記住，您必須添加第19-23行依賴項(xiàng)。如果您不添加該依賴項(xiàng)，那么每次您點(diǎn)擊響應(yīng)式API時(shí)都會(huì)得到HttpMediaNotAcceptableException。如您所見，我還添加了mockito作為單元測試中mock對(duì)象的依賴項(xiàng)。但是我將在另一篇文章中討論單元測試。

4.服務(wù)層

對(duì)于服務(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 -&gt; {
            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方法的返回值是一個(gè)封裝在RxJava中的字符串。

5.web層

@PostMapping(
            consumes = MediaType.APPLICATION_JSON_VALUE,
            produces = MediaType.APPLICATION_JSON_VALUE
    )
    public Single<responseentity<basewebresponse>&gt; addBook(@RequestBody AddBookWebRequest addBookWebRequest) {
        return bookService.addBook(toAddBookRequest(addBookWebRequest))
                .subscribeOn(Schedulers.io())
                .map(s -&gt; 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了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

名稱欄目：SpringBoot中怎么利用RxJava構(gòu)建響應(yīng)式RESTAPI
URL分享：http://chinadenli.net/article22/goegcc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供App設(shè)計(jì)、網(wǎng)頁設(shè)計(jì)公司、小程序開發(fā)、做網(wǎng)站、網(wǎng)站設(shè)計(jì)、Google

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)