Spring Webflux和可观察响应不工作

Question

如果创建一个简单的@RestController并提供一个@GetMapping来返回一个Flux ，那么一切都能按照预期工作。

但是，如果我从flux更改为rxjava的observable，我会得到这个错误：

org.springframework.web.HttpMediaTypeNotAcceptableException: Could not find acceptable representation

对代码进行了一些调试，我发现Jackson的ObjectMapper以某种方式在其typeFactory中注册了Flux、Mono和其余的反应类型，因此稍后的MappingJackson2HttpMessageConverter知道如何（去）序列化它们。

但是，当我使用observable时就不是这样了：我在ObjectMapper的类型工厂中找不到注册的observable或single类型，因此我得到了前面提到的错误。

有人经历过这个问题吗？我错过了什么依赖吗？我需要手动告诉Jackson如何从RxJava构造中（去）序列化吗？但是为什么杰克逊已经知道Flux和Mono了呢？

谢谢你的帮助。

我使用的是RXJava1.2.7。下面是我的pom.xml：

<dependencies>
    <!-- Spring Boot -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-webflux</artifactId>
        <version>2.0.0.BUILD-SNAPSHOT</version>
    </dependency>
    <!-- RxJava dependeencies -->
    <dependency>
        <groupId>io.reactivex</groupId>
        <artifactId>rxjava</artifactId>
        <version>1.2.7</version>
    </dependency>
</dependencies>

下面是我的控制器代码示例：

/**
 * Get all the available tasks.
 *
 * @return the list of tasks
 */
@GetMapping(path = "/task")
@ResponseStatus(HttpStatus.OK)
public Observable<TaskView> allTasks(@AuthenticationPrincipal LoggedUserVO principal) {
    return this.pocComponent.getAllTasks()
            .map(t -> ViewConverter.convertFromTaskDocument(t, principal));
}

Answer 1

您可能缺少以下依赖项来使其正常工作：

<dependency>
    <groupId>io.reactivex</groupId>
    <artifactId>rxjava-reactive-streams</artifactId>
    <version>1.2.1</version>
</dependency>

各种RXJava1.x版本的变化使我们很难支持它，这就是为什么我们更喜欢依赖官方的RXJava->Reactive Streams适配器。请注意，RXJava2.x不需要额外的依赖关系就被支持（它本机构建在反应流之上）。

我将更新Spring WebFlux参考文档，指定这是RXJava1.x支持所必需的。