如何在SpringWebFlux中整合Mono对象的结果？

Question

请查看以下使用RestTemplate的controller代码（添加注释）：

@GetMapping("/{courseid}")
public Course getCourseDetails(@PathVariable Long courseid) {

    // Get Course info (ID, Name, Description) from pre-populated Array List
    CourseInfo courseInfo = getCourseInfo(courseid);
    
    // Get Price info of a course from another microservice using RESTTemplate
    Price price = restTemplate.getForObject("http://localhost:8002/price/"+courseid, Price.class);
    
    // Get enrollment info of a course from another microservice using RESTTemplate
    Enrollment enrollment = restTemplate.getForObject("http://localhost:8003/enrollment/"+courseid, Enrollment.class);
    
    //Consolidate everything in to Course object and send it as response
    return new Course(courseInfo.getCourseID(), courseInfo.getCourseName(), courseInfo.getCourseDesc(), price.getDiscountedPrice(),
            enrollment.getEnrollmentOpen());
}

现在，我正试图通过反应式编程实现同样的目标。我现在使用WebFlux中的WebClient和Mono。但是，我很困惑如何将结果结合起来？看一看下面的代码（在任何地方都使用Mono，其余代码保持不变）

@GetMapping("/{courseid}")
public Mono<Course> getCourseDetails(@PathVariable Long courseid) {

    // Get Course info (ID, Name, Description) from pre-populated Array List
    CourseInfo courseInfo = getCourseInfo(courseid);
    
    // Get Price info of a course from another microservice using RESTTemplate
    Mono<Price> price = webClient.get().uri("http://localhost:8002/price/{courseid}/",courseid).retrieve().bodyToMono(Price.class);
    
    // Get enrollment info of a course from another microservice using RESTTemplate
    Mono<Enrollment> inventory = webClient.get().uri("http://localhost:8003/enrollment/{courseid}/",courseid).retrieve().bodyToMono(Enrollment.class);
    
    //Question : How do we Consolidate everything and form a Mono<Course> object and send it as response?
    
}

问题1：我们如何整合一切，形成一个Mono对象，并将其作为响应发送出去？

问题2：“CourseInfo CourseInfo=getCourseInfo（courseid）；”语句导致阻塞操作？

谢谢！

Answer 1

>

restTemplate.getForObject返回简单的对象-在您的情况下Price或注册。要将它们转换为Mono，您可以简单地Mono.just（对象），然而更好的解决方案是切换到WebClient，这是Spring Reactive的默认HTTP客户端

getCourseInfo这取决于此方法背后的逻辑。可以肯定的是，如果该方法后面有JDBC连接，那么它将被阻塞。

使用Mono进行最终响应

例如：

Mono<Course> courseMono = Mono.zip(price, enrollment)
        .map(tuple -> new Course(courseInfo, tuple.getT1(), tuple.getT2()));

Answer 2

答复：

问题1：我们如何整合一切，形成一个Mono对象，并将其作为响应发送出去？

莫诺。拉链（…）这是将两个结果结合起来所需要的。此图来自文档：

请注意，zip如果A或1中的一个为空，将导致一个空单声道！使用switchIfEmpty/defaultIfEmpty来防止这种情况。

因此，代码如下所示：

@GetMapping("/{courseid}")
public Mono<Course> getCourseDetails(@PathVariable Long courseid) {

    CourseInfo courseInfo = getCourseInfo(courseid);
    Mono<Price> priceMono = webClient.get().uri("http://localhost:8002/price/{courseid}/",courseid).retrieve().bodyToMono(Price.class);
    Mono<Enrollment> enrollmentMono = webClient.get().uri("http://localhost:8003/enrollment/{courseid}/",courseid).retrieve().bodyToMono(Enrollment.class);
    
    return Mono.zip(priceMono, enrollmentMono).map(t -> new Course(courseInfo.getCourseID(), courseInfo.getCourseName(), courseInfo.getCourseDesc(), t.getT1().getDiscountedPrice(),
            t.getT2().getEnrollmentOpen()));
    
}

现在回答：

问题2：“CourseInfo CourseInfo=getCourseInfo（courseid）；”语句导致阻塞操作？

既然你提到了从预填充的数组列表中获取课程信息（ID，名称，描述），如果它只是一个包含课程信息的内存数组，那么它不是阻塞的。

但是（正如@mslowiak也提到的），如果getCourseInfo包含涉及查询数据库的逻辑，请确保您没有使用阻塞JDBC驱动程序。如果是这样，那么使用Webflux和Reactor就没有意义了。如果是这种情况，请使用Spring R2DBC。