我不打算解釋什麼是響應式程式設計，也不解釋為什麼要使用它。我希望你已經在其他地方瞭解過，如果沒有，你可以使用Google去搜索它。在本文中，我將告訴您如何使用專門針對Spring Boot和RxJava的響應式程式設計。讓我們開始吧。

1.預備知識

在你繼續閱讀之前，我希望你能理解如何使用Spring Boot和RxJava建立簡單的REST API。 如果不能，你可以在Baeldung上了解更多關於Spring Boot的知識，也可以在AndroidHive上了解更多關於RxJava的知識。它們很好地解釋了這兩種技術。

2.響應式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並新增如下依賴項。

<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.h2database</groupid>
            <artifactid>h2</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行依賴項。如果您不新增該依賴項，那麼每次您點選響應式API時都會得到HttpMediaNotAcceptableException。如您所見，我還添加了mockito作為單元測試中mock物件的依賴項。但是我將在另一篇文章中討論單元測試。

4.服務層

對於服務層，返回值不僅僅是常規資料型別，而是我將它們封裝在RxJava的Single(單一)資料型別中。例如，下面的程式碼處理新書的新增。

@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方法的返回值是一個封裝在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;
    }

在web層中，它只是將請求轉發給相應的服務，如上所示，用於處理新書的新增。

6.結束

整個程式碼(+單元測試)可以在GitHub上找到。

> 原文：https://dzone.com/articles/reactive-rest-api-using-spring-boot-and-rxjava-1 > > 作者： Axellageraldinc A > > 譯者：李東

9月福利，關注公眾號 ​ 後臺回覆：004，領取8月翻譯集錦! ​ 往期福利回覆：001，002, 003即可領取！

</responseentity<basewebresponse></author></stri